NSQ源码剖析之nsqlookupd

nsqlookupd 是管理的拓扑信息,维护着所有nsqd的状态,并提供了最终一致发现服务的守护进程。

> nsqd在启动时通过-lookupd-tcp-address参数来指定nsqlookupd的地址,并将nsqd节点上的topic 和 channel信息广播给nsqlookupd

> 在nsq官方提供的go语言版的client sdk中 
consumer,_ := nsq.NewConsumer("TopicName", "ChannelName", nsq.NewConfig())
consumer.ConnectToNSQLookupd("Nsqlookupd address")
//consummer会定时向lookupd查询生产TopicName消息的nsqd节点的地址,然后consummer连接nsqd结点消费消息。
稿源:shanks's Blog (源链) | 关于 | 阅读提示

本站遵循[CC BY-NC-SA 4.0]。如您有版权、意见投诉等问题,请通过eMail联系我们处理。
酷辣虫 » 综合编程 » NSQ源码剖析之nsqlookupd

喜欢 (0)or分享给?

专业 x 专注 x 聚合 x 分享 CC BY-NC-SA 4.0

使用声明 | 英豪名录
切换注册

登录

忘记密码 ?

您也可以使用第三方帐号快捷登录

Q Q 登 录
微 博 登 录
切换登录

注册