离线下载
PDF版 ePub版

极客学院团队出品 · 更新于 2017-09-25 15:00:29

快速开始

下面的步骤将通过推送(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,消息也并没有消失。

上一篇: 介绍 下一篇: 特性和担保