Netty发送带数据长度的数据

在Netty中发送带数据长度的数据可以使用LengthFieldPrepender编码器，它会在发送的数据前面添加表示数据长度的字节数组，以便接收方可以正确地解析数据。

使用LengthFieldPrepender非常简单，只需要在ChannelPipeline中加入即可。示例代码如下：

// 创建一个ByteBufAllocator，用来分配ByteBuf
ByteBufAllocator allocator = ByteBufAllocator.DEFAULT;

// 创建一个LengthFieldPrepender，指定长度字段的长度为4个字节
LengthFieldPrepender lengthFieldPrepender = new LengthFieldPrepender(4);

// 创建一个ChannelInitializer，用来初始化ChannelPipeline
ChannelInitializer<SocketChannel> initializer = new ChannelInitializer<SocketChannel>() {
    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        // 获取ChannelPipeline
        ChannelPipeline pipeline = ch.pipeline();
        // 加入LengthFieldPrepender
        pipeline.addLast("lengthFieldPrepender", lengthFieldPrepender);
        // 加入自定义的Handler
        pipeline.addLast("myHandler", new MyHandler());
    }
};

// 创建一个Bootstrap，用来启动客户端
Bootstrap bootstrap = new Bootstrap();
bootstrap.group(new NioEventLoopGroup())
        .channel(NioSocketChannel.class)
        .option(ChannelOption.ALLOCATOR, allocator)
        .handler(initializer);

// 连接服务器
ChannelFuture future = bootstrap.connect(new InetSocketAddress("localhost", 8080)).sync();

// 发送数据
String message = "Hello, world!";
byte[] messageBytes = message.getBytes(StandardCharsets.UTF_8);
ByteBuf data = allocator.buffer(messageBytes.length).writeBytes(messageBytes);
future.channel().writeAndFlush(data);

// 关闭连接
future.channel().closeFuture().sync();

在上面的代码中，创建了一个LengthFieldPrepender并加入到ChannelPipeline中，之后发送数据时，会先调用LengthFieldPrepender对数据进行编码，然后再将编码后的数据发送出去。接收方在接收到数据时，会先解析出数据的长度，再根据长度解析出实际的数据内容。