We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
// Start 启动节点
func (n *Node) Start() { n.setState(cluster.Work)
n.startTransporter() n.registerServiceInstance() n.proxy.watch(n.ctx) go n.dispatch() //处理请求和事件 n.debugPrint() n.runHookFunc(cluster.Start)
}
//麻将例子代码
不是只有dispatch这个协程处理消息吗