加载中
nsq源码channel的messagePump实现原理

nsq里面channel类似于通道的作用,负责给consumer同步消息: func (p *protocolV2) messagePump(client *clientV2, startedChan chan bool) { var err error //内存的MsgChan var memoryMsgCh...

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部