通天战队|「015期」JavaSE面试题（十五）：网络IO流( 二 ) 2020年百日百更原创Java面试题库之往期

public class NioDemo implements Runnable {public int id = 100001;public int bufferSize = 2048;@Overridepublic void run {init;}public void init {try {// 创建通道和选择器ServerSocketChannel socketChannel = ServerSocketChannel.open;Selector selector = Selector.open;InetSocketAddress inetSocketAddress = new InetSocketAddress(InetAddress.getLocalHost, 4700);socketChannel.socket.bind(inetSocketAddress);// 设置通道非阻塞绑定选择器socketChannel.configureBlocking(false);socketChannel.register(selector, SelectionKey.OP_ACCEPT).attach(id++);System.out.println("Server started .... port:4700");listener(selector);} catch (Exception e) {}}public void listener(Selector in_selector) {try {while (true) {Thread.sleep(1 * 1000);in_selector.select; // 阻塞直到有就绪事件为止Set readySelectionKey = in_selector.selectedKeys;Iterator it = readySelectionKey.iterator;while (it.hasNext) {SelectionKey selectionKey = it.next;// 判断是哪个事件if (selectionKey.isAcceptable) {// 客户请求连接System.out.println(selectionKey.attachment+ " - 接受请求事件");// 获取通道接受连接,// 设置非阻塞模式（必须），同时需要注册读写数据的事件，这样有消息触发时才能捕获ServerSocketChannel serverSocketChannel = (ServerSocketChannel) selectionKey.channel;serverSocketChannel.accept.configureBlocking(false).register(in_selector,SelectionKey.OP_READ| SelectionKey.OP_WRITE).attach(id++);System.out.println(selectionKey.attachment + " - 已连接");// 下面这种写法是有问题的不应该在serverSocketChannel上面注册/** serverSocketChannel.configureBlocking(false);* serverSocketChannel.register(in_selector,* SelectionKey.OP_READ);* serverSocketChannel.register(in_selector,* SelectionKey.OP_WRITE);*/}if (selectionKey.isReadable) {// 读数据System.out.println(selectionKey.attachment+ " - 读数据事件");SocketChannel clientChannel = (SocketChannel) selectionKey.channel;ByteBuffer receiveBuf = ByteBuffer.allocate(bufferSize);clientChannel.read(receiveBuf);System.out.println(selectionKey.attachment+ " - 读取数据：" + getString(receiveBuf));}if (selectionKey.isWritable) {// 写数据System.out.println(selectionKey.attachment+ " - 写数据事件");SocketChannel clientChannel = (SocketChannel) selectionKey.channel;ByteBuffer sendBuf = ByteBuffer.allocate(bufferSize);String sendText = "hello\n";sendBuf.put(sendText.getBytes);sendBuf.flip; //写完数据后调用此方法clientChannel.write(sendBuf);}if (selectionKey.isConnectable) {System.out.println(selectionKey.attachment+ " - 连接事件");}// 必须removed 否则会继续存在，下一次循环还会进来,// 注意removed 的位置，针对一个.next remove一次it.remove;}}} catch (Exception e) {System.out.println("Error - " + e.getMessage);e.printStackTrace;}}/*** ByteBuffer 转换 String** @param buffer* @return*/public static String getString(ByteBuffer buffer) {String string = "";try {for (int i = 0; i < buffer.position; i++) {string += (char) buffer.get(i);}return string;} catch (Exception ex) {ex.printStackTrace;return "";}}}Q：
什么是AIO？
异步非阻塞
每个连接发送过来的请求，都会绑定一个buffer ，然后通知操作系统去异步完成读，此时你的程序是会去干别的事儿的，等操作系统完成数据读取之后，就会回调你的接口，给你操作系统异步读完的数据。

通天战队|「015期」JavaSE面试题（十五）：网络IO流( 二 )

推荐阅读

快手宣传语是什么快手宣传词

中年妇女怎么样才能有少女感？

智通财经@上海电气(02727)年度纯利增24.81%至37.2亿元

伦纳德|美媒评现役top5小前锋，乔治第4，小卡第3，第1没有悬念

抖音口碑分低于4.6限流吗？怎么投流？

「医院船」美版“方舱医院”终于要动工？美军：“准备部署”5支野战医院部队

环球时报新媒体▲让人有点害怕，“罗斯福”号航母舰员送别被革职舰长的场面

|厨房不要傻傻装推拉门了，这样设计更美观实用，老师傅看了都夸好

雀斑是怎么淡化怎么去雀斑

南航内部人员能否查到二十多天前的乘客信息呢，只有航班号和座位号，不知道姓名

霉菌和支原体合并感染治疗

男生们可以学习的绑鞋带技巧到底有多少种？鞋带系法

冒险岛打豆豆机器人坐骑在哪

小陈聊搭配|如何优雅地老去？这3位日本老太太告诉你秘诀，收藏好以后用得上

台剧想见你剧情简介,《想见你》台剧-

「」团餐行业发展趋势分析：团餐业态成为餐饮行业的新蓝海

「印度少管所犯人感染」印度奥里萨邦少管所45名在押少年犯确诊新冠肺炎

科技热门源聚湾区——“创业顺德”开源芯片生态建设系列活动启动，同芯开创

中国要建印尼高铁，朋友公司中标，去那工作安全有保障吗

水一白聊历史：只因为母亲的一个错误选择，丢掉了太子之位，一个可怜的皇太子