前言

📅大四是整个大学期间最忙碌的时光,一边要忙着准备考研,考公,考教资或者实习为毕业后面临的就业升学做准备,一边要为毕业设计耗费大量精力。近几年各个学校要求的毕设项目越来越难,有不少课题是研究生级别难度的,对本科同学来说是充满挑战。为帮助大家顺利通过和节省时间与精力投入到更重要的就业和考试中去,学长分享优质的选题经验和毕设项目与技术思路。

🚀对毕设有任何疑问都可以问学长哦!

本次分享的课题是

🎯基于netty的网关推送平台

课题背景与意义

在浏览某些网页的时候，例如 QQ网页版、在线客服服务、CSDN站内私信消息等类似的情况下，我们可以在网页上进行在线聊天，或者即时消息的收取与回复。可见，这种功能的需求由来已久，Web端即时通讯技术因受限于浏览器的设计限制，一直以来实现起来并不容易，主流的Web端即时通讯方案大致有4种：传统Ajax短轮询、Comet技术、WebSocket技术、SSE（Server-sent Events）:

通过几种模式的对比，可见Comet、websocket更适合现有场景的需求，即只使用chrome/firefox做为浏览器的内部系统，使用websocket技术，外部系统使用Comet技术。所以Comet长轮询和websocket 将作为消息推送网关的主要支持协议，为了同时能够兼容这两种模式且发挥服务器的最大性能，使用了netty作为框架底层来实现。

消息推送网关基于netty4 ,客户端与服务端建立TCP 全双工通道的NIO模式，和传统的一个连接一个线程式的BIO不同，NIO是非阻塞的，能支持更多的连接。

客户端注册后，针对每个用户发放一个ID，作为该客户端的标识。在敏感的数据交互场景中，若有连接进来，需要进行鉴权，对于非法的连接进行拒绝，对于合法的连接进来后，注册到注册中心，这样就知道每个客户端的连接在哪个服务器上。

每个模块的角色：

1. Boss Group线程组：作为服务端Acceptor线程，用于accept客户端连接，并转发给WorkerGroup中的线程；

2. Worker Group线程组：作为IO线程，负责IO的读写，从SocketChannel中读取报文或向SocketChannel写入报文；

3.连接空闲检测Task：作为定时任务线程，执行定时任务，例如连路空闲检测；

4.pipLine: 是一个负责和执行ChannelHandler的职责链；

5.编解码器:负责接收数据的加解码；

6.分块写处理器：主要用于大文件传输；

7.对象聚合器：会把请求转换成另外一个对象；

8.proxy server :调用后端接口代理；

9.http服务：主要是用于暴露Http服务给路由分发服务；

10.路由分发服务：主要是通过注册中心，知道某个用户的连接在具体哪一台机器，后端无需关注用户登录在什么机器，只需要知道用户的ID，就可以对用户所登录在线的机器发送消息，由路由分发服务来找到对应的网关，对外暴露dubbo\RMI\http协议，满足不同调用需求。

该系统可以进行横向伸缩，当需要支持更多的客户端或者需要传输的数据时，通过新增机器就可以满足，理论上是没有上限的。

消息推送网关已经应用于中天门户的消息推送功能模块、C端用户中心的微信二维码扫描登录模块、云打印中的PC/移动端打印信息推送模块，尤其解决了业务系统门户（中天门户）即时消息推送不畅的问题。

消息推送：最早门户消息提醒并非使用长连接而是使用HTTP短轮询，每个用户发消息过来后产生一个对后台服务的远程调用，在用户量小时，对后台压力并不是很大，而如果用户数变大后，后台将开始出现服务超时等现象且当用户数达到3W后系统频繁宕机，反应在功能上就是用户收不到消息，而现在中天作为业务系统门户，每天登录用户将超过10W+，通过网页版前端登录后，跟服务端保持长连接，后端根据用户ID，针对某个用户的消息进行推送，触达及时且单一机器可承载用户数更多；

微信图像二维码登录：实现用户使用微信扫一扫，在扫描图像二维码后微信会回调后台接口，后台需要及时通知到客户端，客户端收到后进行登录跳转，前期二维码扫描登录，是通过每5秒短轮询一次后台判断用户是否已经通过微信扫描，这样由于每次请求都需要进行加解密操作，当用户量大时后台负载也变大，且用户反馈扫描后长时间无反应或者反应很慢，用户体验不好，使用消息推送网关后单台机器即可支撑且完美解决客户体验问题。

打印消息推送：由于打印消息推送和普通的消息推送的区别在于推送打印数据的时效要求和.net交互，之前使用的第三方推送由于心跳间隔比较长，如果网络抖动或者在心跳间隙断开，后台并不知道，这样推到前端就无法触达，消息推送网关通过缩短心跳间隔时间和后台调整获取打印消息的逻辑解决。

除了以上场景，还能满足以下一些场景：

在线人数实时报表：通过session管理器可以实时拿到在线的session以及用户通过哪些客户端连接。

聊天室：通过两个客户端都连接到网关，通过服务代理把消息进行交换。

文件上传下载：在上传时会将文件分成多个小块chunck，比方说：一个文件10M，网关会用ChunckedWriteHandler（支持异步发送的码流（大文件传输）但不占用过多的内存，防止java内存溢出）类将这个文件拆分，比如说分成10份，每份1M分10次进行传输，将10次传输封装成1个response进行响应，这样每次传输的内容小所以够快。

基础资料实时同步：现在智能终端或者PDA的基础资料大部分采用开机下载和定时拉取的设计，可以通过消息推送网关，把更新的基础资料数据实时分发，解决基础资料同步延时问题。