zhanghaj00/netty-chat-parent

基于netty的分布式聊天服务器。整合zookeeper

netty-chat

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进行加解密类型，以及序列化反序列化方式。

客户端请求，通过readEntity读取对象数据，以游标方式读取，可以连续读取多个Entity

IMRequest:

readEntity(IMSerializer.class);

服务端应答，通过writeEntity写入对象数据，可以连续写入多个Entity

IMResponse:

writeEntity(IMSerializer);

长连接，发送数据内容，控制客户端连接

IMConnection:

sendResponse(imResponse);
kill();

业务分发处理

IMHandler:

dispatch(IMConnection, IMRequest)

业务处理流程

Received：
findHandler(id).dispatch() -> UserHandler

UserHandler.dispatch()
switch(cmdId)
// doCommand

UserHandler <- UserService <- UserRepository

• 水平扩展设计思路，登录后返回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操作，自动转发到相应服务器，再做业务处理，然后应答相应客户端。

序列图