Mac本地安装和调试NSQ流程

1、brew安装nsq

brew  install nsq

2、在命令行窗口1启动 nsqlookupd 服务

nsqlookupd

可以看到，nsqlookupd启动之后，监听TCP 4160端口，用于管理nsqd服务；监听HTTP 4161端口，用于给nsqadmin提供服务。

3、在命令行窗口2启动nsqd服务

nsqd --lookupd-tcp-address=127.0.0.1:4160 --broadcast-address=127.0.0.1

特别注意：后面的 --broadcast-address=127.0.0.1 一定要加上，表明广播地址，否则客户端连接时，无法连接获取主题中的消息，报错如下

error connecting to nsqd - dial tcp: i/o timeout

（1）再新建一个CMD窗口2，需指定要连接的nsqlookupd的地址和端口，这里我们就连接上一步已经启动的nsqlookupd，地址即127.0.0.1：4160

nsqd连接成功nsqlookupd后，会初始化topic、channal的元数据，获取nsqlookupd信息。

（2）与此同时，nsqlookupd的窗口1输出：

表明新建一个客户端连接：new client(127.0.0.1:52051)

（3）之后nsqd每隔15s向nsqlookupd发送一个心跳包，表明nsqd处于在线状态，而nsqlookupd回复pinged。

nsqd的窗口2发送心跳包

nsqlookupd的窗口1接收到心跳包并反馈

4、生产消息：往nsqd发布一条初始化消息

新建一个CMD窗口3发布消息方法pub，消息主题为test，消息内容为"hello world"

curl -d 'hello world' 'http://127.0.0.1:4151/pub?topic=test'

此时nsqd窗口2输出表明新注册一个主题test：

而nsqlookupd窗口1输出：

此时并没有任何通道channels来连接该主题topic，只是生产了消息，存在topic本身内部。

注意：nsqd对于http请求监控的就是4151端口，因此生产消息往4151端口发送消息

5、新建channal来消费消息

在/tmp文件夹下新建一个nsq_log的文件夹，绝对路径为：/tmp/nsq_log

（1）新建一个CMD窗口4：

nsq_to_file --topic=test --output-dir=/tmp/nsq_log --lookupd-http-address=127.0.0.1:4161

上图表明我们用到nsq_to_file来消费topic为test的消息内容，并将其输出到指定路径（--output-dir=/tmp/nsq_log），监控的地址为本地127.0.0.1:4161

注意：

如果nsqd启动时nsqd --lookupd-tcp-address=127.0.0.1:4160 --broadcast-address=127.0.0.1，后面不加广播地址为本地，那么这里就会报错

无法连接到nsqd

6、在新的窗口查看消费数据

（1）之后每小时会自动生成一个文件

test.QKBJ100574deMacBook-Pro.2020-04-30_10.log

表明是2020-04-30号10点生成的日志文件

然后，所有往topic为test的主题中发送消息时，这里就会同步获取到该消息

7、可视化界面管理

（1）启动nsqadmin，新建一个CMD窗口5：

 nsqadmin --lookupd-http-address=127.0.0.1:4161

此时，该客户端连接的是127.0.0.1:4161端口的数据，监听127.0.0.1:4171端口并展示数据，那么我们就可以在浏览器查看127.0.0.1:4171端口即可

（2）浏览器查看 http://127.0.0.1:4171/

此时能看到我们刚刚创建的topic：test

创建一个新的topic：xueyanxiang
curl -d 'hello sucess' 'http://127.0.0.1:4151/pub?topic=xueyanxiang'