业务需求:
此项目为一气象项目的小部分,在内网条件下,实现网页端的聊天系统,要求可以进行点对点聊天以及群聊,可以发送文字,文件,图片等内容。
技术选型:
此业务要求实时接收人和群组发送的消息,必须使用长链接的服务器,选用netty建立长链接,此外部分业务是传通的crud场景,使用springboot,tomcat,mabytis-plus等进行开发。数据库使用postgre与redis。
技术设计:
整体分为tomcat与netty两部分,tomcat负责传统crud,文件oss等内容,由springboot,mabytis-plus等进行实现,这里不再赘述。netty负责实现聊天,实时消息等。
netty服务器的整个链路从nettyServer开始,在启动tomcat时初始化启动一个NettyServer线程,在线程里建立netty服务器。
此时注意的是通道处理器,项目里使用的MyChannelInitializer,这一步做的是对接收到的消息的解码对返回消息的编码等工作,由于是内网,前端是网页,所以这里只对网页端发送的消息进行简单解码,不在这里进行消息分类(如果是客户端,就可以进行自定义编码了,可以在这里加密,对消息进行分类等)
接下来就是对建立的通道进行处理了,我们已经在MyChannelInitializer加入了MyTextWebSocketframeHandler适配器。
这里主要是接受消息与链接断开,链接断开即用户下线,要在我们维护的用户与通道的关系map以及用户与群组的map中删除用户。
接受消息(channelRead0方法)这里使用了策略模式,先把消息解码为提前定义好的类Packet,再根据packet的command解码为对应的packet的子类,再使用IHandlerAlgorithm的实现类进行业务处理。
数据设计
基础数据包括用户,群组,用户之间的好友关系,用户加入群组,消息,对话框(用户与用户的,用户与群组的)