Thrift之Protocol源碼分析
來源:易賢網(wǎng) 閱讀:2180 次 日期:2015-04-09 15:56:14
溫馨提示:易賢網(wǎng)小編為您整理了“Thrift之Protocol源碼分析”,方便廣大網(wǎng)友查閱!

之前寫過兩篇關(guān)于 Thrift 的相關(guān)文章。

Thrift源碼剖析

Thrift異步IO服務(wù)器源碼分析

也算是對Thrift比較熟悉,不過對 Thrift 里面的 Protocol 部分還是黑盒使用。 雖然大概能猜到具體實現(xiàn)方式,但是還是忍不住花了一點點時間把具體代碼實現(xiàn)翻出來看看。 主要是為了滿足一下好奇心。

簡單搞了一個Thrift的描述文件Insight.thrift作為例子。

struct Person {

1: string name,

2: i32 age,

3: optional string address,

}

service Insight {

Person Hello(1: Person person),

Person Hi(1: Person p1, 2: Person p2),

}

然后通過 畢竟Thrift其實就是干RPC的活,所以看源碼就按著RPC遠程調(diào)用的順序來看就行。

從Hello函數(shù)調(diào)用開始,InsightClient::Hello 可以看出, 在每次RPC調(diào)用的時候,會先將函數(shù)名通過writeMessageBegin("Hello", ::apache::thrift::protocol::T_CALL, cseqid) 先發(fā)送過去。 這個過程的序列化協(xié)議很簡單,直接就是傳輸?shù)暮瘮?shù)名字符串。 然后再發(fā)送參數(shù)。 發(fā)送參數(shù)的時候,會將所有參數(shù)作為一個 struct 發(fā)送 InsightHellopargs,

所以協(xié)議的序列化過程主要都是體現(xiàn)在 struct 的序列化上面。 比如像Hi函數(shù)的參數(shù)序列化過程:

uint32_t Insight_Hi_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {

uint32_t xfer = 0;

xfer += oprot->writeStructBegin("Insight_Hi_pargs");

xfer += oprot->writeFieldBegin("p1", ::apache::thrift::protocol::T_STRUCT, 1);

xfer += (*(this->p1)).write(oprot);

xfer += oprot->writeFieldEnd();

xfer += oprot->writeFieldBegin("p2", ::apache::thrift::protocol::T_STRUCT, 2);

xfer += (*(this->p2)).write(oprot);

xfer += oprot->writeFieldEnd();

xfer += oprot->writeFieldStop();

xfer += oprot->writeStructEnd();

return xfer;

}

整個對象的序列化過程主要是依賴了接口 TProtocol 的函數(shù)。

對于實現(xiàn) TProtocol 接口的序列化實現(xiàn)主要是以下三種(在thrift-0.9.0/lib/cpp/src/thrift/protocol里):

TBinaryProtocol

TCompactProtocol

TJSONProtocol

要了解協(xié)議序列化過程主要看一下 TBinaryProtocol 和 TCompactProtocol 就夠了。

主要是如下幾個關(guān)鍵點:

其實 writeStructStruct 和 writeStructEnd 啥屁事也不用做。

其實 writeFieldBegin 只有后兩個參數(shù)有用,第二個參數(shù)是類型,第三個參數(shù)是ID, 因為光靠這兩者就可以在反序列化(讀取解析)的時候知道是哪個成員了。

struct write 的過程其實是個遞歸的過程,也就是在write函數(shù)中, 會遞歸的調(diào)用結(jié)構(gòu)體本身每個成員的write函數(shù)。

TCompactProtocol 和 TBinaryProtocol 的區(qū)別主要是, TCompactProtocol 對整數(shù)類型使用了 ZigZag 壓縮算法,比如 i32 類型的整數(shù)本來是4個字節(jié), 可以壓縮成 1~5 字節(jié)不等。而 i64類型的整數(shù)本來是8個字節(jié)??梢詨嚎s成 1~10 字節(jié)不等。

更多信息請查看IT技術(shù)專欄

更多信息請查看技術(shù)文章
易賢網(wǎng)手機網(wǎng)站地址:Thrift之Protocol源碼分析
由于各方面情況的不斷調(diào)整與變化,易賢網(wǎng)提供的所有考試信息和咨詢回復(fù)僅供參考,敬請考生以權(quán)威部門公布的正式信息和咨詢?yōu)闇?zhǔn)!

2025國考·省考課程試聽報名

  • 報班類型
  • 姓名
  • 手機號
  • 驗證碼
關(guān)于我們 | 聯(lián)系我們 | 人才招聘 | 網(wǎng)站聲明 | 網(wǎng)站幫助 | 非正式的簡要咨詢 | 簡要咨詢須知 | 加入群交流 | 手機站點 | 投訴建議
工業(yè)和信息化部備案號:滇ICP備2023014141號-1 云南省教育廳備案號:云教ICP備0901021 滇公網(wǎng)安備53010202001879號 人力資源服務(wù)許可證:(云)人服證字(2023)第0102001523號
云南網(wǎng)警備案專用圖標(biāo)
聯(lián)系電話:0871-65099533/13759567129 獲取招聘考試信息及咨詢關(guān)注公眾號:hfpxwx
咨詢QQ:526150442(9:00—18:00)版權(quán)所有:易賢網(wǎng)
云南網(wǎng)警報警專用圖標(biāo)