详解NIO如何实现群聊？

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. 在主线程中循环阻塞获取用户的输入