社区微信群开通啦,扫一扫抢先加入社区官方微信群
社区微信群
项目数据对接方使用了一个消息队列 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,以便大家能找到)。
nsqlookupd
nsqlookupd 是守护进程,负责管理拓扑信息并提供最终一致性的发现服务。客户端通过查询 nsqlookupd 来发现指定话题(topic)的生产者,并且 nsqd 节点广播话题(topic)和通道(channel)信息。
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主页说明中有简单的发布和消费代码,分别创建项目并测试,可以。
如果觉得我的文章对您有用,请随意打赏。你的支持将鼓励我继续创作!