外行人也能看懂的Netty开发教程(1)-第一次接触

package io.netty.example.discard; import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; /**
 * 处理服务端的channel.
 *
 * DiscardServerHandler继承ChannelInboundHandlerAdapter(ChannelInboundHandler的实现)
 * ChannelInboundHandler提供了可重写的各种事件处理器方法
 * 现在，仅扩展ChannelInboundHandlerAdapter即可，而不是自己实现处理器接口
 */ public class DiscardServerHandler extends ChannelInboundHandlerAdapter { /**
     * 当有事件发生时，会调用
     * 这里重写channelRead事件处理器方法。每当从客户端接收到新数据时，就使用接收到的消息来调用此方法
     * 此示例中，接收到的消息的类型为ByteBuf
     */ @Override public void channelRead(ChannelHandlerContext ctx, Object msg) { /**
         * ByteBuf是个引用计数对象，必须通过release显式释放。
         * 释放传递给处理程序的引用计数对象都是处理程序的责任！！！
         *
         * 一般channelRead处理器方法的实现如下：
         * @Override
         * public void channelRead(ChannelHandlerContext ctx, Object msg) {
         *     try {
         *         // 处理 msg
         *     } finally {
         *         ReferenceCountUtil.release(msg);
         *     }
         * }
         */ ByteBuf byteBuf = (ByteBuf) msg; try { int count = byteBuf.readableBytes(); byte[] content = new byte[count]; byteBuf.readBytes(content); System.out.println(new String(content)); } finally { byteBuf.release(); } } /**
     * 当Netty由于I/O错误、处理器的实现类处理事件时抛异常
     * 将使用Throwable调用exceptionCaught事件处理器方法
     * 在大多数情况下，应该记录捕获的异常并在此处关闭其关联的通道，尽管此方法的实现可能会有所不同，具体取决于您要处理特殊情况时要采取的措施
     * 例如，您可能想在关闭连接之前发送带有错误代码的响应消息。
     */ @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { // 引发异常时关闭连接 cause.printStackTrace(); ctx.close(); } }