nsq 使用
2019-02-22 本文已影响0人
agx2
安装
启动服务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查看
