~~~ @ChannelHandler.Sharable public class EchoClientHandler extends SimpleChannelInboundHandler<ByteBuf> { @Override public void channelActive(ChannelHandlerContext ctx) throws Exception { // 當被通知Channel是活躍的時候，發送一條消息 ctx.writeAndFlush(Unpooled.copiedBuffer("Netty socks", CharsetUtil.UTF_8)); } /** * 1. 每次接收數據，都會調用這個方法 * 2. 服務器發送的數據可能被分塊接收，意味著這個方法會被調用多次 */ protected void channelRead0(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf) throws Exception { // 接收消息 System.out.println("Client : "+ byteBuf.toString(CharsetUtil.UTF_8)); } @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { // 異常，記錄錯誤，并關閉Channel cause.printStackTrace(); ctx.close(); } } ~~~