标签:
一,整体概况
大概读了下代码,对整份代码结构有了基本思路。但是对代码具体完成的功能和在系统中扮演的角色还不能完全理解。。
整个nsqlookupd分为几部分
1.main,做了初始化之后,就在等待系统信号进行退出等处理
2.RegistrationDB,记录db
3.tcpServr,处理tcp连接,根据tcp发过来的指令完成对应操作
4.httpServer,处理http连接,根据http参数获得的指令完成对应的操作
ps:去官网看了下文档,感觉这里其实大概讲了这个作用:http://nsq.io/deployment/topology_patterns.html
二,具体流程
producer通过nsqd将topic注册到nsqlookupd
consumer通过nsqlookupd获得nsqd实例信息
consumer从nsqd取得topic/channel下到message进行consume
//太乱了,整理整理再写。。
标签:
原文地址:http://www.cnblogs.com/mruoli/p/4725764.html