dubbo源碼分析25 -- 序列化與反序列化

序列化:把對象轉換為字節(jié)序列的過程稱為對象的序列化。
反序列化:把字節(jié)序列恢復為對象的過程稱為對象的反序列化。

Dubbo是 Alibaba 開源的分布式服務框架遠程調用框架,現(xiàn)在已捐贈給 apache 軟件基本會。因此 dubbo 調用是需要跨 JVM,需要進行網(wǎng)絡通信。這就需要使用到序列化與反序列化。在 dubbo 中定義了 ObjectInput、ObjectOutput 與 Serialization 來進行數(shù)據(jù)的序列化與反序列化。

1、Serialization 定義

下面我們來看一下 Serialization 的接口定義:

@SPI("hessian2")
public interface Serialization {

    byte getContentTypeId();

    String getContentType();

    @Adaptive
    ObjectOutput serialize(URL url, OutputStream output) throws IOException;

    @Adaptive
    ObjectInput deserialize(URL url, InputStream input) throws IOException;

}

這個接口里面定義了 4 個方法:

  • getContentTypeId:獲取序列化 ContextType 的 id。
  • getContentType:獲取到序列化的 ContentType。
  • serialize:創(chuàng)建一個 ObjectOutput (序列化器),用于把對象轉換序列化字節(jié)序列.
  • deserialize:創(chuàng)建一個 ObjectInput (反序列化器),用于把字節(jié)序列恢復成對象.

2、支持多種序列化

下面是 Serialization 的類圖:

Serialization.jpg

dubbo 支持多種序列化方式并且序列化是和協(xié)議相對應的。比如:dubbo協(xié)議的 dubbo, hessian2,java,compactedjava,rmi協(xié)議缺省為java,以及http協(xié)議的json等。

  • dubbo序列化:阿里尚未開發(fā)成熟的高效java序列化實現(xiàn),阿里不建議在生產環(huán)境使用它
  • hessian2序列化:hessian是一種跨語言的高效二進制序列化方式。但這里實際不是原生的hessian2序列化,而是阿里修改過的hessian lite,它是dubbo RPC默認啟用的序列化方式
  • json序列化:目前有兩種實現(xiàn),一種是采用的阿里的fastjson庫,另一種是采用dubbo中自己實現(xiàn)的簡單json庫,但其實現(xiàn)都不是特別成熟,而且json這種文本序列化性能一般不如上面兩種二進制序列化。
  • java序列化:主要是采用JDK自帶的Java序列化實現(xiàn),性能很不理想。

這四種主要序列化方式的性能從上到下依次遞減。對于dubbo RPC這種追求高性能的遠程調用方式來說,實際上只有1、2兩種高效序列化方式比較般配,而第1個 dubbo 序列化由于還不成熟,所以實際只剩下2可用,所以dubbo RPC默認采用 hessian2 序列化。

但 hessian 是一個比較老的序列化實現(xiàn)了,而且它是跨語言的,所以不是單獨針對java進行優(yōu)化的。而dubbo RPC實際上完全是一種Java to Java的遠程調用,其實沒有必要采用跨語言的序列化方式(當然肯定也不排斥跨語言的序列化)。

最近幾年,各種新的高效序列化方式層出不窮,不斷刷新序列化性能的上限,最典型的包括:

  • 專門針對Java語言的:Kryo,F(xiàn)ST等等
  • 跨語言的:Protostuff,ProtoBuf,Thrift,Avro,MsgPack等等

這些序列化方式的性能多數(shù)都顯著優(yōu)于 hessian2 (甚至包括尚未成熟的dubbo序列化)。所以我們可以
為 dubbo 引入 Kryo 和 FST 這兩種高效 Java 來優(yōu)化 dubbo 的序列化。

使用Kryo和FST非常簡單,只需要在dubbo RPC的XML配置中添加一個屬性即可:

<dubbo:protocol name="dubbo" serialization="kryo"/>

或者

<dubbo:protocol name="dubbo" serialization="fst"/>

3、序列化擴展

可以通過擴展 Serialization、ObjectInput、ObjectOutput 來進行 dubbo 序列化的擴展。

擴展示例

Maven 項目結構:

src
 |-main
    |-java
        |-com
            |-xxx
                |-XxxSerialization.java (實現(xiàn)Serialization接口)
                |-XxxObjectInput.java (實現(xiàn)ObjectInput接口)
                |-XxxObjectOutput.java (實現(xiàn)ObjectOutput接口)
    |-resources
        |-META-INF
            |-dubbo
                |-com.alibaba.dubbo.common.serialize.Serialization (純文本文件,內容為:xxx=com.xxx.XxxSerialization)

XxxSerialization.java:

package com.xxx;

import com.alibaba.dubbo.common.serialize.Serialization;
import com.alibaba.dubbo.common.serialize.ObjectInput;
import com.alibaba.dubbo.common.serialize.ObjectOutput;


public class XxxSerialization implements Serialization {
    public ObjectOutput serialize(Parameters parameters, OutputStream output) throws IOException {
        return new XxxObjectOutput(output);
    }
    public ObjectInput deserialize(Parameters parameters, InputStream input) throws IOException {
        return new XxxObjectInput(input);
    }
}

META-INF/dubbo/com.alibaba.dubbo.common.serialize.Serialization:

xxx=com.xxx.XxxSerialization

并且通過以下配置來使用新的擴展。

<!-- 協(xié)議的序列化方式 -->
<dubbo:protocol serialization="xxx" />
<!-- 缺省值設置,當<dubbo:protocol>沒有配置serialization時,使用此配置 -->
<dubbo:provider serialization="xxx" />

參考資料:

?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成,瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明:文章內容(如有圖片或視頻亦包括在內)由作者上傳并發(fā)布,文章內容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關閱讀更多精彩內容

  • 0 準備 安裝注冊中心:Zookeeper、Dubbox自帶的dubbo-registry-simple;安裝Du...
    七寸知架構閱讀 14,114評論 0 88
  • github項目地址https://github.com/SuperMan42/dubbox-ssm 簡介 SOA...
    hpw123閱讀 2,767評論 0 10
  • 1. 前言 隨著現(xiàn)在互聯(lián)網(wǎng)行業(yè)的發(fā)展,越來越多的框架、中間件、容器等開源技術不斷地涌現(xiàn),更好地來服務于業(yè)務,實現(xiàn)業(yè)...
    七寸知架構閱讀 10,179評論 11 86
  • 1、不是怕,是我們不具備抗衡的能力 大家印象中,外交部發(fā)言人一般用語是強烈譴責、嚴重抗議。。。 簡單來說就是,別人...
    An_An閱讀 2,330評論 0 0
  • 別 擔 心 文/中流擊水 心上 不長皺紋 臉龐 更年輕 黑夜 沒有燈 眼里有目標 照樣前行 書海 浩瀚無垠 勤奮 ...
    楚山漢水閱讀 276評論 0 5

友情鏈接更多精彩內容