SpringBoot+Netty+Redis搭建长连接集群

点击上方“芋道源码”&＃xff0c;选择“设为星标”

管她前浪&＃xff0c;还是后浪&＃xff1f;

能浪的浪&＃xff0c;才是好浪&＃xff01;

每天 10:33 更新文章&＃xff0c;每天掉亿点点头发...

源码精品专栏

• 原创 | Java 2021 超神之路&＃xff0c;很肝~
  

• 中文详细注释的开源项目
  

• RPC 框架 Dubbo 源码解析

• 网络应用框架 Netty 源码解析
  

• 消息中间件 RocketMQ 源码解析
  

• 数据库中间件 Sharding-JDBC 和 MyCAT 源码解析

• 作业调度中间件 Elastic-Job 源码解析

• 分布式事务中间件 TCC-Transaction 源码解析

• Eureka 和 Hystrix 源码解析

• Java 并发源码

来源&＃xff1a;网络

• 1.背景

• 2.技术选项&实现

• 3.代码实现

• 4.总结

1.背景

公司在做一个社交项目&＃xff0c;音视频技术是使用的第三方技术&＃xff0c;直播间开播&＃xff0c;进出房间&＃xff0c;以及推送相关功能需要自己完成开发&＃xff0c;因而需要自己搭建长连接服务器。

于是在技术选型上&＃xff0c;为了保证服务高并发性能&＃xff0c;以及长连接性能&＃xff0c;在本身就是微服务架构上&＃xff0c;采用了SpringBoot &＃43; Netty实现了长连接服务搭建&＃xff0c;关于SpringBoot和Netty框架相关&＃xff0c;本文不是重点&＃xff0c;本文重点在于Netty集群搭建实现消息转发功能。

基于 Spring Boot &＃43; MyBatis Plus &＃43; Vue & Element 实现的后台管理系统 &＃43; 用户小程序&＃xff0c;支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能。

项目地址&＃xff1a;https://github.com/YunaiV/ruoyi-vue-pro

2.技术选项&实现

2.1 关于Netty长连接

Netty是一个非常优秀的NIO异步事件驱动框架&＃xff0c;在JDK NIO的基础上&＃xff0c;封装并拓展包装&＃xff0c;使得NIO的API简单易用&＃xff0c;很多框架底层也应用了(比如Dubbo)&＃xff0c;Netty是可以做为一个长连接服务的&＃xff0c;使用ws协议&＃xff0c;可以构建一个高性能的长连接服务器&＃xff0c;据说单机就能支持1万左右的连接。

熟悉Netty或NIO的都了解&＃xff0c;其底层数据传输时通过一个网络连接Channel&＃xff0c;对于单机Netty来说&＃xff0c;Channel都连接在同一台服务器上&＃xff0c;Channel之间的通信可以直接根据绑定的用户信息进行获取并转发。但是对于Netty集群来说&＃xff0c;每个客户端的连接可能在不同的服务器上&＃xff0c;这样在Channel互相通信时&＃xff0c;需要判断是否在当前节点&＃xff0c;并实现消息的转发。

2.2 技术选项

实现消息转发&＃xff0c;有多种技术框架可以实现&＃xff0c;比如ZK&＃xff0c;MQ&＃xff0c;Redis等&＃xff0c;由于当前项目已经搭建了自己的MQ和Redis服务&＃xff0c;因此考虑成本&＃xff0c;目前只在MQ和Redis中选择。

如上文&＃xff0c;Netty集群搭建后&＃xff0c;Channel收到消息后&＃xff0c;需要判断目标用户的Channel是否在本节点&＃xff0c;如果不在&＃xff0c;就需要做消息转发&＃xff0c;转发到目标节点上&＃xff0c;并将消息写到Channel中。因而MQ的广播机制和Redis的发布订阅就可以实现功能。

对比如下&＃xff1a;

• MQ&＃xff1a;专门做消息队列的&＃xff0c;可靠性高&＃xff0c;但重量级&＃xff0c;异步&＃xff0c;不能保证实时。

• Redis&＃xff1a;较轻量级&＃xff0c;低延迟&＃xff0c;高并发&＃xff0c;低可靠性。

两者在项目均在使用&＃xff0c;考虑到直播消息更加保证时效性&＃xff0c;故而选择Redis发布订阅功能&＃xff0c;相对而言集成较为简单。

2.3 实现架构图

①服务启动时&＃xff0c;向Redis注册自己的节点信息&＃xff0c;并指定监听频道。

②客户端连接Netty Server成功后&＃xff0c;并在Redis缓存中绑定用户加入的节点&＃xff0c;以便后续信息转发&＃xff0c;将信息转发到指定的频道。

③在Channel转发时&＃xff0c;判断如果当前用户在本节点&＃xff0c;就直接转发&＃xff0c;如果不在&＃xff0c;从Redis获取到注册的节点信息&＃xff0c;并将消息发布到指定的频道节点。

基于微服务的思想&＃xff0c;构建在 B2C 电商场景下的项目实战。核心技术栈&＃xff0c;是 Spring Boot &＃43; Dubbo 。未来&＃xff0c;会重构成 Spring Cloud Alibaba 。

项目地址&＃xff1a;https://github.com/YunaiV/onemall

3.代码实现

绑定当前节点&＃xff0c;服务启动并监听指定的频道&＃xff0c;指定Listener。

订阅节点生成器 本机 ip &＃43; 服务端口

监听器实现&＃xff0c;监听的频道收到消息&＃xff0c;处理并发送到对应Channel

消息转发Sender

4.总结

①通过应用Redis发布订阅&＃xff0c;Netty Server多个集群&＃xff0c;追加多节点时&＃xff0c;新增节点会自动注册监听对于的频道&＃xff0c;消息转发时也会自动投递到新注册的节点频道上&＃xff0c;可扩展性强。

②当前Redis 5中有很多新增的高级特性&＃xff0c;笔者也在慢慢学习中&＃xff0c;可应用到项目业务场景中也比较多。

欢迎加入我的知识星球&＃xff0c;一起探讨架构&＃xff0c;交流源码。加入方式&＃xff0c;长按下方二维码噢&＃xff1a;

已在知识星球更新源码解析如下&＃xff1a;

最近更新《芋道 SpringBoot 2.X 入门》系列&＃xff0c;已经 101 余篇&＃xff0c;覆盖了 MyBatis、Redis、MongoDB、ES、分库分表、读写分离、SpringMVC、Webflux、权限、WebSocket、Dubbo、RabbitMQ、RocketMQ、Kafka、性能测试等等内容。

提供近 3W 行代码的 SpringBoot 示例&＃xff0c;以及超 4W 行代码的电商微服务项目。

获取方式&＃xff1a;点“在看”&＃xff0c;关注公众号并回复 666 领取&＃xff0c;更多内容陆续奉上。

文章有帮助的话&＃xff0c;在看&＃xff0c;转发吧。
谢谢支持哟 (*^__^*&＃xff09;