服务端调用session.channel().writeAndFlush()方法，客户端怎么才能取到数据

客户端可以通过实现Netty中的ChannelHandler来处理服务端发送的数据。具体来说，你可以实现ChannelInboundHandlerAdapter类，并覆盖channelRead方法来处理服务端发送的数据。在这个方法中，你可以使用ByteBuf类来解码服务端发送的数据。

下面是一个简单的示例代码：

public class MyClientHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        ByteBuf buf = (ByteBuf) msg;
        String data = buf.toString(CharsetUtil.UTF_8);
        // 处理接收到的数据
        System.out.println("Client received data: " + data);
        buf.release();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        // 发生异常时的处理逻辑
        cause.printStackTrace();
        ctx.close();
    }
}

在这个示例中，我们通过覆盖channelRead方法来处理服务端发送的数据。当有数据到达时，Netty会自动调用这个方法并将接收到的数据作为参数传入。在这个方法中，我们首先将接收到的数据转换成字符串，然后进行进一步的处理。注意，我们在处理完数据后需要调用ByteBuf的release方法来释放内存。

接下来，你需要将MyClientHandler添加到客户端的ChannelPipeline中，以便在客户端接收到数据时被调用。你可以通过以下代码来实现：

Bootstrap b = new Bootstrap();
b.group(group)
 .channel(NioSocketChannel.class)
 .handler(new ChannelInitializer<SocketChannel>() {
     @Override
     public void initChannel(SocketChannel ch) throws Exception {
         ch.pipeline().addLast(new MyClientHandler());
     }
 });
ChannelFuture f = b.connect("localhost", port).sync();

在这个示例中，我们首先创建了一个Bootstrap实例，并指定了事件循环组和通道类型。然后，我们创建了一个ChannelInitializer实例，并在其中添加了MyClientHandler到客户端的ChannelPipeline中。最后，我们通过调用connect方法来连接服务端。当连接成功后，Netty会自动调用MyClientHandler的channelActive方法。