快速开始

以下步骤将在本地计算机上运行一个小型NSQ群集,并逐步完成将消息发布,使用和归档到磁盘的过程。

  1. 请按照 INSTALLING 文档中的说明进行操作。

  2. 在一个 shell 中,开始 nsqlookupd:

    $ nsqlookupd
    
  3. 再开启一个 shell ,运行 nsqd:

    $ nsqd --lookupd-tcp-address=127.0.0.1:4160
    
  4. 再开启第三个 shell ,运行 nsqadmin:

    $ nsqadmin --lookupd-http-address=127.0.0.1:4161
    
  5. 发布一条初始消息 (并且在集群中创建一个 topic):

    $ curl -d 'hello world 1' 'http://127.0.0.1:4151/pub?topic=test'
    
  6. 最后,在第五个 shell 中,运行 nsq_to_file:

    $ nsq_to_file --topic=test --output-dir=/tmp --lookupd-http-address=127.0.0.1:4161
    
  7. 推送更多的数据到 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'
    
  8. 为了验证事情是否按预期进行,请在打开的网络浏览器 http://127.0.0.1:4171/ 中查看 nsqadmin 用户界面并查看统计信息。另外,检查 (test.*.log) 写入的日志文件内容从 /tmp的目录.

这里重要的是 nsq_to_file (客户端)没有明确告知 test 主题的产生地,它从 nsqlookupd 获取信息,即使在消息推送之后才开始连接 nsqd,消息也并没有消失。