详解NIO如何实现群聊?

2021-08-31 10:57:10 浏览数 (1)

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. 如果是读数据事件就交给具体的读数据方法处理数据

0 人点赞