快速开始
下面的步骤将通过推送(publishing)、消费(consuming)和归档(archiving)消息到本地磁盘,在本地环境演示一个小型的 NSQ 集群
-
根据文档安装安装 NSQ。
-
在另外一个 shell 中,运行
nsqlookupd
:$ nsqlookupd
-
再开启一个 shell,运行
nsqd
:$ nsqd --lookupd-tcp-address=127.0.0.1:4160
-
再开启第三个 shell,运行
nsqadmin
:$ nsqadmin --lookupd-http-address=127.0.0.1:4161
-
开启第四个 shell,推送一条初始化数据(并且在集群中创建一个 topic):
$ curl -d 'hello world 1' 'http://127.0.0.1:4151/put?topic=test'
-
最后,开启第五个 shell, 运行
nsq_to_file
:$ nsq_to_file --topic=test --output-dir=/tmp --lookupd-http-address=127.0.0.1:4161
-
推送更多地数据到
nsqd
:$ curl -d 'hello world 2' 'http://127.0.0.1:4151/put?topic=test' $ curl -d 'hello world 3' 'http://127.0.0.1:4151/put?topic=test'
- 按照预先设想的,在浏览器中打开
http://127.0.0.1:4171/
就能查看nsqadmin
的 UI 界面和队列统计数据。同时,还可以在/tmp
目录下检查 (test.*.log
) 文件.
这个教程中最重要的是:nsq_to_file
(客户端)没有明确地指出 test
主题从哪里产生,它从 nsqlookupd
获取信息,即使在消息推送之后才开始连接 nsqd,消息也并没有消失。