快速开始

下面的步骤将通过推送(publishing)、消费(consuming)和归档(archiving)消息到本地磁盘,在本地环境演示一个小型的NSQ 集群

  1. 根据文档安装安装 NSQ。

  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. 开启第四个 shell,推送一条初始化数据(并且在集群中创建一个 topic):

     $ curl -d 'hello world 1' 'http://127.0.0.1:4151/put?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/put?topic=test'
     $ curl -d 'hello world 3' 'http://127.0.0.1:4151/put?topic=test'


  8. 按照预先设想的,在浏览器中打开 http://127.0.0.1:4171/ 就能查看 nsqadmin 的 UI 界面和队列统计数据。同时,还可以在 /tmp目录下检查 (test.*.log) 文件.

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

联系我们

邮箱 626512443@qq.com
电话 18611320371(微信)
QQ群 235681453

Copyright © 2015-2024

备案号:京ICP备15003423号-3