前面几章中可以看到，nsq进行消息消费的时候主要使用tcpServer去处理，也就是如下的方法func(p*tcpServer)Handle(clientConnnet.Conn){p.ctx.nsqd.logf(LOG_INFO,"TCP:newclient(%s)",clientConn.Remot...

在上节中已经成功的解析了系统配置并创建了核心结构体nsqd，本文主要从nsqd的main方法入手在main方法中，主要会创建一系列的tcp监听器，以及轮询检测。 func(n*NSQD)Main(){varerrerrorctx:=&context{n}//检车是否能开启tcpbroadcastAdd...

　直接找到nsqd中main包下的start方法，即下图中代码func(p*program)Start()error{//返回options结构体包含了一些默认信息//例如id，自身监听的tcp端口和http端口等，还包括了一系列阈值//这儿注意id使用hostname进行MD5后生成的三列码opts:=nsqd.Ne...