文章目录
- 二、Netty实现聊天室
二、Netty实现聊天室
项目相关代码已上传至github:https://github.com/2NaCl/netty-Chatting
项目的中心是实现一对多的聊天平台,首先我们要整理思路,这个平台的代码实现,肯定也是一个启动类的服务器,一个能启动多次的client。
先说服务器的思路:
- 创建事件循环组,绑定端口
- 创建初始化程序,进行channel的过滤操作
- 过滤的同时写一个Handler,能够让Client实现一对多。
启动程序和过滤channel的操作,和之前的是一样的,可以参考上一篇博客的详解,这里就不过多累述了,代码也在github。
文章链接:https://blog.csdn.net/qq_41936805/article/details/100557748
在这里主要说一下ServerHandler的实现
也是继承这个类,但是我们可以继承这个,也可以继承ChannelInboundHandler,这是一个简单的适配器模式,如果不知道什么是适配器模式的话,可以参考这篇文章https://blog.csdn.net/qq_41936805/article/details/100620303
- 首先也是先搭好大体的框架,一个具体的Handler,和一个错误打印和服务器关闭。
接下来我们要实现的是,一个Client的上线会通知给其他Client,并且消息会进行广播。
- 因为会有很多client都注册进来,所以就会产生很多channel,我们要进行广播的话,就要把channel放进一个组里,也是借用netty的一个实现。
下面依次介绍我们要实现的功能:
- 首先client连接到server,连通之后,立刻触发回调函数,表示服务器正常
- 若连接失败,Server端出现了问题的话,触发回调函数
- 若有人上线,立即触发回调函数
- 有人下线
- 当客户端有信息经由服务端去转发的时候,我们要保证,这个信息可以广播到所有其他的ip,除了自己的,那么就需要对channels进行遍历,然后进行一下筛选,再处理。
实现了服务端之后,下面就要开始写客户端了,客户端相对于服务端已经简单了很多。
- Client的启动类和初始化也都是和之前一样的,我们只需要完善一下读取控制台输入的信息,然后放进channel组里面去写出就行了
然后一个基于TCP的netty实现的聊天室就ok了,代码已经上传到github,可以看最上面的地址。
但是还有一个缺陷:如果客户端异常退出,而不是正常点击下线的话,无法触发handlerRemoved操作,所以我们需要手写一个类似于zk的心跳包去send each other来确定是否还在线。
这个操作需要在Server Handler上去改正:
-
首先我们新添一个过滤器,将被判定为离线的人的消息进行过滤。
-
重写一个回调方法,定义一下,当一个事件触发以上三种超时之后,我们的措施是什么