/**
     * 服務(wù)啟動器
     *
     * @return
     */
    @Bean
    public ServerBootstrap serverBootstrap() {
        ServerBootstrap serverBootstrap = new ServerBootstrap()
                // 指定使用的線程組
                .group(boosGroup(), workerGroup())
                // 指定使用的通道
                .channel(NioServerSocketChannel.class)
                // 指定連接超時時間
                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, nettyProperties.getTimeout())          
                // 通過換行符處理沾包/拆包
                .childHandler(new NettyServerLineBasedHandler());
        return serverBootstrap;
    }

public class NettyServerLineBasedHandler extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel socketChannel) throws Exception {
        ChannelPipeline pipeline = socketChannel.pipeline();
        // 使用LineBasedFrameDecoder解決粘包問題，其會根據(jù)"\n"或"\r\n"對二進制數(shù)據(jù)進行拆分，封裝到不同的ByteBuf實例中，并且每次查找的最大長度為1024字節(jié)
        pipeline.addLast(new LineBasedFrameDecoder(1024, true, true));
        // 將上一步解碼后的數(shù)據(jù)轉(zhuǎn)碼為Message實例
        pipeline.addLast(new MessageDecodeHandler());
        // 對發(fā)送客戶端的數(shù)據(jù)進行編碼
        pipeline.addLast(new MessageEncodeHandler());
        // 對數(shù)據(jù)進行最終處理
        pipeline.addLast(new ServerListenerHandler());
    }
}

    @Override
    protected void initChannel(SocketChannel socketChannel) throws Exception {
        // 數(shù)據(jù)分割符
        String delimiterStr = "##@##";
        ByteBuf delimiter = Unpooled.copiedBuffer(delimiterStr.getBytes());
        ChannelPipeline pipeline = socketChannel.pipeline();
        // 使用自定義分隔符處理拆包/沾包，并且每次查找的最大長度為1024字節(jié)
        pipeline.addLast(new DelimiterBasedFrameDecoder(1024, delimiter));
        // 將上一步解碼后的數(shù)據(jù)轉(zhuǎn)碼為Message實例
        pipeline.addLast(new MessageDecodeHandler());
        // 對發(fā)送客戶端的數(shù)據(jù)進行編碼，并添加數(shù)據(jù)分隔符
        pipeline.addLast(new MessageEncodeHandler(delimiterStr));
        // 對數(shù)據(jù)進行最終處理
        pipeline.addLast(new ServerListenerHandler());
    }

public class MessageEncodeHandler extends MessageToByteEncoder<Message> {
    // 數(shù)據(jù)分割符
    String delimiter;
    public MessageEncodeHandler(String delimiter) {
        this.delimiter = delimiter;
    }
    @Override
    protected void encode(ChannelHandlerContext channelHandlerContext, Message message, ByteBuf out) throws Exception {
        out.writeBytes((message.toJsonString() + delimiter).getBytes(CharsetUtil.UTF_8));
    }
}

    /**
     * 服務(wù)啟動器
     *
     * @return
     */
    @Bean
    public ServerBootstrap serverBootstrap() {
        ServerBootstrap serverBootstrap = new ServerBootstrap()
                // 指定使用的線程組
                .group(boosGroup(), workerGroup())
                // 指定使用的通道
                .channel(NioServerSocketChannel.class)
                // 指定連接超時時間
                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, nettyProperties.getTimeout())
                // 指定為固定長度字節(jié)的處理器
                .childHandler(new NettyServerFixedLengthHandler());
        return serverBootstrap;
    }

public class NettyServerFixedLengthHandler extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel socketChannel) throws Exception {
        // 固定字節(jié)長度
        Integer length = 100;
        ChannelPipeline pipeline = socketChannel.pipeline();
        // 按固定100字節(jié)數(shù)拆分接收到的ByteBuf的解碼器
        pipeline.addLast(new FixedLengthFrameDecoder(length));
        // 將上一步解碼后的數(shù)據(jù)轉(zhuǎn)碼為Message實例
        pipeline.addLast(new MessageDecodeHandler());
        // 對發(fā)送客戶端的數(shù)據(jù)進行自定義編碼，并設(shè)置字節(jié)長度不足補0
        pipeline.addLast(new MessageEncodeFixedLengthHandler(length));
        // 對數(shù)據(jù)進行最終處理
        pipeline.addLast(new ServerListenerHandler());
    }
}

