客户端相关的数据读写逻辑是通过 Bootstrap 的 handler() 方法指定
.handler(new ChannelInitializer
下面看下FirstClientHandler的实现
public class FirstClientHandler extends ChannelInboundHandlerAdapter {// channelActive()方法会在客户端连接建立成功之后被调用 @Override public void channelActive(ChannelHandlerContext ctx) { System.out.println(new Date() + ": 客户端写出数据");// 写数据的逻辑分为两步： // 1、获取数据 ByteBuf buffer = getByteBuf(ctx); // 2、写数据 ctx.channel().writeAndFlush(buffer); } private ByteBuf getByteBuf(ChannelHandlerContext ctx) { // 1、获取二进制抽象 ByteBuf ByteBuf buffer = ctx.alloc().buffer(); // 2、准备数据，指定字符串的字符集为 utf-8 byte[] bytes = "hello word".getBytes(Charset.forName("utf-8")); // 3、填充数据到 ByteBuf buffer.writeBytes(bytes); return buffer; }}
内存管理器的作用就是分配一个 ByteBuf，然后把字符串的二进制数据填充到 ByteBuf，这样就获取到了 Netty 需要的数据格式，最后调用 ctx.channel().writeAndFlush()把数据写到服务端
2 服务端读取客户端数据
服务端相关的数据处理逻辑是通过 ServerBootstrap 的 childHandler() 方法指定
.childHandler(new ChannelInitializer
下面看下FirstClientHandler的实现
public class FirstServerHandler extends ChannelInboundHandlerAdapter {// 方法在接收到客户端发来的数据之后被回调 @Override public void channelRead(ChannelHandlerContext ctx , Object msg // msg 参数指的就是 Netty 里面数据读写的载体 ) { ByteBuf byteBuf = (ByteBuf) msg; System.out.println(new Date() + ": 服务端读到数据 -> " + byteBuf.toString(Charset.forName("utf-8"))); }}
先运行服务端，再运行客户端，便可以接收到消息。
3 服务端返回数据给客户端
服务端向客户端写数据逻辑与客户端侧的写数据逻辑一样：
先创建一个 ByteBuf然后填充二进制数据最后调用 writeAndFlush() 方法写出去代码如下：
public class FirstServerHandler extends ChannelInboundHandlerAdapter { @Override public void channelRead(ChannelHandlerContext ctx, Object msg) { // ..、收数据逻辑省略 // 回复数据到客户端 System.out.println(new Date() + ": 服务端写出数据"); ByteBuf out = getByteBuf(ctx); ctx.channel().writeAndFlush(out); } private ByteBuf getByteBuf(ChannelHandlerContext ctx) { byte[] bytes = "你好，欢迎关注我的微信公众号，《闪电侠的博客》!".getBytes(Charset.forName("utf-8")); ByteBuf buffer = ctx.alloc().buffer(); buffer.writeBytes(bytes); return buffer; }}
此时需要客户端读取数据了，客户端的逻辑和服务端读取数据的逻辑一样，同样是覆盖 ChannelRead() 方法
public class FirstClientHandler extends ChannelInboundHandlerAdapter { // 写数据相关的逻辑省略 @Override public void channelRead(ChannelHandlerContext ctx, Object msg) { ByteBuf byteBuf = (ByteBuf) msg; System.out.println(new Date() + ": 客户端读到数据 -> " + byteBuf.toString(Charset.forName("utf-8"))); }}
4 小结 客户端和服务端的逻辑处理是均是在启动的时候给逻辑处理链 pipeline 添加逻辑处理器，来编写数据的读写逻辑；客户端连接成功之后会回调到逻辑处器的 channelActive() 方法，而不管是服务端还是客户端，收到数据之后都会调用到 channelRead 方法；写数据调用writeAndFlush()方法，客户端与服务端交互的二进制数据载体为 ByteBuf ByteBuf 通过连接的内存管理器创建字节数据填充到 ByteBuf 之后才能写到对端；