由于网上已经有很多大佬已经做了很多相关项目案例。所以我们应该站在巨人的肩膀上,多向大佬们学习。下面主要是我收集到Netty项目,具体项目怎么实现的,我就不讲了,大佬们已经做得很简单明了。
来自lightningMan大佬的:
https://github.com/lightningMan
Netty 入门与实战:仿写微信 IM 即时通讯系统
使用Netty实现了单聊和群聊,将Netty从基础到项目一体化,可以说是入门Netty不错的选择。
单聊指的是两个用户之间相互聊天。下面我们来看一下,用户单聊的基本流程
下面我们先来看一下,要实现单聊,客户端与服务端分别要实现哪些指令:
指令内容 | 客户端 | 服务端 |
---|---|---|
登录请求 | 发送 | 接收 |
登录响应 | 接收 | 发送 |
客户端发消息 | 发送 | 接收 |
服务端发消息 | 接收 | 发送 |
登出请求 | 发送 | 接收 |
登出响应 | 接收 | 发送 |
群聊指的是一个组内多个用户之间的聊天,一个用户发到群组的消息会被组内任何一个成员接收,下面我们来看一下群聊的基本流程
如上图,要实现群聊,其实和单聊类似
下面,我们再来看一下群聊除了需要实现上述指令之外,还需要实现的指令集
指令内容 | 客户端 | 服务端 |
---|---|---|
创建群聊请求 | 发送 | 接收 |
群聊创建成功通知 | 接收 | 发送 |
加入群聊请求 | 发送 | 接收 |
群聊加入通知 | 接收 | 发送 |
发送群聊消息 | 发送 | 接收 |
接收群聊消息 | 接收 | 发送 |
退出群聊请求 | 发送 | 接收 |
退出群聊通知 | 接收 | 发送 |
我们使用 Netty 统一的 IO 读写 API 以及强大的 pipeline 来编写业务处理逻辑,在后续的章节中,我会通过 IM 这个例子,带你逐步了解 Netty 的以下核心知识点。
上面这幅图展示了客户端的程序逻辑结构
同类型的项目还有:
琪琪IM:https://gitee.com/qiqiim/qiqiim-server
蚂蚁金融服务集团开发的一套基于 Netty 实现的网络通信框架。
地址:https://github.com/sofastack/sofa-bolt
SOFABolt 是蚂蚁金融服务集团开发的一套基于 Netty 实现的网络通信框架。
目前该产品已经运用在了蚂蚁中间件的微服务 (SOFARPC)、消息中心、分布式事务、分布式开关、以及配置中心等众多产品上。
SOFABolt 的基础功能包括:基础通信功能 ( remoting-core )
基于 Netty 高效的网络 IO 与线程模型运用 连接管理 (无锁建连,定时断链,自动重连) 基础通信模型 ( oneway,sync,future,callback ) 超时控制 批量解包与批量提交处理器 心跳与 IDLE 事件处理
协议框架 ( protocol-skeleton )
命令与命令处理器 编解码处理器 心跳触发器
私有协议定制实现 - RPC 通信协议 ( protocol-implementation )
RPC 通信协议的设计 灵活的反序列化时机控制 请求处理超时 FailFast 机制 用户请求处理器 ( UserProcessor ) 双工通信
陆陆大神的:https://github.com/1ssqq1lxr/iot_push
MQTT 协议是 IBM 开发的即时通讯协议,相对于 IM 的实际上的准标准协议 XMPP 来说,MQTT 更小,更快,更轻量。MQTT 适合于任何计算能力有限,工作在低带宽、不可靠的网络中的设备,包括手机,传感器等等。
已实现的功能:
发布订阅功能 遗言通知 会话session数据 发布保留消息 主题过滤(/test 会接受到 /test/yy 的主题消息) 实现标准的 qos0 qos1 qos2消息确认机制 ssl加密 支持ws协议 集成spring容器