nsq-简单启动说明
简介NSQ 是实时的分布式消息处理平台,其设计的目的是用来大规模地处理每天数以十亿计级别的消息。它具有分布式和去中心化拓扑结构,该结构具有无单点故障、故障容错、高可用性以及能够保证消息的可靠传递的特征
nsqlookupd
会监听两个端口:
- http: 4161 客户端用它来发现和管理。
- tcp: 4160 nsqd 用它来广播
支持参数
- -http-address=”0.0.0.0:4161”:
: 监听 HTTP 客户端 - -inactive-producer-timeout=5m0s: 从上次 ping 之后,生产者驻留在活跃列表中的时长
- -tcp-address=”0.0.0.0:4160”: TCP 客户端监听的
: - -broadcast-address: 这个 lookupd 节点的外部地址, (默认是 OS 主机名)
- -tombstone-lifetime=45s: 生产者保持 tombstoned 的时长
- -verbose=false: 允许输出日志
- -version=false: 打印版本信息
nsqd
nsqd —lookupd-tcp-address=127.0.0.1:4160
会监听两个端口:
- http: 4151
- tcp: 4150
nsqd 是一个守护进程,负责接收,排队,投递消息给客户端。
nsqadmin
nsqadmin —lookupd-http-address=127.0.0.1:4161
监听一个端口
http:4171
推送数据
curl -d ‘hello world 1’ ‘http://127.0.0.1:4151/put?topic=test‘
打印数据
nsq_to_file —topic=test —output-dir=/tmp —lookupd-http-address=127.0.0.1:4161