01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
public class FinalServerNioSocketChannel extends NioSocketChannel {
    public FinalServerNioSocketChannel(Channel parent, SocketChannel socket) {
        super(parent, socket);
    }

    // 自定义ID
    @Override
    protected ChannelId newId() {
        return new ChannelId() {
            private String id = IdUtil.objectId();

            @Override
            public String asShortText() {
                return id;
            }

            @Override
            public String asLongText() {
                return id;
            }

            @Override
            public int compareTo(ChannelId o) {
                return id.equals(o.asLongText()) ? 1 : 0;
            }
        };
    }
}

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
public class FinalServerNioServerSocketChannel extends NioServerSocketChannel {
    private static final Logger logger=LoggerFactory.getLogger(FinalServerNioServerSocketChannel.class);

    @Override
    protected int doReadMessages(List<Object> buf) throws Exception {
        SocketChannel ch = SocketUtils.accept(javaChannel());

        try {
            if (ch != null) {
                // 此处重写ID
                NioSocketChannel nioSocketChannel = new FinalServerNioSocketChannel(this, ch);
                buf.add(nioSocketChannel);
                return 1;
            }
        } catch (Throwable t) {
            logger.warn("Failed to create a new channel from an accepted socket.", t);

            try {
                ch.close();
            } catch (Throwable t2) {
                logger.warn("Failed to close a socket.", t2);
            }
        }

        return 0;
    }
}

01
02
03
04
05
06
07
08
09
ServerBootstrap serverBootstrap = new ServerBootstrap();
serverBootstrap.group(mainGroup, subGroup)      //设置主从线程
        .channel(FinalServerNioServerSocketChannel.class) //  设置nio的双向管道
        //当连接被阻塞时BACKLOG代表的是阻塞队列的长度
        .option(ChannelOption.SO_BACKLOG, 256)
        //置连接为保持活动的状态
        .childOption(ChannelOption.SO_KEEPALIVE, true);
// 子处理器
serverBootstrap.childHandler(new ServerInitializer(applicationContext));