客服系统逻辑设计图

所有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数据源

以后