# netty-chat
**Repository Path**: zhangbin111/netty-chat
## Basic Information
- **Project Name**: netty-chat
- **Description**: 使用Netty实现IMServer，方便的Entity解码编码机制，融合到二进制协议中。
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No
## Statistics
- **Stars**: 0
- **Forks**: 9
- **Created**: 2018-03-13
- **Last Updated**: 2021-06-21
## Categories & Tags
**Categories**: Uncategorized
**Tags**: None
## README
# 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操作，自动转发到相应服务器，再做业务处理，然后应答相应客户端。
#### 序列图
