Netty——NIO(Selector处理accept事件)代码示例
Posted 小志的博客
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Netty——NIO(Selector处理accept事件)代码示例相关的知识,希望对你有一定的参考价值。
目录
一、服务端代码示例
-
服务端代码示例
package com.example.nettytest.nio.day3; import lombok.extern.slf4j.Slf4j; import java.io.IOException; import java.net.InetSocketAddress; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; import java.util.Iterator; import java.util.Set; /** * @description: Selector处理accept事件 代码示例 * @author: xz * @create: 2022-09-01 */ @Slf4j public class Test2Server public static void main(String[] args) nioselectorAcceptServer(); /** * Selector处理accept事件 方法 * */ private static void nioSelectorAcceptServer() try (ServerSocketChannel channel = ServerSocketChannel.open()) //1、创建服务器 //绑定监听端口 channel.bind(new InetSocketAddress(8080)); //设置为非阻塞模式 channel.configureBlocking(false); System.out.println("channel=="+channel); /** * 2、创建Selector,管理多个channel */ Selector selector = Selector.open(); /** * 3、建立Selector与channel的联系(也称为注册) * key只关注事件,绑定的事件类型4种,connect - 客户端连接成功时触发;accept - 服务器端成功接受连接时触发; read - 数据可读入时触发;write - 数据可写出时触发, * */ channel.register(selector, SelectionKey.OP_ACCEPT); while(true) /** * 3、select 方法, 没有事件发生,线程阻塞,有事件,线程才会恢复运行 * select 在事件未处理时,它不会阻塞 */ int count = selector.select(); log.debug("select count: ", count); // 获取所有事件 Set<SelectionKey> keys = selector.selectedKeys(); // 遍历所有事件,逐一处理 Iterator<SelectionKey> iterator = keys.iterator(); //遍历所有事件,逐一处理 while(iterator.hasNext()) SelectionKey key = iterator.next(); log.info("key====",key); // 判断事件类型,如果事件类型是 accept - 服务器端成功接受连接时触发; if (key.isAcceptable()) //channel中有哪些key ServerSocketChannel c = (ServerSocketChannel) key.channel(); //必须处理 selector 上的 channel SocketChannel sc = c.accept(); log.debug("sc===", sc); // 处理完毕,必须将事件移除 iterator.remove(); catch (IOException e) e.printStackTrace();
二、客户端代码示例
-
客户端代码示例
package com.example.nettytest.nio.day3; import java.io.IOException; import java.net.Socket; /** * @description: * @author: xz * @create: 2022-09-01 */ public class Test2Client public static void main(String[] args) try (Socket socket = new Socket("localhost", 8080)) System.out.println(socket); socket.getOutputStream().write("hello world".getBytes()); System.in.read(); catch (IOException e) e.printStackTrace();
三、启动一个客户端测试
-
先启动服务端
由下图输出结果可知,由于没有事件发生,再select 方法处,线程阻塞。
-
再启动客户端
-
再查看服务端控制台输出
由下图输出结果可知,由于有事件发生,再select 方法处,线程会恢复运行。
四、启动2个客户端测试
- 再启动一个客户端
- 再次查看服务端控制台输出
由下图输出结果可知,由于有事件发生,再select 方法处,线程再次恢复运行。并且服务端2次接受的key是同一个对象。
五、事件发生后能否不处理
- 事件发生后,要么处理,要么取消(cancel),不能什么都不做,否则下次该事件仍会触发,这是因为 nio 底层使用的是水平触发。
以上是关于Netty——NIO(Selector处理accept事件)代码示例的主要内容,如果未能解决你的问题,请参考以下文章
Netty——NIO(Selector处理accept事件)代码示例
Netty——NIO(Selector处理accept事件)代码示例
Netty——网络编程 NIO(Selector处理read事件)代码示例
Netty——网络编程 NIO(Selector处理accept事件)代码示例