NSQ - Go语言中文社区

NSQ


项目数据对接方使用了一个消息队列 https://nsq.io/,我们相应的也需要能够加入该队列中。

被一个查到的资料误导或者说是我理解错了,以为nsq一定要在docker中运行,导致去研究了一下docker的安装和使用。

然后现在发现只需要下载nsq相应的的exe文件,其实就能开始使用了。

安装文件地址:https://nsq.io/deployment/installing.html

参考资料:https://blog.csdn.net/u011692924/article/details/80858704

官方教程:https://nsq.io/overview/quick_start.html

 

nsq有三个组件以及辅助的几个工具构成。 
nsqd 
nsqd 是一个守护进程,负责接收,排队,投递消息给客户端。 
它可以独立运行,不过通常它是由 nsqlookupd 实例所在集群配置的(它在这能声明 topics 和 channels,以便大家能找到)。

  • 服务启动后有两个端口:一个给客户端,另一个是 HTTP API。还能够开启HTTPS。
  • 同一台服务器启动多个nsqd,要注意端口和数据路径必须不同,包括:–lookupd-tcp-address、 -tcp-address、–data-path。
  • 删除topic、channel需要http api调用。

nsqlookupd 
nsqlookupd 是守护进程,负责管理拓扑信息并提供最终一致性的发现服务。客户端通过查询 nsqlookupd 来发现指定话题(topic)的生产者,并且 nsqd 节点广播话题(topic)和通道(channel)信息。

  • 该服务运行后有两个端口:TCP 接口,nsqd 用它来广播;HTTP 接口,客户端用它来发现和管理。
  • 在生产环境中,为了高可用,最好部署三个nsqlookupd服务。

nsqadmin 
nsqadmin 是一套 WEB UI,用来汇集集群的实时统计,并执行不同的管理任务。 
运行后,能够通过4171端口查看并管理topic和channel。

  • 通常只需要运行一个。

utilities 
常见基础功能、数据流处理工具,如nsq_stat、nsq_tail、nsq_to_file、nsq_to_http、nsq_to_nsq、to_nsq

 

nsqllookupd.exe:服务端

nsqd.exe:服务端

nsqadmin.exe:服务端管理工具(Web)

nsq_to_file.exe:消息订阅方

git bash:消息发起方

比较不明白的是为什么是用git bash来发布消息呢

我的项目是c#,需要用c#订阅消息。

找到相应的.net客户端,下载代码研究一下。

 

NsqSharp下载下来打开sln,没找到合适的例子,发现git主页说明中有简单的发布和消费代码,分别创建项目并测试,可以。

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

0 条评论

请先 登录 后评论

官方社群

GO教程

推荐文章

猜你喜欢