簡(jiǎn)易R(shí)PC框架：序列化機(jī)制

walterrwu 發(fā)布于2019-08-16 13:39 / 3153人閱讀

摘要：由于我們還未談到具體的調(diào)用機(jī)制，因此暫且認(rèn)為就是把一個(gè)包含了調(diào)用信息的對(duì)象，從經(jīng)過(guò)序列化，變成一串二進(jìn)制流，發(fā)送到了端。

概述

在上一篇文章《簡(jiǎn)易R(shí)PC框架：基于 netty 的協(xié)議編解碼》中談到對(duì)于協(xié)議的 decode 和 encode，在談 decode 之前，必須先要知道 encode 的過(guò)程是什么，它把什么東西轉(zhuǎn)化成了二進(jìn)制協(xié)議。
由于我們還未談到具體的 RPC 調(diào)用機(jī)制，因此暫且認(rèn)為 encode 就是把一個(gè)包含了調(diào)用信息的 Java 對(duì)象，從 client 經(jīng)過(guò)序列化，變成一串二進(jìn)制流，發(fā)送到了 server 端。
這里需要明確的是，encode 的職責(zé)是拼協(xié)議，它不負(fù)責(zé)序列化，同樣，decode 只是把整個(gè)二進(jìn)制報(bào)文分割，哪部分是報(bào)文頭，哪部分是報(bào)文體，誠(chéng)然，報(bào)文體就是被序列化成二進(jìn)制流的一個(gè) Java 對(duì)象。
對(duì)于調(diào)用方來(lái)說(shuō)，先將調(diào)用信息封裝成一個(gè) Java 對(duì)象，經(jīng)過(guò)序列化后形成二進(jìn)制流，再經(jīng)過(guò) encode 階段，拼接成一個(gè)完整的遵守我們定好的協(xié)議的報(bào)文。
對(duì)于被調(diào)用方來(lái)說(shuō)，則是收取完整的報(bào)文，在 decode 階段將報(bào)文中的報(bào)文頭，報(bào)文體分割出來(lái)，在序列化階段將報(bào)文體反序列化為一個(gè) Java 對(duì)象，從而獲得調(diào)用信息。
本文探討序列化機(jī)制。

基于 netty handler

由于這個(gè) RPC 框架基于 netty 實(shí)現(xiàn)，因此序列化機(jī)制其實(shí)體現(xiàn)在了 netty 的 pipeline 上的 handler 上。
例如對(duì)于調(diào)用方，它需要在 pipeline 上加上一個(gè) 序列化 encode handler，用來(lái)序列化發(fā)出去的請(qǐng)求，同時(shí)需要加上一個(gè)反序列化的 decode handler, 以便反序列化調(diào)用結(jié)果。如下所示：

                    protected void initChannel(SocketChannel ch) throws Exception {
                        ChannelPipeline pipeline = ch.pipeline();
                        pipeline.addLast(new ProtocolEncoder())
                                .addLast(new ProtocolDecoder())
                                .addLast(new SerializationHandler(serialization))
                                .addLast(new DeserializationHandler(serialization));

                    }

其中的 SerializationHandler 和 DeserializationHandler 就是上文提到的序列化 encode handler 和反序列化 decode handler。
同樣，對(duì)于被調(diào)用方來(lái)說(shuō)，它也需要這兩個(gè)handler，與調(diào)用方的 handler 編排順序一致。

其中，serialization 這個(gè)參數(shù)的對(duì)象代表具體的序列化機(jī)制策略。

序列化機(jī)制

上文中，SerializationHandler 和 DeserializationHandler 這兩個(gè)對(duì)象都需要一個(gè) serialization 對(duì)象作為參數(shù)，它是這么定義的：

private ISerialization serialization = SerializationFactory.getSerialization(ServerDefaults.DEFAULT_SERIALIZATION_TYPE);

采用工廠模式來(lái)創(chuàng)建具體的序列化機(jī)制：

/**
 * 序列化工廠
 *
 * @author beanlam
 * @version 1.0
 */
public class SerializationFactory {

    private SerializationFactory() {
    }

    public static ISerialization getSerialization(SerializationType type) {
        if (type == SerializationType.JDK) {
            return new JdkSerialization();
        }
        return new HessianSerialization();
    }
}

這里暫時(shí)只支持 JDK 原生序列化和基于 Hessian 的序列化機(jī)制，日后若有其他效率更高更適合的序列化機(jī)制，則可以在工廠類中進(jìn)行添加。

這里的 hessian 序列化是從 dubbo 中剝離出來(lái)的一塊代碼，感興趣可以從 dubbo 的源碼中的 com.caucho.hessian 包中獲得。

以 HessianSerialization 為例：

/**
 * @author beanlam
 * @version 1.0
 */
public class HessianSerialization implements ISerialization {

    private ISerializer serializer = new HessianSerializer();
    private IDeserializer deserializer = new HessianDeserializer();

    @Override
    public ISerializer getSerializer() {
        return serializer;
    }

    @Override
    public IDeserializer getDeserializer() {
        return deserializer;
    }

    @Override
    public boolean accept(Class clazz) {
        return Serializable.class.isAssignableFrom(clazz);
    }
}

根據(jù) Hessian 的 API，分別返回一個(gè) hessian 的序列化器和反序列化器即可。