public class MessageEncodeFixedLengthHandler extends MessageToByteEncoder<Message> {
    private int length;
    public MessageEncodeFixedLengthHandler(int length) {
        this.length = length;
    }
    /**
     * 使用固定字節(jié)長度編碼消息，字節(jié)長度不足時補0
     *
     * @param ctx the {@link ChannelHandlerContext} which this {@link MessageToByteEncoder} belongs to
     * @param msg the message to encode
     * @param out the {@link ByteBuf} into which the encoded message will be written
     * @throws Exception
     */
    @Override
    protected void encode(ChannelHandlerContext ctx, Message msg, ByteBuf out) throws Exception {
        String jsonStr = msg.toJsonString();
        // 如果長度不足，則進行補0
        if (jsonStr.length() < length) {
            jsonStr = addSpace(jsonStr);
        }
        // 使用Unpooled.wrappedBuffer實現(xiàn)零拷貝，將字符串轉(zhuǎn)為ByteBuf
        ctx.writeAndFlush(Unpooled.wrappedBuffer(jsonStr.getBytes()));
    }
    /**
     * 如果沒有達到指定長度進行補0
     *
     * @param msg
     * @return
     */
    private String addSpace(String msg) {
        StringBuilder builder = new StringBuilder(msg);
        for (int i = 0; i < length - msg.length(); i++) {
            builder.append(0);
        }
        return builder.toString();
    }
}

    /**
     * 服務(wù)啟動器
     *
     * @return
     */
    @Bean
    public ServerBootstrap serverBootstrap() {
        ServerBootstrap serverBootstrap = new ServerBootstrap()
                // 指定使用的線程組
                .group(boosGroup(), workerGroup())
                // 指定使用的通道
                .channel(NioServerSocketChannel.class)
                // 指定連接超時時間
                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, nettyProperties.getTimeout())
                // 請求頭包含數(shù)據(jù)長度
                .childHandler(new NettyServerLenghtFieldBasedHandler());
        return serverBootstrap;
    }

public class NettyServerLenghtFieldBasedHandler extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel socketChannel) throws Exception {
        ChannelPipeline pipeline = socketChannel.pipeline();
        // 請求頭包含數(shù)據(jù)長度，根據(jù)長度進行沾包拆包處理
        /**
         * maxFrameLength：指定了每個包所能傳遞的最大數(shù)據(jù)包大小；
         * lengthFieldOffset：指定了長度字段在字節(jié)碼中的偏移量；
         * lengthFieldLength：指定了長度字段所占用的字節(jié)長度；
         * lengthAdjustment：對一些不僅包含有消息頭和消息體的數(shù)據(jù)進行消息頭的長度的調(diào)整，這樣就可以只得到消息體的數(shù)據(jù)，這里的lengthAdjustment指定的就是消息頭的長度；
         * initialBytesToStrip：對于長度字段在消息頭中間的情況，可以通過initialBytesToStrip忽略掉消息頭以及長度字段占用的字節(jié)。
         */
        pipeline.addLast(new LengthFieldBasedFrameDecoder(1024, 0, 2, 0, 2));
        // 在請求頭添加字節(jié)長度字段
        pipeline.addLast(new LengthFieldPrepender(2));
        // 將上一步解碼后的數(shù)據(jù)轉(zhuǎn)碼為Message實例
        pipeline.addLast(new MessageDecodeHandler());
        // 對發(fā)送客戶端的數(shù)據(jù)進行編碼，字節(jié)長度不足補0
        pipeline.addLast(new MessageEncodeHandler());
        // 對數(shù)據(jù)進行最終處理
        pipeline.addLast(new ServerListenerHandler());
    }
}