/**
     * 服務(wù)啟動(dòng)器
     *
     * @return
     */
    @Bean
    public ServerBootstrap serverBootstrap() {
        ServerBootstrap serverBootstrap = new ServerBootstrap()
                // 指定使用的線程組
                .group(boosGroup(), workerGroup())
                // 指定使用的通道
                .channel(NioServerSocketChannel.class)
                // 指定連接超時(shí)時(shí)間
                .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解決粘包問題，其會(huì)根據(jù)"\n"或"\r\n"對(duì)二進(jìn)制數(shù)據(jù)進(jìn)行拆分，封裝到不同的ByteBuf實(shí)例中，并且每次查找的最大長(zhǎng)度為1024字節(jié)
        pipeline.addLast(new LineBasedFrameDecoder(1024, true, true));
        // 將上一步解碼后的數(shù)據(jù)轉(zhuǎn)碼為Message實(shí)例
        pipeline.addLast(new MessageDecodeHandler());
        // 對(duì)發(fā)送客戶端的數(shù)據(jù)進(jìn)行編碼
        pipeline.addLast(new MessageEncodeHandler());
        // 對(duì)數(shù)據(jù)進(jìn)行最終處理
        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();
        // 使用自定義分隔符處理拆包/沾包，并且每次查找的最大長(zhǎng)度為1024字節(jié)
        pipeline.addLast(new DelimiterBasedFrameDecoder(1024, delimiter));
        // 將上一步解碼后的數(shù)據(jù)轉(zhuǎn)碼為Message實(shí)例
        pipeline.addLast(new MessageDecodeHandler());
        // 對(duì)發(fā)送客戶端的數(shù)據(jù)進(jìn)行編碼，并添加數(shù)據(jù)分隔符
        pipeline.addLast(new MessageEncodeHandler(delimiterStr));
        // 對(duì)數(shù)據(jù)進(jìn)行最終處理
        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ù)啟動(dòng)器
     *
     * @return
     */
    @Bean
    public ServerBootstrap serverBootstrap() {
        ServerBootstrap serverBootstrap = new ServerBootstrap()
                // 指定使用的線程組
                .group(boosGroup(), workerGroup())
                // 指定使用的通道
                .channel(NioServerSocketChannel.class)
                // 指定連接超時(shí)時(shí)間
                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, nettyProperties.getTimeout())
                // 指定為固定長(zhǎng)度字節(jié)的處理器
                .childHandler(new NettyServerFixedLengthHandler());
        return serverBootstrap;
    }

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

public class MessageEncodeFixedLengthHandler extends MessageToByteEncoder<Message> {
    private int length;
    public MessageEncodeFixedLengthHandler(int length) {
        this.length = length;
    }
    /**
     * 使用固定字節(jié)長(zhǎng)度編碼消息，字節(jié)長(zhǎng)度不足時(shí)補(bǔ)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();
        // 如果長(zhǎng)度不足，則進(jìn)行補(bǔ)0
        if (jsonStr.length() < length) {
            jsonStr = addSpace(jsonStr);
        }
        // 使用Unpooled.wrappedBuffer實(shí)現(xiàn)零拷貝，將字符串轉(zhuǎn)為ByteBuf
        ctx.writeAndFlush(Unpooled.wrappedBuffer(jsonStr.getBytes()));
    }
    /**
     * 如果沒有達(dá)到指定長(zhǎng)度進(jìn)行補(bǔ)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ù)啟動(dòng)器
     *
     * @return
     */
    @Bean
    public ServerBootstrap serverBootstrap() {
        ServerBootstrap serverBootstrap = new ServerBootstrap()
                // 指定使用的線程組
                .group(boosGroup(), workerGroup())
                // 指定使用的通道
                .channel(NioServerSocketChannel.class)
                // 指定連接超時(shí)時(shí)間
                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, nettyProperties.getTimeout())
                // 請(qǐng)求頭包含數(shù)據(jù)長(zhǎng)度
                .childHandler(new NettyServerLenghtFieldBasedHandler());
        return serverBootstrap;
    }

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