以下步骤将在本地计算机上运行一个小型NSQ群集,并逐步完成将消息发布,使用和归档到磁盘的过程。
请按照 INSTALLING 文档中的说明进行操作。
在一个 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
发布一条初始消息 (并且在集群中创建一个 topic):
$ curl -d 'hello world 1' 'http://127.0.0.1:4151/pub?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/pub?topic=test'
$ curl -d 'hello world 3' 'http://127.0.0.1:4151/pub?topic=test'
为了验证事情是否按预期进行,请在打开的网络浏览器 http://127.0.0.1:4171/
中查看 nsqadmin
用户界面并查看统计信息。另外,检查 (test.*.log
)
写入的日志文件内容从 /tmp
的目录.
这里重要的是 nsq_to_file
(客户端)没有明确告知 test
主题的产生地,它从 nsqlookupd
获取信息,即使在消息推送之后才开始连接 nsqd,消息也并没有消失。