Netty——网络编程 NIO（Selector处理read事件）代码示例

服务端代码示例

package com.example.nettytest.nio.day3;

import com.example.nettytest.nio.day1.ByteBufferUtil;
import lombok.extern.slf4j.Slf4j;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
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处理read事件 代码示例
 * @author: xz
 * @create: 2022-09-01
 */
@Slf4j
public class Test3Server {
    public static void main(String[] args) {
        nioSelectorReadServer();
    }
    /**
     * Selector处理read事件 方法
     * */
    private static void nioSelectorReadServer(){
        try (ServerSocketChannel channel = ServerSocketChannel.open()) {//1、创建服务器
            //绑定监听端口
            channel.bind(new InetSocketAddress(8080));
            //设置为非阻塞模式
            channel.configureBlocking(false);
            System.out.println(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) {
                /**
                 * 4、select 方法, 没有事件发生，线程阻塞，有事件，线程才会恢复运行
                 *   select 在事件未处理时，它不会阻塞
                 */
                int count = selector.select();
                log.debug("select count: {}", count);
                // 获取所有事件
                Set keys = selector.selectedKeys();
                // 遍历所有事件，逐一处理
                Iterator iter = keys.iterator();
                while (iter.hasNext()) {
                    SelectionKey key = iter.next();
                    // 判断事件类型 如果事件类型是 accept - 服务器端成功接受连接时触发;
                    if (key.isAcceptable()) {
                        //channel中有哪些key
                        ServerSocketChannel c = (ServerSocketChannel) key.channel();
                        // 必须处理 selector 上的 channel
                        SocketChannel sc = c.accept();
                        //设置为非阻塞模式
                        sc.configureBlocking(false);
                        //建立Selector与channel的联系（也称为注册）
                        sc.register(selector, SelectionKey.OP_READ);
                        log.debug("连接已建立: {}", sc);
                    // 判断事件类型 如果事件类型是read - 数据可读入时触发
                    } else if (key.isReadable()) {
                        //channel中有哪些key
                        SocketChannel sc = (SocketChannel) key.channel();
                        //申请ByteBuffer容量
                        ByteBuffer buffer = ByteBuffer.allocate(128);
                        //从channel中读并写入到buffer
                        int read = sc.read(buffer);
                        if(read == -1) { //如果读到末尾
                            //取消注册在 selector 上的 channel
                            key.cancel();
                            //关闭channel
                            sc.close();
                        } else { //如果没有读到末尾
                            //切换到读模式
                            buffer.flip();
                            //打印可读取内容
                            ByteBufferUtil.debugRead(buffer);
                        }
                    }
                    // 处理完毕，必须将事件移除
                    iter.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 Test3Client {
    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();
        }
    }
}

工具类，打印输入、输出数据使用

package com.example.nettytest.nio.day1;

import io.netty.util.internal.StringUtil;

import java.nio.ByteBuffer;

import static io.netty.util.internal.MathUtil.isOutOfBounds;
import static io.netty.util.internal.StringUtil.NEWLINE;

public class ByteBufferUtil {
    private static final char[] BYTE2CHAR = new char[256];
    private static final char[] HEXDUMP_TABLE = new char[256 * 4];
    private static final String[] HEXPADDING = new String[16];
    private static final String[] HEXDUMP_ROWPREFIXES = new String[65536 >>> 4];
    private static final String[] BYTE2HEX = new String[256];
    private static final String[] BYTEPADDING = new String[16];

    static {
        final char[] DIGITS = "0123456789abcdef".toCharArray();
        for (int i = 0; i  4 & 0x0F];
            HEXDUMP_TABLE[(i