Nio入门示例（服务器端&客户端）

电玩女神 2023-01-17 06:22 203阅读 0赞

### Nio入门示例 ###

简单的nio模型如图所示：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2MzI3MjY2_size_16_color_FFFFFF_t_70_pic_center]

#### 服务端 ####

代码示例：

//创建selector
            Selector selector = Selector.open();		
    		//创建一个channel并设置为非阻塞的
            ServerSocketChannel socketChannel = ServerSocketChannel.open();
            socketChannel.configureBlocking(false);
            //绑定端口
            socketChannel.bind(new InetSocketAddress(8899));
            //将register注册到selector上,将该channel指定为监听连接事件
            socketChannel.register(selector, SelectionKey.OP_ACCEPT);
    
            //监听连接
            while(true){
        
                //通过selector获取绑定在其身上的channel发生的事件个数
                if(selector.select() == 0){
        
                    continue;
                }
                //获取发生在当前selector上的所有事件
                Set<SelectionKey> selectionKeys = selector.selectedKeys();
                Iterator<SelectionKey> iterator = selectionKeys.iterator();
                while(iterator.hasNext()){
        
                    SelectionKey selectionKey = iterator.next();
                    //表示连接事件
                    if(selectionKey.isAcceptable()){
        
                        //接收连接并得到一个channel，并设置为非阻塞
                        SocketChannel acceptChannel = socketChannel.accept();
                        acceptChannel.configureBlocking(false);
                        acceptChannel.register(selector, SelectionKey.OP_READ,ByteBuffer.allocate(512));
                    }else  if(selectionKey.isReadable()){
        //读事件
                        //通过selector中的selectionKey获取发起读事件的channel
                        SocketChannel channel = (SocketChannel)selectionKey.channel();
                        //读取数据
                        ByteBuffer buffer = (ByteBuffer) selectionKey.attachment();
                        int limit = buffer.limit();
                        while(true){
        
                            channel.read(buffer);
                            System.out.println(new String(buffer.array(), "GBK"));
                            if(buffer.position()<limit){
        
                                break;
                            }
                            if(buffer.position() >= limit-1){
        
                                buffer.clear();
                            }
                        }
                    }
                    iterator.remove();
                }
            }

最关键的部分就是SelectionKey，它里面存储了很多信息。例如：Channel对象、Channel的作用(connect/read)，而这个对象与通道是一一对应的，当通道绑定在selector上时就会生成一个SelectionKey存在与Selector中。

Selector判断通道是否有事件发生时就会通过SelectionKey中的某些变量来判断：

public static final int OP_READ = 1 << 0;
    
    
    public static final int OP_WRITE = 1 << 2;
    
    
    public static final int OP_CONNECT = 1 << 3;
    
    public static final int OP_ACCEPT = 1 << 4;

如判断是否是读事件时：

readOps()会返回当前事件的值，只有是读事件时才会达成条件：(readyOps() & OP\_READ) != 0

public final boolean isReadable() {
        
        return (readyOps() & OP_READ) != 0;
    }

#### 客户端 ####

SocketChannel socketChannel = SocketChannel.open();
            socketChannel.configureBlocking(false);
    		//这里需要做判断，不能直接连接，因为如果直接连接可能会出现一种结果：还未连接完成时客户端就开始发送信息了
            if(!socketChannel.connect(new InetSocketAddress("127.0.0.1", 8899))){
        
                while (!socketChannel.finishConnect()){
        
                    System.out.println("客户端正在连接过程中");
                }
            }
            String s = "月亮惹的祸 (Live) - 张宇 (Phil Chang)\n" +
                    "词：十一郎\n" +
                    "曲：张宇\n" +
                    "都是你的错轻易爱上我\n" +
                    "让我不知不觉满足被爱的虚荣\n" +
                    "都是你的错你对人的宠\n" +
                    "是一种诱惑\n" +
                    "都是你的错在你的眼中\n" +
                    "总是藏着让人又爱又怜的朦胧\n" +
                    "都是你的错你的痴情梦\n" +
                    "像一个魔咒 被你爱过还能为谁蠢动\n" +
                    "我承认都是月亮惹的祸\n" +
                    "那样的月色太美你太温柔\n" +
                    "才会在刹那之间\n" +
                    "只想和你一起到白头\n" +
                    "我承认都是誓言惹的祸\n" +
                    "偏偏似糖如蜜说来最动人\n" +
                    "再怎么心如钢铁也成绕指柔\n" +
                    "都是你的错轻易爱上我\n" +
                    "让我不知不觉满足被爱的虚荣\n" +
                    "都是你的错你对人的宠\n" +
                    "是一种诱惑\n" +
                    "都是你的错在你的眼中\n" +
                    "总是藏着让人又爱又怜的朦胧\n" +
                    "都是你的错你的痴情梦\n" +
                    "像一个魔咒 被你爱过还能为谁蠢动\n" +
                    "我承认都是月亮惹的祸\n" +
                    "那样的月色太美你太温柔\n" +
                    "才会在刹那之间\n" +
                    "只想和你一起到白头\n" +
                    "我承认都是誓言惹的祸\n" +
                    "偏偏似糖如蜜说来最动人\n" +
                    "再怎么心如钢铁也成绕指柔\n" +
                    "怎样的情生意动\n" +
                    "会让两个人拿一生当承诺\n" +
                    "我承认都是誓言惹的祸\n" +
                    "偏偏似糖如蜜说来最动人\n" +
                    "再怎么心如钢铁也成绕指柔\n" +
                    "我承认都是月亮惹的祸\n" +
                    "那样的月色太美你太温柔\n" +
                    "才会在刹那之间\n" +
                    "只想和你一起到白头\n" +
                    "我承认都是誓言惹的祸\n" +
                    "偏偏似糖如蜜说来最动人\n" +
                    "再怎么心如钢铁也成绕指柔\n";
            ByteBuffer buffer = ByteBuffer.wrap(s.getBytes("GBK"));
            socketChannel.write(buffer);

这里可能会出现乱码的情况，原因：GBK编码的情况下一个汉字是两个字节，ascii中存在的字符是1个字节；客户端是一次性将全部的字节发送过来的，而服务器端设置的缓冲区ByteBuffer的大小是512个字节；所以中间可能会有两个中文字节会分开存在于服务端的两个ByteBuffer中。可以修改服务器端缓冲区的大小来解决。如果信息过大时就需要另外考虑别的方案解决。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2MzI3MjY2_size_16_color_FFFFFF_t_70_pic_center]: /images/20221021/17c6a8a0c3a64998a9179428d8308bc4.png