Protocol:
Length | Header | Actual Content |
---|---|---|
4byte | 8byte | data length |
Header:
version 协议版本号,当协议有改变,以及entity属性有改变时通过版本号进行序列化操作。
handlerId 业务分发处理,IMHandlerManager.find(handlerId),通过handler去处理客户端请求命令。
commandId 命令动作处理,IMHandler.dispatch(IMConnection, IMRequest),对IMRequest处理,IMConnection应答或者kill。
reserved 数据序列处理,对Actual Content进行加解密类型,以及序列化反序列化方式。
IMRequest:
readEntity(Entity.class);
IMResponse:
writeEntity(IMSerializer);
IMConnection:
sendResponse(imResponse);
kill();
IMHandler:
dispatch(IMConnection, IMRequest)
UserHandler <- UserService <- UserDao
- 水平扩展设计思路,登录后返回token,并分配chat-server,再进行loginChannel,通过token建立连接,以chat-server持有客户连接上的IMConnection。
- 每个chat-server都有一个node cache,保存当前连接用户的在线信息,如果当前node中不存在,在全局nodeAll中获取是否在线信息。
- 并加入chat-route模块,在chat-server启动时注册服到route中,以长连接通信(断开时无限重试连接),做send/notify操作。
- 如果发送消息时from == to服务器,直接做业务处理,再做应答客户端。
- 如果发送消息时from != to服务器,通过chat-route做send操作,自动转发到相应服务器,再做业务处理,然后应答相应客户端。