详解NIO如何实现群聊?
愿天堂没有BUG
共 874字,需浏览 2分钟
·
2021-04-14 11:42
1. 实现步骤
构建Selector以及服务端监听
通道启动监听并处理建立连接请求
处理读数据群发数据
实现客户端测试
2. 服务端实现
2.0 服务端完整代码
服务端的主要功能如下 :
1. 开放监听端口,方法ChatServer构造方法
2. 处理链接请求,方法listener实现连接的建立
3. 读取消息内容,方法readData
4. 转发消息给当前所有在线的人,方法sendData2All
2.1 构建Selector以及服务端监听通道
当ChatServer对象被创建时具体实现步骤如下:
1. 创建serverSocketChannel对象
2. 设置处理模式为非阻塞模式
3. 绑定监听端口
4. 将channel注册到selector中
2.2 实现监听并处理建立连接请求
连接请求处理实现步骤:
1. 获得所有有事件的key, 通过key就可以拿到用户的SocketChannel
2. 循环遍历每一个key,判断当前是读事件,还是建立连接事件
3. 如果是建立连接事件则直接将该通道注册到selector中
4. 如果是读数据事件就交给具体的读数据方法处理数据
2.3 处理读数据
数据处理的具体实现步骤 :
1. 通过key获取和用户连接的通道(相当于输入流)
2. 获取通道的数据并打印
3. 将数据转发给其他在线用户
2.4 群发数据实现
数据群发实现步骤:
1. 当前在线用户实际上就是selector中所有注册的key,也就是在线的用户
2. 通过key拿到和用户的链接讲消息转发出去
2.5 启动服务端
3. 客户端实现
客户端实现 :
1. 首先创建SocketChannel对象并链接到具体的服务器
2. 将通道注册到selector中
3. 开启一个新的线程监听selector中所有key的事件
4. 在主线程中循环阻塞获取用户的输入
评论