nsq 使用

安装

• https://nsq.io/deployment/installing.html

启动服务nsqlookupd

$ nsqlookupd

[nsqlookupd] 2019/02/22 10:19:43.003107 INFO: nsqlookupd v1.1.0 (built w/go1.10.3)
[nsqlookupd] 2019/02/22 10:19:43.003298 INFO: TCP: listening on [::]:4160
[nsqlookupd] 2019/02/22 10:19:43.003322 INFO: HTTP: listening on [::]:4161

• 4161 是http 消费监听端口
• 4160 是nsqd 用的端口

启动nsqd

$ nsqd -lookupd-tcp-address=127.0.0.1:4160

[nsqd] 2019/02/22 10:23:54.934847 INFO: LOOKUP(127.0.0.1:4160): adding peer
[nsqd] 2019/02/22 10:23:54.934861 INFO: LOOKUP connecting to 127.0.0.1:4160
[nsqd] 2019/02/22 10:23:54.934938 INFO: HTTP: listening on [::]:4151
[nsqd] 2019/02/22 10:23:54.934995 INFO: TCP: listening on [::]:4150

• 4151 是http生产监听接口

生产数据

curl -d 'hello world 3' 'http://127.0.0.1:4151/pub?topic=test'

• 生产数据的时候topic参数来发送到主题上 如果主题不存在则被创建 生产数据只能生产到主题。

nsq_to_http

nsq_to_http -lookupd-http-address=127.0.0.1:4161 --topic=test --post=http://test.local/a.php -n=1

nsq_to_http -lookupd-http-address=127.0.0.1:4161 --topic=test --channel=http --post=http://test.local/a.php -n=1

• http消费数据 有数据的时候 就会调用--post指定的接口 接口来接收数据
• 消费指定channel channel是消费的时候创建的 多个channel多次消费同一条消息

nsq_to_file

nsq_to_file --topic=test --output-dir=/tmp --lookupd-http-address=127.0.0.1:4161

• 直接写文件消费

nsq_tail

nsq_tail -topic=test --lookupd-http-address=127.0.0.1:4161

• 用来查看生产的数据

nsq_stat

nsq_stat -lookupd-http-address=127.0.0.1:4161 --topic=test --channel=nsq_to_file

• nsq 状态

nsqadmin

 nsqadmin --lookupd-http-address=127.0.0.1:4161
http://127.0.0.1:4171/

• nsq web查看