基于Netty实现的即时通讯

BUG弄潮儿

发布于 2022-06-30 15:35:58

7450

发布于 2022-06-30 15:35:58

文章被收录于专栏：JAVA乐园

Jelly是一款基于Netty4.x开发的TCP长连接即时通讯服务器端程序；并且提供了Java客户端API。

Github项目地址：https://github.com/Yohann-Codes/Jelly

功能包括

账户：登录、注册、登出
好友：添加、删除、好友在线状态
消息：个人消息、讨论组消息（在线消息和离线消息）
讨论组：创建和解散讨论组、添加和删除成员
个人信息：修改个人信息、查看个人信息

Architecture

模块介绍

jelly-launcher 　启动模块(就一个类而已)
jelly-transport 　数据传输模块
jelly-serialization 　序列化模块
jelly-service 　服务模块
jelly-dao 　数据访问模块

应用层协议

                                        Jelly Protocol    __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __ __
   |           |           |           |           |              |                          |         2           1           1           1            4               Uncertainty
   |__ __ __ __|__ __ __ __|__ __ __ __|__ __ __ __|__ __ __ __ __|__ __ __ __ __ __ __ __ __|
   |           |           |           |           |              |                          |
       Magic        Sign        Type       Status     Body Length         Body Content
   |__ __ __ __|__ __ __ __|__ __ __ __|__ __ __ __|__ __ __ __ __|__ __ __ __ __ __ __ __ __|
 
   协议头9个字节定长
       Magic      // 数据包的验证位，short类型
       Sign       // 消息标志，请求／响应／通知，byte类型
       Type       // 消息类型，登录／发送消息等，byte类型
       Status     // 响应状态，成功／失败，byte类型
       BodyLength // 协议体长度，int类型

数据交换格式：JSON（框架：Gson）

工作流程

              --------> Request        - - - - -> Response       -- -- --> Notice                    
---------------------------------------------------------------------------------------------------- 
                                                                                                     
                                                                                                     
                             __ __ __ __ __ __ __ __ __ __ __ __ __ __                               
                            |                  Server                 |                              
      __ __ __ __           |  __ __ __ __ __         __ __ __ __ __  |            __ __ __ __       
     |           | Request  | |              |       |              | |  Notice   |           |      
     |   Client  |--------> | | BlockingQueue| ----> |  ThreadPool  | | -- -- --> |   Client  |      
     |__ __ __ __|          | |__ __ __ __ __|       |__ __ __ __ __| |           |__ __ __ __|      
           |                |                                |        |                              
           |                |__ __ __ __ __ __ __ __ __ __ __|__ __ __|                              
           |                                                 |                                       
           |                    Response                     |                                       
            <- - - - - - - - - - - - - - - - - - - - - - - -                                         
                                                                                                     
                                                                                                     
----------------------------------------------------------------------------------------------------