Netty序列化數(shù)據(jù)

JDK 序列化

如果程序與端對端間的交互是使用 ObjectOutputStream 和 ObjectInputStream，并且主要面臨的問題是兼容性，那么， JDK 序列化 是不錯的選擇。

表8.8列出了序列化類，Netty 提供了與 JDK 的互操作。

Table 8.8 JDK Serialization codecs

JBoss Marshalling 序列化

如果可以使用外部依賴 JBoss Marshalling 是個明智的選擇。比 JDK 序列化快3倍且更加簡練。

JBoss Marshalling 是另一個序列化 API,修復(fù)的許多 JDK序列化 API 中發(fā)現(xiàn)的問題,它與 java.io.Serializable 完全兼容。并添加了一些新的可調(diào)參數(shù)和附加功能,所有這些都可插入通過工廠配置外部化,類/實例查找表,類決議,對象替換,等等)

下表展示了 Netty 支持 JBoss Marshalling 的編解碼器。

Table 8.9 JBoss Marshalling codecs

MarshallingEncoder MarshallingEncoder | 使用自定義序列化用于編碼，必須使用 MarshallingDecoder

下面展示了使用 MarshallingDecoder 和 MarshallingEncoder

Listing 8.13 Using JBoss Marshalling

public class MarshallingInitializer extends ChannelInitializer<Channel> {

    private final MarshallerProvider marshallerProvider;
    private final UnmarshallerProvider unmarshallerProvider;

    public MarshallingInitializer(UnmarshallerProvider unmarshallerProvider,
                                  MarshallerProvider marshallerProvider) {
        this.marshallerProvider = marshallerProvider;
        this.unmarshallerProvider = unmarshallerProvider;
    }
    @Override
    protected void initChannel(Channel channel) throws Exception {
        ChannelPipeline pipeline = channel.pipeline();
        pipeline.addLast(new MarshallingDecoder(unmarshallerProvider));
        pipeline.addLast(new MarshallingEncoder(marshallerProvider));
        pipeline.addLast(new ObjectHandler());
    }

    public static final class ObjectHandler extends SimpleChannelInboundHandler<Serializable> {
        @Override
        public void channelRead0(ChannelHandlerContext channelHandlerContext, Serializable serializable) throws Exception {
            // Do something
        }
    }
}

ProtoBuf 序列化

ProtoBuf 來自谷歌，并且開源了。它使編解碼數(shù)據(jù)更加緊湊和高效。它已經(jīng)綁定各種編程語言,使它適合跨語言項目。

下表展示了 Netty 支持 ProtoBuf 的 ChannelHandler 實現(xiàn)。

Table 8.10 ProtoBuf codec

用法見下面

Listing 8.14 Using Google Protobuf

public class ProtoBufInitializer extends ChannelInitializer<Channel> {

    private final MessageLite lite;

    public ProtoBufInitializer(MessageLite lite) {
        this.lite = lite;
    }

    @Override
    protected void initChannel(Channel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();
        pipeline.addLast(new ProtobufVarint32FrameDecoder());
        pipeline.addLast(new ProtobufEncoder());
        pipeline.addLast(new ProtobufDecoder(lite));
        pipeline.addLast(new ObjectHandler());
    }

    public static final class ObjectHandler extends SimpleChannelInboundHandler<Object> {
        @Override
        public void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
            // Do something with the object
        }
    }
}

1. 添加 ProtobufVarint32FrameDecoder 用來分割幀
2. 添加 ProtobufEncoder 用來處理消息的編碼
3. 添加 ProtobufDecoder 用來處理消息的解碼
4. 添加 ObjectHandler 用來處理解碼了的消息

本章在這最后一節(jié)中,我們探討了 Netty 支持的不同的序列化的專門的解碼器和編碼器。這些是標準 JDK 序列化 API,JBoss Marshalling 和谷歌ProtoBuf。