面试官问我NIO，我舒服了

待我称王封你为后i 2021-09-07 06:04 439阅读 0赞

![e78f75faa3b3245da232e2800693a82d.png][]

![c1c2c523f19b30e45af4cffb1797b847.png][]

![d5bd8ef6a6c112491ebc0d24f5e6e095.png][]

![9132a0bd3264ea812cf5874929a2ec32.png][]

![73da46adecae82da93ac6479e2dca839.png][]

服务端：

public class NoBlockServer { 
    
        public static void main(String[] args) throws IOException { 
    
            // 1.获取通道
            ServerSocketChannel server = ServerSocketChannel.open();
    
            // 2.切换成非阻塞模式
            server.configureBlocking(false);
    
            // 3. 绑定连接
            server.bind(new InetSocketAddress(6666));
    
            // 4. 获取选择器
            Selector selector = Selector.open();
    
            // 4.1将通道注册到选择器上，指定接收“监听通道”事件
            server.register(selector, SelectionKey.OP_ACCEPT);
    
            // 5. 轮训地获取选择器上已“就绪”的事件--->只要select()>0，说明已就绪
            while (selector.select() > 0) { 
                // 6. 获取当前选择器所有注册的“选择键”(已就绪的监听事件)
                Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();
    
                // 7. 获取已“就绪”的事件，(不同的事件做不同的事)
                while (iterator.hasNext()) { 
    
                    SelectionKey selectionKey = iterator.next();
    
                    // 接收事件就绪
                    if (selectionKey.isAcceptable()) { 
    
                        // 8. 获取客户端的链接
                        SocketChannel client = server.accept();
    
                        // 8.1 切换成非阻塞状态
                        client.configureBlocking(false);
    
                        // 8.2 注册到选择器上-->拿到客户端的连接为了读取通道的数据(监听读就绪事件)
                        client.register(selector, SelectionKey.OP_READ);
    
                    } else if (selectionKey.isReadable()) {  // 读事件就绪
    
                        // 9. 获取当前选择器读就绪状态的通道
                        SocketChannel client = (SocketChannel) selectionKey.channel();
    
                        // 9.1读取数据
                        ByteBuffer buffer = ByteBuffer.allocate(1024);
    
                        // 9.2得到文件通道，将客户端传递过来的图片写到本地项目下(写模式、没有则创建)
                        FileChannel outChannel = FileChannel.open(Paths.get("2.png"), StandardOpenOption.WRITE, StandardOpenOption.CREATE);
    
                        while (client.read(buffer) > 0) { 
                            // 在读之前都要切换成读模式
                            buffer.flip();
    
                            outChannel.write(buffer);
    
                            // 读完切换成写模式，能让管道继续读取文件的数据
                            buffer.clear();
                        }
                    }
                    // 10. 取消选择键(已经处理过的事件，就应该取消掉了)
                    iterator.remove();
                }
            }
    
        }
    }

客户端：

public class NoBlockClient { 
    
        public static void main(String[] args) throws IOException { 
    
            // 1. 获取通道
            SocketChannel socketChannel = SocketChannel.open(new InetSocketAddress("127.0.0.1", 6666));
    
            // 1.1切换成非阻塞模式
            socketChannel.configureBlocking(false);
    
            // 1.2获取选择器
            Selector selector = Selector.open();
    
            // 1.3将通道注册到选择器中，获取服务端返回的数据
            socketChannel.register(selector, SelectionKey.OP_READ);
    
            // 2. 发送一张图片给服务端吧
            FileChannel fileChannel = FileChannel.open(Paths.get("X:\\Users\\ozc\\Desktop\\面试造火箭\\1.png"), StandardOpenOption.READ);
    
            // 3.要使用NIO，有了Channel，就必然要有Buffer，Buffer是与数据打交道的呢
            ByteBuffer buffer = ByteBuffer.allocate(1024);
    
            // 4.读取本地文件(图片)，发送到服务器
            while (fileChannel.read(buffer) != -1) { 
    
                // 在读之前都要切换成读模式
                buffer.flip();
    
                socketChannel.write(buffer);
    
                // 读完切换成写模式，能让管道继续读取文件的数据
                buffer.clear();
            }
    
    
            // 5. 轮训地获取选择器上已“就绪”的事件--->只要select()>0，说明已就绪
            while (selector.select() > 0) { 
                // 6. 获取当前选择器所有注册的“选择键”(已就绪的监听事件)
                Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();
    
                // 7. 获取已“就绪”的事件，(不同的事件做不同的事)
                while (iterator.hasNext()) { 
    
                    SelectionKey selectionKey = iterator.next();
    
                    // 8. 读事件就绪
                    if (selectionKey.isReadable()) { 
    
                        // 8.1得到对应的通道
                        SocketChannel channel = (SocketChannel) selectionKey.channel();
    
                        ByteBuffer responseBuffer = ByteBuffer.allocate(1024);
    
                        // 9. 知道服务端要返回响应的数据给客户端，客户端在这里接收
                        int readBytes = channel.read(responseBuffer);
    
                        if (readBytes > 0) { 
                            // 切换读模式
                            responseBuffer.flip();
                            System.out.println(new String(responseBuffer.array(), 0, readBytes));
                        }
                    }
    
                    // 10. 取消选择键(已经处理过的事件，就应该取消掉了)
                    iterator.remove();
                }
            }
        }
    
    }

