天富娱乐登录网页版 体育官网平台功能详解【传智播客】

1.NIO群聊实现步骤

·构建Selector以及服务端监听通

·道启动监听并处理建立连接请求

·处理读数据

·群发数据实现

·客户端测试实现

2. 服务端实现
2.0 服务端完整代码服务端的主要功能如下

(1)开放监听端口，方法ChatServer构造方法

(2)处理链接请求，方法listener实现连接的建立

(2)读取消息内容，方法readData

(4)转发消息给当前所有在线的人，方法sendData2All

 package com.hgy.chat; /** * 群聊服务器 */ public class ChatServer { private ServerSocketChannel serverSocketChannel; private Selector selector; /** * 初始化服务端 */ public ChatServer() { try { selector = Selector.open(); serverSocketChannel = serverSocketChannel.open(); serverSocketChannel.configureBlocking(false); serverSocketChannel.socket().bind(new InetSocketAddress(8888)); serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT); } catch (Exception e) { e.printStackTrace(); } } /** * 监听客户端操作 */ public void listener() { while (true) { try { if (selector.select(1000) == 0) { continue; } Set<SelectionKey> selectionKeys = selector.selectedKeys(); Iterator<SelectionKey> iterator = selectionKeys.iterator(); while (iterator.hasNext()) { SelectionKey key = iterator.next(); if (key.isAcceptable()) { SocketChannel socketChannel = serverSocketChannel.accept(); socketChannel.configureBlocking(false); socketChannel.register(selector, SelectionKey.OP_READ); } if (key.isReadable()) { readData(key); } iterator.remove(); } } catch (IOException e) { e.printStackTrace(); } } } /** * 读取数据并群发给所有的用户 * @param key */ private void readData(SelectionKey key) { try { if (key.isReadable()) { SocketChannel channel = (SocketChannel) key.channel(); ByteBuffer byteBuffer = ByteBuffer.allocate(1024); channel.read(byteBuffer); String s = new String(byteBuffer.array()); sendData2All(s); } } catch (IOException e) { e.printStackTrace(); } } /** * 群发给所有的用户 * @param msg 需要发送的消息 */ private void sendData2All(String msg) { try { Set<SelectionKey> keys = selector.keys(); for (SelectionKey key : keys) { SelectableChannel channel = key.channel(); if (channel instanceof SocketChannel) { System.out.println(":::" + msg); ByteBuffer byteBuffer = ByteBuffer.wrap(msg.getBytes()); SocketChannel socketChannel = (SocketChannel) channel; socketChannel.write(byteBuffer); } } } catch (Exception e) { e.printStackTrace(); } } public static void main(String[] args) { ChatServer chatServer = new ChatServer(); chatServer.listener(); } }

2.1 构建Selector以及服务端监听通道

当ChatServer对象被创建时具体实现步骤如下

（1）创建serverSocketChannel对象

（2）设置处理模式为非阻塞模式

（3）绑定监听端口

（4）将channel注册到selector中

 public class ChatServer { private ServerSocketChannel serverSocketChannel; private Selector selector; /** * 初始化服务端 */ public ChatServer() { try { selector = Selector.open(); serverSocketChannel = serverSocketChannel.open(); serverSocketChannel.configureBlocking(false); serverSocketChannel.socket().bind(new InetSocketAddress(8888)); serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT); } catch (Exception e) { e.printStackTrace(); } } }

2.2 实现监听并处理建立连接请求

连接请求处理实现步骤

（1）获得所有有事件的key，通过key就可以拿到用户的SocketChannel

（2）循环遍历每一个key，判断当前是读事件，还是建立连接事件

（3）如果是建立连接事件则直接将该通道注册到selector中

（4）如果是读数据事件就交给具体的读数据方法处理数据

2.3 处理读数据数据

处理的具体实现步骤

（1）通过key获取和用户连接的通道（相当于输入流）

（2）获取通道的数据并打印

（3）将数据转发给其他在线用户

 public void listener() { while (true) { try { if (selector.select(1000) == 0) { continue; } Set<SelectionKey> selectionKeys = selector.selectedKeys(); Iterator<SelectionKey> iterator = selectionKeys.iterator(); while (iterator.hasNext()) { SelectionKey key = iterator.next(); if (key.isAcceptable()) { SocketChannel socketChannel = serverSocketChannel.accept(); socketChannel.configureBlocking(false); socketChannel.register(selector, SelectionKey.OP_READ); } if (key.isReadable()) { readData(key); } iterator.remove(); } } catch (IOException e) { e.printStackTrace(); } } }

2.4 群发数据实现

数据群发实现步骤

（1）当前在线用户实际上就是selector中所有注册的key，也就是在线的用户

（2）通过key拿到和用户的链接讲消息转发出去

 /** * 监听客户端操作 */ /** * 读取数据并群发给所有的用户 * @param key */ private void readData(SelectionKey key) { try { if (key.isReadable()) { SocketChannel channel = (SocketChannel) key.channel(); ByteBuffer byteBuffer = ByteBuffer.allocate(1024); channel.read(byteBuffer); String s = new String(byteBuffer.array()); sendData2All(s); } } catch (IOException e) { e.printStackTrace(); } }

2.5 启动服务端

 public static void main(String[] args) { ChatServer chatServer = new ChatServer(); chatServer.listener(); }

3. 客户端实现

客户端实现

（1）首先创建SocketChannel对象并链接到具体的服务器

（2）将通道注册到selector中

（3）开启一个新的线程监听selector中所有key的事件

（4）在主线程中循环阻塞获取用户的输入 

 public class ChatClient { public static void main(String[] args) throws Exception { Selector selector = Selector.open(); SocketChannel socketChannel = SocketChannel.open(new InetSocketAddress("127.0.0.1", 8888)); socketChannel.configureBlocking(false); socketChannel.register(selector, SelectionKey.OP_READ); new Thread(() -> { while (true) { try { int select = selector.select(1000); if (select > 0) { for (SelectionKey key : selector.selectedKeys()) { if (key.isReadable()) { SocketChannel channel = (SocketChannel) key.channel(); ByteBuffer byteBuffer = ByteBuffer.allocate(1024); channel.read(byteBuffer); System.out.println(":==:" + new String(byteBuffer.array())); System.out.println(new String(byteBuffer.array())); } } } } catch (Exception e) { e.printStackTrace(); } } }).start(); while(true) { Scanner scanner = new Scanner(System.in); socketChannel.write(ByteBuffer.wrap(scanner.nextLine().getBytes())); } } }

猜你喜欢：

什么是filter?filter是用来做什么的?

如何理解面向对象编程中的类和对象? 

shiro的编码/解码详细介绍