扫一扫下方二维码,关注本站官方公众号
获取永久解锁本站全部文章的验证码
还能不定期领现金红包

捣鼓nsq - 安装和运行-Go语言中文社区

捣鼓nsq - 安装和运行


【学习新东西,最好先成功运行一个demo,这样才有研究下去的信心和动力。】

 

1. nsq安装

下载地址: http://nsq.io/deployment/installing.html 

目前的稳定版是V1.0.0-compat,由于在window平台上安装,所以选择: 

nsq-1.0.0-compat.windows-amd64.go1.8.tar.gz

下载之后解压到某目录,这里是放在D盘 D:nsq

同时要把nsq的bin目录(D:nsqbin)添加到系统环境变量中

 

2. 启动nsqlookupd

新建一个CMD窗口1:

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

 

3. 启动nsqd

(1)再新建一个CMD窗口2,需指定要连接的nsqlookupd的地址和端口,这里我们就连接上一步已经启动的nsqlookupd,地址即127.0.0.1:

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

(2)与此同时,nsqlookupd的窗口1输出:

表明新建一个客户端连接:new client<127.0.0.1:64679>

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

窗口1:

窗口2:

 

4. 往nsqd发布一条初始化消息

新建一个CMD窗口3(window上使用git bash),发布消息方法pub,消息主题为test,消息内容为"hello world lee":

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

而nsqlookupd窗口1输出:

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

 

5. 新建channal来消费消息

(1)新建一个CMD窗口4:

这里我们用到nsq_to_file来消费topic为test的消息内容,并将其输出到指定路径(--output-dir=E:/tmp/)

打开该文件:

(2)之后每小时会自动生成一个文件

 

6. 用nsqadmin查看topic、channal信息

(1)启动nsqadmin,新建一个CMD窗口5:

这时,nsqadmin进程已经启动了。

(2)打开nsqadmin界面

浏览器输入:127.0.0.1:4171

 

版权声明1:本文来源CSDN,感谢博主原创文章,遵循 CC 4.0 by-sa 版权协议,转载请附上原文出处链接和本声明。
原文链接:https://blog.csdn.net/u011692924/article/details/80858704
站方申明:本站部分内容来自社区用户分享,若涉及侵权,请联系站方删除。
  • 发表于 2019-09-13 19:53
  • 阅读 ( 713 )

0 条评论

请先 登录 后评论

官方社群