所有worker进程发布ChatReceived事件
op
MessageTask
1.Channel/Client通过connect接口连接Channel/Server并保持长连接2.Channel/Client通过调用on接口告诉Channel/Server自己关注哪些事件，并3.注册事件回调函数（回调发生在Channel/Client所在进程中）4.Channel/Client通过publish接口向Channel/Server发布某个事件及事件相关的数据5.Channel/Server接收事件及数据后会分发给关注这个事件的Channel/Client6.Channel/Client收到事件及数据后触发on接口设置的回调7.Channel/Client只会收到自己关注事件并触发回调
kafaka
NSQ
Login 登陆的回调事件
订阅者websocket服务端监听2545
现在
http
初始化相关链接，client监听ChatReceived
开启自动客服
ClearUnread 清除未读
Start
消费数据xs_chat_session
ChatReceived事件
RPC
发送消息给客户端_onChannelEvent
nsq
EndCov 最后的会话
触发on
onMessage监听相关回调事件_onWebSocketMessage
AdminhttpproxyTask
raccon
end
push
ChatmessageexTask
SendMessage 发送消息 调用im sdk
订阅
AutochatTask
GetCov 加载会话
发布者XsHttpServer进程 监听2550
开启一个websocket进程2545
IM数据源
以后