![8cb1f66ce7947c92b9bbef0a40ee4b59.png][]

![e0f4a0c54a50a943b51071b49dfe1335.png][]

![5d9bdb400cd2019b96635652b9bd231d.png][]

![027d8b7e3b815d798a8385832b69f9a9.png][]

![b93820dae323493b30633e61ce63f112.png][]

![1b8e99e08b4ff81fbc062aeb3bbe2843.png][]

![423a7c64ad7df912c1f1d763716be5a7.png][]

![1c20c97c2aee0e79a99b267612cf0da8.png][]

![40d29b66d2d84b319bfd3fcda67c9a57.png][]

![f24e9ce4924c24cce65c24daf179cd8d.png][]

![d883623ddf3e99efb78a117967d12f7d.png][]

**[【对线面试官】系列][Link 1] 一周两篇持续更新中！**

[e78f75faa3b3245da232e2800693a82d.png]: /images/20210827/d00ace08c343408bbfcc4fbd26a2b7ca.png
[c1c2c523f19b30e45af4cffb1797b847.png]: /images/20210827/41f91c0e8321494e95fd8253088379c2.png
[d5bd8ef6a6c112491ebc0d24f5e6e095.png]: /images/20210827/c2e78453748c42c7859ee53141453b3b.png
[9132a0bd3264ea812cf5874929a2ec32.png]: /images/20210827/af36075bfa674c5ea4eb992bd4e0b8cd.png
[73da46adecae82da93ac6479e2dca839.png]: /images/20210827/a172103d3b3c4f1cbe87e8c2a81c929f.png
[8cb1f66ce7947c92b9bbef0a40ee4b59.png]: /images/20210827/d803ddb040f94ccd8d2709a2a00bc867.png
[e0f4a0c54a50a943b51071b49dfe1335.png]: /images/20210827/bb2b5bd5c48a40519bf3f14f43a5bec7.png
[5d9bdb400cd2019b96635652b9bd231d.png]: /images/20210827/a55c1ed4f51249faaede86f6e9830026.png
[027d8b7e3b815d798a8385832b69f9a9.png]: /images/20210827/27e4cbb8a7e04968aa824e96a64ab538.png
[b93820dae323493b30633e61ce63f112.png]: /images/20210827/6a57f9e362354239bb63a2fb363ae557.png
[1b8e99e08b4ff81fbc062aeb3bbe2843.png]: /images/20210827/b5d59578d080459ebd0ce04b6456f4e7.png
[423a7c64ad7df912c1f1d763716be5a7.png]: /images/20210827/bef0441c02a3442a88425b77b8bf89c2.png
[1c20c97c2aee0e79a99b267612cf0da8.png]: /images/20210827/4b718a3065564291b93f37df5675575c.png
[40d29b66d2d84b319bfd3fcda67c9a57.png]: /images/20210827/0e5e6836cebb4b0fb2da310e79a5299f.png
[f24e9ce4924c24cce65c24daf179cd8d.png]: /images/20210827/6e16161da70845e89965b6516e774dda.png
[d883623ddf3e99efb78a117967d12f7d.png]: /images/20210827/4a087c4183584c84a6362cd2a3c768a9.png
[Link 1]: https://mp.weixin.qq.com/mp/appmsgalbum?__biz=MzU4NzA3MTc5Mg==&action=getalbum&album_id=1657204970858872832#wechat_redirect