NSQ源码剖析之nsqlookupd

综合编程 2016-06-24

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结点消费消息。

责编内容by:shanks's Blog (源链)。感谢您的支持!

您可能感兴趣的

Android——EventBus源码分析 停停走走又几天,断断续续这一年。时间还是如此之快,转眼间又到了17年的末尾了。趁着这些天还能静下心来看看代码,赶紧记录下自己的心得。 这一周,工作任务不多,总是想要看点什么但又不清楚该看啥,有些迷茫~不过既然自己还想要在Android路上继续前行,那么请深入探索吧! OK,闲话不多说。今天打...
【Java学习笔记】(十一)Vector 源码分析... 这篇文章来自 我的博客 正文之前 之前介绍过 ArrayList 和 LinkedList ,所以今天来说说 List 接口的另一个实现类: Vector ,其实这也是一个类似的动态数组,只不过是线程安全的,和 ArrayList 还是有一点区别的 ...
Retrofit2.0- 源码分析 1. 阅读引导 在分析 Retrofit 源码之前,你首先得理解动态代理模式,因为Retrofit是通过动态代理的方式进行统一网络请求接口类的处理。Retrofit的代码量并不大,只是对OkHttp进行了封装,用更少的代码进行网络请求,明白动态代理模式之后,再看Retrofit网络请求处理流程...
axios源码分析——取消请求 之前分析了两篇文章 请求流程分析,传送门,戳这里; 拦截器分析,传送门,戳这里; 这篇文章,来分析下取消请求是怎么实现的,先从一个简单的取消请求的例子开始: var CancelToken = axios.CancelToken; var...
java 源码分析 —Boolean 概况 Java的Boolean类主要作用就是对基本类型boolean进行封装,提供了一些处理boolean类型的方法。 当作为一个构造函数(带有运算符 new)调用时,Boolean() 将把它的参数转换成一个布尔值,并且返回一个包含该值的 Boolean 对象。 如果作为一个函数...