nsqd源码分析

type NSQD struct {
{
//A nsqd instance can have multiple topics
topicMap map[string]*Topic
}

type Topic struct {
//There are multiple Channels under a Topic instance
channelMap map[string]*Channel
//The goroutines in golang communicate through chan. If you want to publish a message to this topic, you only need to write the message to Topic.memoryMsgChan
memoryMsgChan chan *Message
}

//When cre

nsqd源码分析最先出现在Python成神之路。