---

Netty是一个高性能的网络编程框架，它提供了丰富的编解码器（Codec）来简化网络数据的处理。在Netty中，MessageToMessageCodec类是一个关键的编解码器组件，它同时实现了消息的编码和解码功能。本文将结合Netty的源码，详细分析MessageToMessageCodec类的工作原理、实现细节以及使用场景。

一、MessageToMessageCodec类概述

MessageToMessageCodec是Netty提供的一个抽象类，它同时继承了ChannelInboundHandlerAdapter和ChannelOutboundHandlerAdapter，因此它既可以处理入站消息（解码），也可以处理出站消息（编码）。这个类的主要作用是将业务消息对象与字节流或其他形式的消息进行相互转换，以便在网络中传输。

二、源码解析

首先，我们来看一下MessageToMessageCodec的核心源码结构。

public abstract class MessageToMessageCodec<INBOUND_IN, OUTBOUND_IN> 
    extends ChannelDuplexHandler {

    // 解码方法，需要子类实现
    protected abstract void decode(ChannelHandlerContext ctx, INBOUND_IN msg, List<Object> out) throws Exception;

    // 编码方法，需要子类实现
    protected abstract void encode(ChannelHandlerContext ctx, OUTBOUND_IN msg, List<Object> out) throws Exception;

    // 处理入站消息
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        List<Object> out = decode(ctx, (INBOUND_IN) msg, null);
        if (out != null) {
            for (Object o : out) {
                ctx.fireChannelRead(o);
            }
        } else {
            // 如果没有解码出消息，则释放原始消息
            ReferenceCountUtil.release(msg);
        }
    }

    // 处理出站消息
    @Override
    public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
        List<Object> encoded = encode(ctx, (OUTBOUND_IN) msg, promise.task());
        if (encoded == null || encoded.isEmpty()) {
            // 如果没有编码后的消息，则释放原始消息并设置promise成功
            ReferenceCountUtil.release(msg);
            promise.setSuccess();
        } else {
            // 如果有编码后的消息，则逐个写入
            for (Object e : encoded) {
                ctx.write(e, promise);
            }
        }
    }

    // ... 其他方法和字段
}

从源码中可以看出，MessageToMessageCodec类有两个关键的抽象方法：decode和encode。子类需要实现这两个方法来完成消息的解码和编码逻辑。

• decode方法用于将入站消息（通常是字节流）解码为业务消息对象，并将解码后的消息传递给下一个ChannelInboundHandler进行处理。
• encode方法用于将业务消息对象编码为出站消息（通常是字节流），以便发送到网络中。

三、工作原理

1. 解码过程：

   • 当有入站消息到达时，Netty会调用MessageToMessageCodec的channelRead方法。
   • channelRead方法内部会调用子类实现的decode方法进行解码。
   • 解码过程中，decode方法会根据具体的协议逻辑将入站消息（通常是字节流）解码为业务消息对象，并将解码后的消息添加到传入的List<Object>中。
   • 解码完成后，解码后的消息会被逐个传递给下一个ChannelInboundHandler进行处理。

2. 编码过程：

   • 当有出站消息需要发送时，Netty会调用MessageToMessageCodec的write方法。
   • write方法内部会调用子类实现的encode方法进行编码。
   • 编码过程中，encode方法会根据具体的协议逻辑将业务消息对象编码为出站消息（通常是字节流），并将编码后的消息添加到传入的List<Object>中。
   • 编码完成后，编码后的消息会被逐个写入到网络中。

四、使用场景

MessageToMessageCodec适用于需要同时处理消息的编码和解码的场景。例如，在处理自定义协议时，可以使用MessageToMessageCodec将接收到的字节流解码为业务消息对象，并将业务消息对象编码为字节流发送到网络中。

五、注意事项

1. 线程安全：MessageToMessageCodec本身不是线程安全的。如果你的编解码逻辑涉及到共享资源的访问或修改，需要确保这些操作是线程安全的。
2. 性能考虑：在编解码过程中，MessageToMessageCodec可能会创建新的消息对象，这可能会带来一定的内存开销。因此，在使用MessageToMessageCodec时，需要权衡其带来的便利和可能的性能开销。
3. 异常处理：在编解码过程中，如果发生异常，需要妥善处理，例如记录日志、关闭连接等。

六、结语

MessageToMessageCodec是Netty中用于处理消息编解码过程的重要工具。通过提供一个抽象的编解码框架，它使得开发者可以更容易地编写基于消息的协议编解码逻辑。希望本文能够帮助开发者更好地理解MessageToMessageCodec类的工作原理和使用方法，并在实际开发中充分利用其提供的便利。

---

关注公众号[码到三十五]获取更多技术干货 !