• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            感覺Google Protocol Buffer無論對存儲還是數(shù)據(jù)交換,都是個挺有用的東西,這里記錄下,以后應(yīng)該用得著。
            下文轉(zhuǎn)自: 
            http://www.ibm.com/developerworks/cn/linux/l-cn-gpb/index.html



            簡介

             

            什么是 Google Protocol Buffer? 假如您在網(wǎng)上搜索,應(yīng)該會得到類似這樣的文字介紹:

            Google Protocol Buffer( 簡稱 Protobuf) 是 Google 公司內(nèi)部的混合語言數(shù)據(jù)標(biāo)準(zhǔn),目前已經(jīng)正在使用的有超過 48,162 種報文格式定義和超過 12,183 個 .proto 文件。他們用于 RPC 系統(tǒng)和持續(xù)數(shù)據(jù)存儲系統(tǒng)。

            Protocol Buffers 是一種輕便高效的結(jié)構(gòu)化數(shù)據(jù)存儲格式,可以用于結(jié)構(gòu)化數(shù)據(jù)串行化,或者說序列化。它很適合做數(shù)據(jù)存儲或 RPC 數(shù)據(jù)交換格式??捎糜谕ㄓ崊f(xié)議、數(shù)據(jù)存儲等領(lǐng)域的語言無關(guān)、平臺無關(guān)、可擴展的序列化結(jié)構(gòu)數(shù)據(jù)格式。目前提供了 C++、Java、Python 三種語言的 API。

            或許您和我一樣,在第一次看完這些介紹后還是不明白 Protobuf 究竟是什么,那么我想一個簡單的例子應(yīng)該比較有助于理解它。

            回頁首

            一個簡單的例子

            安裝 Google Protocol Buffer

            在網(wǎng)站 http://code.google.com/p/protobuf/downloads/list上可以下載 Protobuf 的源代碼。然后解壓編譯安裝便可以使用它了。

            安裝步驟如下所示:

             tar -xzf protobuf-2.1.0.tar.gz 
             cd protobuf-2.1.0 
             ./configure --prefix=$INSTALL_DIR 
             make 
             make check 
             make install 

             

              關(guān)于簡單例子的描述

             

            我打算使用 Protobuf 和 C++ 開發(fā)一個十分簡單的例子程序。

            該程序由兩部分組成。第一部分被稱為 Writer,第二部分叫做 Reader。

            Writer 負(fù)責(zé)將一些結(jié)構(gòu)化的數(shù)據(jù)寫入一個磁盤文件,Reader 則負(fù)責(zé)從該磁盤文件中讀取結(jié)構(gòu)化數(shù)據(jù)并打印到屏幕上。

            準(zhǔn)備用于演示的結(jié)構(gòu)化數(shù)據(jù)是 HelloWorld,它包含兩個基本數(shù)據(jù):

            • ID,為一個整數(shù)類型的數(shù)據(jù)
            • Str,這是一個字符串

            書寫 .proto 文件

            首先我們需要編寫一個 proto 文件,定義我們程序中需要處理的結(jié)構(gòu)化數(shù)據(jù),在 protobuf 的術(shù)語中,結(jié)構(gòu)化數(shù)據(jù)被稱為 Message。proto 文件非常類似 java 或者 C 語言的數(shù)據(jù)定義。代碼清單 1 顯示了例子應(yīng)用中的 proto 文件內(nèi)容。


            清單 1. proto 文件

             package lm; 
             message helloworld 
             { 
                required int32     id = 1;  // ID 
                required string    str = 2;  // str 
                optional int32     opt = 3;  //optional field 
             } 

            一個比較好的習(xí)慣是認(rèn)真對待 proto 文件的文件名。比如將命名規(guī)則定于如下:
            packageName.MessageName.proto 

            編譯 .proto 文件
            在上例中,package 名字叫做 lm,定義了一個消息 helloworld,該消息有三個成員,類型為 int32 的 id,另一個為類型為 string 的成員 str。opt 是一個可選的成員,即消息中可以不包含該成員。

             

            寫好 proto 文件之后就可以用 Protobuf 編譯器將該文件編譯成目標(biāo)語言了。本例中我們將使用 C++。

            假設(shè)您的 proto 文件存放在 $SRC_DIR 下面,您也想把生成的文件放在同一個目錄下,則可以使用如下命令:

            protoc -I=$SRC_DIR --cpp_out=$DST_DIR $SRC_DIR/addressbook.proto 

            命令將生成兩個文件:

            lm.helloworld.pb.h , 定義了 C++ 類的頭文件

            lm.helloworld.pb.cc , C++ 類的實現(xiàn)文件

            在生成的頭文件中,定義了一個 C++ 類 helloworld,后面的 Writer 和 Reader 將使用這個類來對消息進(jìn)行操作。諸如對消息的成員進(jìn)行賦值,將消息序列化等等都有相應(yīng)的方法。

            編寫 writer 和 Reader

            如前所述,Writer 將把一個結(jié)構(gòu)化數(shù)據(jù)寫入磁盤,以便其他人來讀取。假如我們不使用 Protobuf,其實也有許多的選擇。一個可能的方法是將數(shù)據(jù)轉(zhuǎn)換為字符串,然后將字符串寫入磁盤。轉(zhuǎn)換為字符串的方法可以使用 sprintf(),這非常簡單。數(shù)字 123 可以變成字符串”123”。

            這樣做似乎沒有什么不妥,但是仔細(xì)考慮一下就會發(fā)現(xiàn),這樣的做法對寫 Reader 的那個人的要求比較高,Reader 的作者必須了 Writer 的細(xì)節(jié)。比如”123”可以是單個數(shù)字 123,但也可以是三個數(shù)字 1,2 和 3,等等。這么說來,我們還必須讓 Writer 定義一種分隔符一樣的字符,以便 Reader 可以正確讀取。但分隔符也許還會引起其他的什么問題。最后我們發(fā)現(xiàn)一個簡單的 Helloworld 也需要寫許多處理消息格式的代碼。

            如果使用 Protobuf,那么這些細(xì)節(jié)就可以不需要應(yīng)用程序來考慮了。

            使用 Protobuf,Writer 的工作很簡單,需要處理的結(jié)構(gòu)化數(shù)據(jù)由 .proto 文件描述,經(jīng)過上一節(jié)中的編譯過程后,該數(shù)據(jù)化結(jié)構(gòu)對應(yīng)了一個 C++ 的類,并定義在 lm.helloworld.pb.h 中。對于本例,類名為 lm::helloworld。

            Writer 需要 include 該頭文件,然后便可以使用這個類了。

            現(xiàn)在,在 Writer 代碼中,將要存入磁盤的結(jié)構(gòu)化數(shù)據(jù)由一個 lm::helloworld 類的對象表示,它提供了一系列的 get/set 函數(shù)用來修改和讀取結(jié)構(gòu)化數(shù)據(jù)中的數(shù)據(jù)成員,或者叫 field。

            當(dāng)我們需要將該結(jié)構(gòu)化數(shù)據(jù)保存到磁盤上時,類 lm::helloworld 已經(jīng)提供相應(yīng)的方法來把一個復(fù)雜的數(shù)據(jù)變成一個字節(jié)序列,我們可以將這個字節(jié)序列寫入磁盤。

            對于想要讀取這個數(shù)據(jù)的程序來說,也只需要使用類 lm::helloworld 的相應(yīng)反序列化方法來將這個字節(jié)序列重新轉(zhuǎn)換會結(jié)構(gòu)化數(shù)據(jù)。這同我們開始時那個“123”的想法類似,不過 Protobuf 想的遠(yuǎn)遠(yuǎn)比我們那個粗糙的字符串轉(zhuǎn)換要全面,因此,我們不如放心將這類事情交給 Protobuf 吧。

            程序清單 2 演示了 Writer 的主要代碼,您一定會覺得很簡單吧?


            清單 2. Writer 的主要代碼
             #include "lm.helloworld.pb.h"


             int main(void
             { 
              
              lm::helloworld msg1; 
              msg1.set_id(101); 
              msg1.set_str(“hello”); 
                
              // Write the new address book back to disk. 
              fstream output("./log", ios::out | ios::trunc | ios::binary); 
                    
              if (!msg1.SerializeToOstream(&output)) { 
                  cerr << "Failed to write msg." << endl; 
                  return -1; 
              }         
              return 0; 
             } 

            Msg1 是一個 helloworld 類的對象,set_id() 用來設(shè)置 id 的值。SerializeToOstream 將對象序列化后寫入一個 fstream 流。

            代碼清單 3 列出了 reader 的主要代碼。


            清單 3. Reader
            #include "lm.helloworld.pb.h" 

             void ListMsg(const lm::helloworld & msg) { 
              cout << msg.id() << endl; 
              cout << msg.str() << endl; 
             } 
             
             int main(int argc, char* argv[]) { 

              lm::helloworld msg1; 
             
              { 
                fstream input("./log", ios::in | ios::binary); 
                if (!msg1.ParseFromIstream(&input)) { 
                  cerr << "Failed to parse address book." << endl; 
                  return -1; 
                } 
              } 
             
              ListMsg(msg1); 
              … 
             } 

            同樣,Reader 聲明類 helloworld 的對象 msg1,然后利用 ParseFromIstream 從一個 fstream 流中讀取信息并反序列化。此后,ListMsg 中采用 get 方法讀取消息的內(nèi)部信息,并進(jìn)行打印輸出操作。

            運行結(jié)果

            運行 Writer 和 Reader 的結(jié)果如下:

             >writer 
             >reader 
             101 
             Hello 

            Reader 讀取文件 log 中的序列化信息并打印到屏幕上。本文中所有的例子代碼都可以在附件中下載。您可以親身體驗一下。

            這個例子本身并無意義,但只要您稍加修改就可以將它變成更加有用的程序。比如將磁盤替換為網(wǎng)絡(luò) socket,那么就可以實現(xiàn)基于網(wǎng)絡(luò)的數(shù)據(jù)交換任務(wù)。而存儲和交換正是 Protobuf 最有效的應(yīng)用領(lǐng)域。

            回頁首

            和其他類似技術(shù)的比較

            看完這個簡單的例子之后,希望您已經(jīng)能理解 Protobuf 能做什么了,那么您可能會說,世上還有很多其他的類似技術(shù)啊,比如 XML,JSON,Thrift 等等。和他們相比,Protobuf 有什么不同呢?

            簡單說來 Protobuf 的主要優(yōu)點就是:簡單,快。

            這有測試為證,項目 thrift-protobuf-compare 比較了這些類似的技術(shù),圖 1 顯示了該項目的一項測試結(jié)果,Total Time.


            圖 1. 性能測試結(jié)果
            圖 1. 性能測試結(jié)果 

            Total Time 指一個對象操作的整個時間,包括創(chuàng)建對象,將對象序列化為內(nèi)存中的字節(jié)序列,然后再反序列化的整個過程。從測試結(jié)果可以看到 Protobuf 的成績很好,感興趣的讀者可以自行到網(wǎng)站 http://code.google.com/p/thrift-protobuf-compare/wiki/Benchmarking上了解更詳細(xì)的測試結(jié)果。

            Protobuf 的優(yōu)點

            Protobuf 有如 XML,不過它更小、更快、也更簡單。你可以定義自己的數(shù)據(jù)結(jié)構(gòu),然后使用代碼生成器生成的代碼來讀寫這個數(shù)據(jù)結(jié)構(gòu)。你甚至可以在無需重新部署程序的情況下更新數(shù)據(jù)結(jié)構(gòu)。只需使用 Protobuf 對數(shù)據(jù)結(jié)構(gòu)進(jìn)行一次描述,即可利用各種不同語言或從各種不同數(shù)據(jù)流中對你的結(jié)構(gòu)化數(shù)據(jù)輕松讀寫。

            它有一個非常棒的特性,即“向后”兼容性好,人們不必破壞已部署的、依靠“老”數(shù)據(jù)格式的程序就可以對數(shù)據(jù)結(jié)構(gòu)進(jìn)行升級。這樣您的程序就可以不必?fù)?dān)心因為消息結(jié)構(gòu)的改變而造成的大規(guī)模的代碼重構(gòu)或者遷移的問題。因為添加新的消息中的 field 并不會引起已經(jīng)發(fā)布的程序的任何改變。

            Protobuf 語義更清晰,無需類似 XML 解析器的東西(因為 Protobuf 編譯器會將 .proto 文件編譯生成對應(yīng)的數(shù)據(jù)訪問類以對 Protobuf 數(shù)據(jù)進(jìn)行序列化、反序列化操作)。

            使用 Protobuf 無需學(xué)習(xí)復(fù)雜的文檔對象模型,Protobuf 的編程模式比較友好,簡單易學(xué),同時它擁有良好的文檔和示例,對于喜歡簡單事物的人們而言,Protobuf 比其他的技術(shù)更加有吸引力。

            Protobuf 的不足

            Protbuf 與 XML 相比也有不足之處。它功能簡單,無法用來表示復(fù)雜的概念。

            XML 已經(jīng)成為多種行業(yè)標(biāo)準(zhǔn)的編寫工具,Protobuf 只是 Google 公司內(nèi)部使用的工具,在通用性上還差很多。

            由于文本并不適合用來描述數(shù)據(jù)結(jié)構(gòu),所以 Protobuf 也不適合用來對基于文本的標(biāo)記文檔(如 HTML)建模。另外,由于 XML 具有某種程度上的自解釋性,它可以被人直接讀取編輯,在這一點上 Protobuf 不行,它以二進(jìn)制的方式存儲,除非你有 .proto 定義,否則你沒法直接讀出 Protobuf 的任何內(nèi)容【 2 】。

            回頁首

            高級應(yīng)用話題

            更復(fù)雜的 Message

            到這里為止,我們只給出了一個簡單的沒有任何用處的例子。在實際應(yīng)用中,人們往往需要定義更加復(fù)雜的 Message。我們用“復(fù)雜”這個詞,不僅僅是指從個數(shù)上說有更多的 fields 或者更多類型的 fields,而是指更加復(fù)雜的數(shù)據(jù)結(jié)構(gòu):

            嵌套 Message

            嵌套是一個神奇的概念,一旦擁有嵌套能力,消息的表達(dá)能力就會非常強大。

            代碼清單 4 給出一個嵌套 Message 的例子。


            清單 4. 嵌套 Message 的例子
             message Person { 
              required string name = 1; 
              required int32 id = 2;        // Unique ID number for this person. 
              optional string email = 3; 

              enum PhoneType { 
                MOBILE = 0; 
                HOME = 1; 
                WORK = 2; 
              } 

              message PhoneNumber { 
                required string number = 1; 
                optional PhoneType type = 2 [default = HOME]; 
              } 
              repeated PhoneNumber phone = 4; 
             } 

            在 Message Person 中,定義了嵌套消息 PhoneNumber,并用來定義 Person 消息中的 phone 域。這使得人們可以定義更加復(fù)雜的數(shù)據(jù)結(jié)構(gòu)。

            4.1.2 Import Message

            在一個 .proto 文件中,還可以用 Import 關(guān)鍵字引入在其他 .proto 文件中定義的消息,這可以稱做 Import Message,或者 Dependency Message。

            比如下例:


            清單 5. 代碼
             import common.header; 

             message youMsg{ 
              required common.info_header header = 1; 
              required string youPrivateData = 2; 
             } 

            其中 ,common.info_header定義在common.header包內(nèi)。

            Import Message 的用處主要在于提供了方便的代碼管理機制,類似 C 語言中的頭文件。您可以將一些公用的 Message 定義在一個 package 中,然后在別的 .proto 文件中引入該 package,進(jìn)而使用其中的消息定義。

            Google Protocol Buffer 可以很好地支持嵌套 Message 和引入 Message,從而讓定義復(fù)雜的數(shù)據(jù)結(jié)構(gòu)的工作變得非常輕松愉快。

            動態(tài)編譯

            一般情況下,使用 Protobuf 的人們都會先寫好 .proto 文件,再用 Protobuf 編譯器生成目標(biāo)語言所需要的源代碼文件。將這些生成的代碼和應(yīng)用程序一起編譯。

            可是在某且情況下,人們無法預(yù)先知道 .proto 文件,他們需要動態(tài)處理一些未知的 .proto 文件。比如一個通用的消息轉(zhuǎn)發(fā)中間件,它不可能預(yù)知需要處理怎樣的消息。這需要動態(tài)編譯 .proto 文件,并使用其中的 Message。

            Protobuf 提供了 google::protobuf::compiler 包來完成動態(tài)編譯的功能。主要的類叫做 importer,定義在 importer.h 中。使用 Importer 非常簡單,下圖展示了與 Import 和其它幾個重要的類的關(guān)系。


            圖 2. Importer 類
            圖 2. Importer 類 

            Import 類對象中包含三個主要的對象,分別為處理錯誤的 MultiFileErrorCollector 類,定義 .proto 文件源目錄的 SourceTree 類。

            下面還是通過實例說明這些類的關(guān)系和使用吧。

            對于給定的 proto 文件,比如 lm.helloworld.proto,在程序中動態(tài)編譯它只需要很少的一些代碼。如代碼清單 6 所示。


            清單 6. 代碼

             google::protobuf::compiler::MultiFileErrorCollector errorCollector;
             google::protobuf::compiler::DiskSourceTree sourceTree; 

             google::protobuf::compiler::Importer importer(&sourceTree, &errorCollector); 
             sourceTree.MapPath("", protosrc); 

             importer.import(“lm.helloworld.proto”); 
            首先構(gòu)造一個 importer 對象。構(gòu)造函數(shù)需要兩個入口參數(shù),一個是 source Tree 對象,該對象指定了存放 .proto 文件的源目錄。第二個參數(shù)是一個 error collector 對象,該對象有一個 AddError 方法,用來處理解析 .proto 文件時遇到的語法錯誤。

             

            之后,需要動態(tài)編譯一個 .proto 文件時,只需調(diào)用 importer 對象的 import 方法。非常簡單。

            那么我們?nèi)绾问褂脛討B(tài)編譯后的 Message 呢?我們需要首先了解幾個其他的類

            Package google::protobuf::compiler 中提供了以下幾個類,用來表示一個 .proto 文件中定義的 message,以及 Message 中的 field,如圖所示。


            圖 3. 各個 Compiler 類之間的關(guān)系
            圖 3. 各個 Compiler 類之間的關(guān)系 

            類 FileDescriptor 表示一個編譯后的 .proto 文件;類 Descriptor 對應(yīng)該文件中的一個 Message;類 FieldDescriptor 描述一個 Message 中的一個具體 Field。

            比如編譯完 lm.helloworld.proto 之后,可以通過如下代碼得到 lm.helloworld.id 的定義:


            清單 7. 得到 lm.helloworld.id 的定義的代碼
                            
             const protobuf::Descriptor *desc = 
                importer_.pool()->FindMessageTypeByName(“lm.helloworld”); 
             const protobuf::FieldDescriptor* field = 
                desc->pool()->FindFileByName (“id”); 

            通過 Descriptor,F(xiàn)ieldDescriptor 的各種方法和屬性,應(yīng)用程序可以獲得各種關(guān)于 Message 定義的信息。比如通過 field->name() 得到 field 的名字。這樣,您就可以使用一個動態(tài)定義的消息了。

            編寫新的 proto 編譯器

            隨 Google Protocol Buffer 源代碼一起發(fā)布的編譯器 protoc 支持 3 種編程語言:C++,java 和 Python。但使用 Google Protocol Buffer 的 Compiler 包,您可以開發(fā)出支持其他語言的新的編譯器。

            類 CommandLineInterface 封裝了 protoc 編譯器的前端,包括命令行參數(shù)的解析,proto 文件的編譯等功能。您所需要做的是實現(xiàn)類 CodeGenerator 的派生類,實現(xiàn)諸如代碼生成等后端工作:

            程序的大體框架如圖所示:


            圖 4. XML 編譯器框圖
            圖 4. XML 編譯器框圖 

            在 main() 函數(shù)內(nèi),生成 CommandLineInterface 的對象 cli,調(diào)用其 RegisterGenerator() 方法將新語言的后端代碼生成器 yourG 對象注冊給 cli 對象。然后調(diào)用 cli 的 Run() 方法即可。

            這樣生成的編譯器和 protoc 的使用方法相同,接受同樣的命令行參數(shù),cli 將對用戶輸入的 .proto 進(jìn)行詞法語法等分析工作,最終生成一個語法樹。該樹的結(jié)構(gòu)如圖所示。


            圖 5. 語法樹
            圖 5. 語法樹 

            其根節(jié)點為一個 FileDescriptor 對象(請參考“動態(tài)編譯”一節(jié)),并作為輸入?yún)?shù)被傳入 yourG 的 Generator() 方法。在這個方法內(nèi),您可以遍歷語法樹,然后生成對應(yīng)的您所需要的代碼。簡單說來,要想實現(xiàn)一個新的 compiler,您只需要寫一個 main 函數(shù),和一個實現(xiàn)了方法 Generator() 的派生類即可。

            在本文的下載附件中,有一個參考例子,將 .proto 文件編譯生成 XML 的 compiler,可以作為參考。

            回頁首

            Protobuf 的更多細(xì)節(jié)

            人們一直在強調(diào),同 XML 相比, Protobuf 的主要優(yōu)點在于性能高。它以高效的二進(jìn)制方式存儲,比 XML 小 3 到 10 倍,快 20 到 100 倍。

            對于這些 “小 3 到 10 倍”,“快 20 到 100 倍”的說法,嚴(yán)肅的程序員需要一個解釋。因此在本文的最后,讓我們稍微深入 Protobuf 的內(nèi)部實現(xiàn)吧。

            有兩項技術(shù)保證了采用 Protobuf 的程序能獲得相對于 XML 極大的性能提高。

            第一點,我們可以考察 Protobuf 序列化后的信息內(nèi)容。您可以看到 Protocol Buffer 信息的表示非常緊湊,這意味著消息的體積減少,自然需要更少的資源。比如網(wǎng)絡(luò)上傳輸?shù)淖止?jié)數(shù)更少,需要的 IO 更少等,從而提高性能。

            第二點我們需要理解 Protobuf 封解包的大致過程,從而理解為什么會比 XML 快很多。

            Google Protocol Buffer 的 Encoding

            Protobuf 序列化后所生成的二進(jìn)制消息非常緊湊,這得益于 Protobuf 采用的非常巧妙的 Encoding 方法。

            考察消息結(jié)構(gòu)之前,讓我首先要介紹一個叫做 Varint 的術(shù)語。

            Varint 是一種緊湊的表示數(shù)字的方法。它用一個或多個字節(jié)來表示一個數(shù)字,值越小的數(shù)字使用越少的字節(jié)數(shù)。這能減少用來表示數(shù)字的字節(jié)數(shù)。

            比如對于 int32 類型的數(shù)字,一般需要 4 個 byte 來表示。但是采用 Varint,對于很小的 int32 類型的數(shù)字,則可以用 1 個 byte 來表示。當(dāng)然凡事都有好的也有不好的一面,采用 Varint 表示法,大的數(shù)字則需要 5 個 byte 來表示。從統(tǒng)計的角度來說,一般不會所有的消息中的數(shù)字都是大數(shù),因此大多數(shù)情況下,采用 Varint 后,可以用更少的字節(jié)數(shù)來表示數(shù)字信息。下面就詳細(xì)介紹一下 Varint。

            Varint 中的每個 byte 的最高位 bit 有特殊的含義,如果該位為 1,表示后續(xù)的 byte 也是該數(shù)字的一部分,如果該位為 0,則結(jié)束。其他的 7 個 bit 都用來表示數(shù)字。因此小于 128 的數(shù)字都可以用一個 byte 表示。大于 128 的數(shù)字,比如 300,會用兩個字節(jié)來表示:1010 1100 0000 0010

            下圖演示了 Google Protocol Buffer 如何解析兩個 bytes。注意到最終計算前將兩個 byte 的位置相互交換過一次,這是因為 Google Protocol Buffer 字節(jié)序采用 little-endian 的方式。


            圖 6. Varint 編碼
            圖 6. Varint 編碼 

            消息經(jīng)過序列化后會成為一個二進(jìn)制數(shù)據(jù)流,該流中的數(shù)據(jù)為一系列的 Key-Value 對。如下圖所示:


            圖 7. Message Buffer
            圖 7. Message Buffer 

            采用這種 Key-Pair 結(jié)構(gòu)無需使用分隔符來分割不同的 Field。對于可選的 Field,如果消息中不存在該 field,那么在最終的 Message Buffer 中就沒有該 field,這些特性都有助于節(jié)約消息本身的大小。

            以代碼清單 1 中的消息為例。假設(shè)我們生成如下的一個消息 Test1:

             Test1.id = 10; 
             Test1.str = “hello”;

            則最終的 Message Buffer 中有兩個 Key-Value 對,一個對應(yīng)消息中的 id;另一個對應(yīng) str。

            Key 用來標(biāo)識具體的 field,在解包的時候,Protocol Buffer 根據(jù) Key 就可以知道相應(yīng)的 Value 應(yīng)該對應(yīng)于消息中的哪一個 field。

            Key 的定義如下:

             (field_number << 3) | wire_type  

            可以看到 Key 由兩部分組成。第一部分是 field_number,比如消息 lm.helloworld 中 field id 的 field_number 為 1。第二部分為 wire_type。表示 Value 的傳輸類型。

            Wire Type 可能的類型如下表所示:


            表 1. Wire Type
            TypeMeaningUsed For
            0Varintint32, int64, uint32, uint64, sint32, sint64, bool, enum
            164-bitfixed64, sfixed64, double
            2Length-delimistring, bytes, embedded messages, packed repeated fields
            3Start groupGroups (deprecated)
            4End groupGroups (deprecated)
            532-bitfixed32, sfixed32, float

            在我們的例子當(dāng)中,field id 所采用的數(shù)據(jù)類型為 int32,因此對應(yīng)的 wire type 為 0。細(xì)心的讀者或許會看到在 Type 0 所能表示的數(shù)據(jù)類型中有 int32 和 sint32 這兩個非常類似的數(shù)據(jù)類型。Google Protocol Buffer 區(qū)別它們的主要意圖也是為了減少 encoding 后的字節(jié)數(shù)。

            在計算機內(nèi),一個負(fù)數(shù)一般會被表示為一個很大的整數(shù),因為計算機定義負(fù)數(shù)的符號位為數(shù)字的最高位。如果采用 Varint 表示一個負(fù)數(shù),那么一定需要 5 個 byte。為此 Google Protocol Buffer 定義了 sint32 這種類型,采用 zigzag 編碼。

            Zigzag 編碼用無符號數(shù)來表示有符號數(shù)字,正數(shù)和負(fù)數(shù)交錯,這就是 zigzag 這個詞的含義了。

            如圖所示:


            圖 8. ZigZag 編碼
            圖 8. ZigZag 編碼 

            使用 zigzag 編碼,絕對值小的數(shù)字,無論正負(fù)都可以采用較少的 byte 來表示,充分利用了 Varint 這種技術(shù)。

            其他的數(shù)據(jù)類型,比如字符串等則采用類似數(shù)據(jù)庫中的 varchar 的表示方法,即用一個 varint 表示長度,然后將其余部分緊跟在這個長度部分之后即可。

            通過以上對 protobuf Encoding 方法的介紹,想必您也已經(jīng)發(fā)現(xiàn) protobuf 消息的內(nèi)容小,適于網(wǎng)絡(luò)傳輸。假如您對那些有關(guān)技術(shù)細(xì)節(jié)的描述缺乏耐心和興趣,那么下面這個簡單而直觀的比較應(yīng)該能給您更加深刻的印象。

            對于代碼清單 1 中的消息,用 Protobuf 序列化后的字節(jié)序列為:

             08 65 12 06 48 65 6C 6C 6F 77  

            而如果用 XML,則類似這樣:


             31 30 31 3C 2F 69 64 3E 3C 6E 61 6D 65 3E 68 65 
             6C 6C 6F 3C 2F 6E 61 6D 65 3E 3C 2F 68 65 6C 6C 
             6F 77 6F 72 6C 64 3E 

            一共 55 個字節(jié),這些奇怪的數(shù)字需要稍微解釋一下,其含義用 ASCII 表示如下:
             <helloworld> 
                <id>101</id> 
                <name>hello</name> 
             </helloworld> 

            封解包的速度

            首先我們來了解一下 XML 的封解包過程。XML 需要從文件中讀取出字符串,再轉(zhuǎn)換為 XML 文檔對象結(jié)構(gòu)模型。之后,再從 XML 文檔對象結(jié)構(gòu)模型中讀取指定節(jié)點的字符串,最后再將這個字符串轉(zhuǎn)換成指定類型的變量。這個過程非常復(fù)雜,其中將 XML 文件轉(zhuǎn)換為文檔對象結(jié)構(gòu)模型的過程通常需要完成詞法文法分析等大量消耗 CPU 的復(fù)雜計算。

            反觀 Protobuf,它只需要簡單地將一個二進(jìn)制序列,按照指定的格式讀取到 C++ 對應(yīng)的結(jié)構(gòu)類型中就可以了。從上一節(jié)的描述可以看到消息的 decoding 過程也可以通過幾個位移操作組成的表達(dá)式計算即可完成。速度非???。

            為了說明這并不是我拍腦袋隨意想出來的說法,下面讓我們簡單分析一下 Protobuf 解包的代碼流程吧。

            以代碼清單 3 中的 Reader 為例,該程序首先調(diào)用 msg1 的 ParseFromIstream 方法,這個方法解析從文件讀入的二進(jìn)制數(shù)據(jù)流,并將解析出來的數(shù)據(jù)賦予 helloworld 類的相應(yīng)數(shù)據(jù)成員。

            該過程可以用下圖表示:


            圖 9. 解包流程圖
            圖 9. 解包流程圖 

            整個解析過程需要 Protobuf 本身的框架代碼和由 Protobuf 編譯器生成的代碼共同完成。Protobuf 提供了基類 Message 以及 Message_lite 作為通用的 Framework,,CodedInputStream 類,WireFormatLite 類等提供了對二進(jìn)制數(shù)據(jù)的 decode 功能,從 5.1 節(jié)的分析來看,Protobuf 的解碼可以通過幾個簡單的數(shù)學(xué)運算完成,無需復(fù)雜的詞法語法分析,因此 ReadTag() 等方法都非常快。 在這個調(diào)用路徑上的其他類和方法都非常簡單,感興趣的讀者可以自行閱讀。 相對于 XML 的解析過程,以上的流程圖實在是非常簡單吧?這也就是 Protobuf 效率高的第二個原因了。

            回頁首

            結(jié)束語

            往往了解越多,人們就會越覺得自己無知。我惶恐地發(fā)現(xiàn)自己竟然寫了一篇關(guān)于序列化的文章,文中必然有許多想當(dāng)然而自以為是的東西,還希望各位能夠去偽存真,更希望真的高手能不吝賜教,給我來信。謝謝。


            參考資料

            學(xué)習(xí)

            posted on 2012-10-15 20:16 Richard Wei 閱讀(3121) 評論(0)  編輯 收藏 引用 所屬分類: 開源
            久久精品www| 99久久精品国产高清一区二区| 99热都是精品久久久久久| 久久国产三级无码一区二区| 一本久久综合亚洲鲁鲁五月天亚洲欧美一区二区 | 99久久超碰中文字幕伊人| 国产V综合V亚洲欧美久久| 国产精品99久久久久久宅男| 伊人色综合九久久天天蜜桃| 久久久久人妻一区精品色| 一级做a爱片久久毛片| 国产精品久久久香蕉| 99国产欧美精品久久久蜜芽| 久久人人爽人爽人人爽av| 人妻精品久久无码区| 精品久久久久一区二区三区| 色偷偷久久一区二区三区| 九九热久久免费视频| 午夜久久久久久禁播电影| 久久久精品日本一区二区三区| 久久精品中文无码资源站| 99久久99久久精品国产片果冻 | 午夜精品久久久久久| 国内精品久久久久久久97牛牛| 开心久久婷婷综合中文字幕| 91精品国产91久久综合| 日韩欧美亚洲综合久久| 国产激情久久久久影院小草| 日韩精品久久久久久久电影蜜臀| 久久精品国产精品亚洲下载| 精品999久久久久久中文字幕| 久久精品国产亚洲av麻豆图片| 国产成人无码精品久久久免费 | 久久久老熟女一区二区三区| 热久久国产欧美一区二区精品| 久久精品嫩草影院| 久久人人爽爽爽人久久久| 亚洲精品无码久久久| 精品综合久久久久久88小说| 成人a毛片久久免费播放| 久久久久久九九99精品|