protobuf 使用


1. 定義 .proto 文件:

     首先我們需要編寫一個 proto 文件,定義我們程序中需要處理的結構化數據,在 protobuf 的術語中,結構化數據被稱為 Message。proto 文件非常類似 java 或者 C 語言的 數據定義,可以使用 C或 C++風格的注釋,下面是proto文件的例子

package tutorial;
option java_package = "com.example.tutorial";
option java_outer_classname = "AddressBookProtos";
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;
}
// Our address book file is just one of these.
message AddressBook {
    repeated Person person = 1;
}

一個 proto 文件主要包含 package定義、 message定義和屬性定義三個部分,還有一些 可選項。

1.1 定義 package

     Package在 c++中對應 namespace。 對於 Java,包聲明符會變為 java 的一個包,除非在 .proto 文件中提供了一個明確有 java_package。

1.2 定義 message

     Message在 C++中對應 class。Message中定義的全部屬性在 class中全部為 private 的。

     Message的嵌套使用可以嵌套定義,也可以采用先定義再使用的方式。

     Message的定義末尾可以采用 java方式在末尾不加“ ;”,也可以采用 C++定義方式在末尾加 上“;”,這兩種方式都兼容,建議采用 java定義方式。

     向.proto 文件添加注釋,可以使用 C/C++/java風格的雙斜杠( // ) 語法格式。

1.3 定義屬性

     屬性定義分為四部分:標注 +類型+屬性名 +屬性順序號 +[默認值 ],其示意如下所示

     

 

其中屬性名與 C++和 java語言類似,不再解釋;下面分別對標注、類型和屬性順序號加 以詳細介紹。 其中包名和消息名以及其中變量名均采用 java 的命名規則——駝峰式命名法。

1.3.1 標注

        標注包括“ required”、“optional”、“repeated”三種,其中

        required 表示該屬性為必選屬性,否則對應的 message“未初始化”,debug 模式下導致 斷言, release模式下解析失敗;

        optional 表示該屬性為可選屬性,不指定,使用默認值( int 或者 char 數據類型默認為 0,string 默認為空, bool 默認為 false,嵌套 message默認為構造,枚舉則為第一個)

 

        repeated 表示該屬性為重復字段,可看作是動態數組,類似於 C++中的 vector。

        如果為 optional 屬性,發送端沒有包含該屬性,則接收端在解析式采用默認值。對於默認值,如果已設置默認值,則采用默認值,如果未設置,則類型特定的默認值為使用,例如 string 的默認值為 ” ”。

 1.3.2 類型

        Protobuf 的屬性基本包含了 c++需要的所有基本屬性類型。

      

 

 

 1.3.2.1 Union 類型定義

        Protobuf 沒有提供 union 類型,如果希望使用 union 類型,可以采用 enum 和 optional 屬性定義的方式。 例如,如果已經定義了 Foo、Bar、Baz等 message,則可以采用如下定義。

message OneMessage {
 enum Type { FOO = 1; BAR = 2; BAZ = 3; }
 // Identifies which field is filled in.
 required Type type = 1;
 // One of the following will be filled in.
 optional Foo foo = 2;
 optional Bar bar = 3;
 optional Baz baz = 4;
}

1.3.3 屬性順序號

      屬性順序號是 protobuf 為了提高數據的壓縮和可選性等功能定義的, 需要按照順序進行 定義,且不允許有重復。

1.4. 其他

1.4.1 import 可選項

       Import 可選項用於包含其它 proto 文件中定義的 message或 enum等。標准格式如 下

import “phonetype.proto ”;

使用時,import 的文件必須與當前文件處於同一個文件夾下, protoc 無法完成不處於同 一個文件夾下的 import 選項。

 

1.4.2 packed

        packed (field option): 如果該選項在一個整型基本類型上被設置為真, 則采用更緊湊的編 碼方式。當然使用該值並不會對數值造成任何損失。在 2.3.0 版本之前,解析器將會忽略那些非期望的包裝值。因此,它不可能在不破壞現有框架的兼容性上而改變壓縮格式。 在 2.3.0 之后,這種改變將是安全的,解析器能夠接受上述兩種格式,但是在 處理 protobuf 老版本 程序時,還是要多留意一下。

repeated int32 samples = 4 [packed=true];

1.4.3 default

      [default = default_value]: optional 類型的字段,如果在序列化時沒有被設置,或者是老版 本的消息中根本不存在該字段,那么在反序列化該類型的消息是, optional 的字段將被賦予類型相關的缺省值,如 bool 被設置為 false,int32 被設置為 0。Protocol Buffer 也支持自定義 的缺省值,如:

optional int32 result_per_page = 3 [default = 10];

1.5 大數據量使用建議

      在使用過程中發現,對於大數據量的協議報文(循環超過10000 條),如果 repeated 修飾的屬性為對象類型 (諸如 message 、Bytes、string 等稱為“對象類型”,其余的諸如 int32、 int64、float 等等稱為“原始類型” )時,效率非常低,而且占用的進程內存也非常大,建議 采用如下方式優化。

1.5.1 repeated message類型

       在 message 中對 repeated 標識的 message類型的字段需要做大量 ADD操作時,可以考 慮盡量避免嵌套 message或者減少嵌套的 message個數。 實例如下所示:

 

 

 1.5.2 repeated raw 類型

      在 message中對 repeated 標識的原始數據類型的字段需要做大量 ADD操作(例如超過3千)時,可以考慮預分配數據空間,避免重復大量地分配空間。 實例如下所示:

 

 

 

 1.5.3 repeated Bytes類型

       在 protobuf 中,Bytes基於 C++ STL中的 string 實現,因為 string 內存管理的原因,程序 空間往往較大。所以應用如果有很多 repeated Bytes類型的字段的話,進程顯示耗用大量內存,這與 vector的情況基本一致。 

1.6 Protocol Buffer 消息升級原則

       在實際的開發中會存在這樣一種應用場景, 即消息格式因為某些需求的變化而不得不進行必要的升級, 但是有些使用原有消息格式的應用程序暫時又不能被立刻升級, 這便要求我們在升級消息格式時要遵守一定的規則, 從而可以保證基於新老消息格式的新老程序同時運行。規則如下:

           1. 不要修改已經存在字段的標簽號。

           2. 任何新添加的字段必須是 optional 和 repeated 限定符,否則無法保證新老程序在 互相傳遞消息時的消息兼容性。

           3. 在原有的消息中, 不能移除已經存在的 required 字段,optional 和 repeated 類型的 字段可以被移除,但是他們之前使用的標簽號必須被保留,不能被新的字段重用。

           4. int32、uint32、int64、uint64 和 bool 等類型之間是兼容的, sint32 和 sint64 是兼容 的,string 和 bytes 是兼容的, fixed32 和 sfixed32,以及 fixed64 和 sfixed64之間是兼容的, 這意味着如果想修改原有字段的類型時, 為了保證兼容性, 只能將其修改為與其原有類型兼 容的類型,否則就將打破新老消息格式的兼容性。 

           5. optional 和 repeated 限定符也是相互兼容的。

第2章   編譯 .proto文件

     可以通過定義好的 .proto 文件來生成 Java、Python、C++代碼,需要基於 .proto 文件運行 protocol buffer 編譯器 protoc。運行的命令如下所示:

      

protoc --proto_path=IMPORT_PATH --cpp_out=DST_DIR --java_out=DST_DIR --python_out=DST_DIR path/to/file.proto

MPORT_PATH聲明了一個 .proto 文件所在的具體目錄。 如果忽略該值, 則使用當前目錄。

如果有多個目錄則可以 對 --proto_path 寫多次,它們將會順序的被訪問並執行導入。 -I=IMPORT_PATH是它的簡化形式。

當然也可以提供一個或多個輸出路徑: --cpp_out 在目標目錄 DST_DIR 中 產 生 C++ 代 碼 ,

你必須提供一個或多個 .proto 文件作為輸入。多個 .proto 文件能夠一次全部聲明。雖然 這些文件是相對於當前目錄來命名的,每個文件必須在一個 IMPORT_PATH中,只有如此編 譯器才可以決定它的標准名稱。

 

 

第3章 使用 message

        3.1 類成員變量的訪問

               在生成的 .h 文件中定義了類成員的訪問方法。例如,對於 Person類,定義了 name、id、 email、phone 等成員的訪問方法。 獲取成員變量值直接采用使用成員變量名(全部為小寫) ,設置成員變量值,使用在成 員變量名前加 set_的方法。

               對於普通成員變量( required 和 optional)提供 has_方法判斷變量值是否被設置;提供 clear_方法清除設置的變量值。

               對於 string 類型,提供多種 set_方法,其參數不同。同時,提供了一個 mutable_方法, 返回變量值的可修改指針。

             對於 repeated 變量,提供了其它一些特殊的方法:

                       _size方法:返回 repeated field’s size

                        通過下腳標訪問其中的數組成員組

                        通過 mutable_的方法返回指針

                       _add 方法:增加一個成員。

// name
inline bool has_name() const;
inline void clear_name();
inline const ::std::string& name() const;
inline void set_name(const ::std::string& value);
inline void set_name(const char* value);
inline ::std::string* mutable_name();
// id
inline bool has_id() const;
inline void clear_id();
inline int32_t id() const;
inline void set_id(int32_t value);
// email
inline bool has_email() const;
inline void clear_email();
inline const ::std::string& email() const;
inline void set_email(const ::std::string& value);
inline void set_email(const char* value);
inline ::std::string* mutable_email();
// phone
inline int phone_size() const;
inline void clear_phone();
inline const ::google::protobuf::RepeatedPtrField< ::tutorial::Person_PhoneNumber >& phone() const;
inline ::google::protobuf::RepeatedPtrField< ::tutorial::Person_PhoneNumber >* mutable_phone(); 
inline const ::tutorial::Person_PhoneNumber& phone(int index) const;
inline ::tutorial::Person_PhoneNumber* mutable_phone(int index);
inline ::tutorial::Person_PhoneNumber* add_phone();

3.2 標准 message 方法

       生成的 .h 文件中的 class都繼承自 ::google::protobuf::Message 類,Message類提供了一些 方法可以檢查或者操作整個 message,包括

             bool IsInitialized() const; 檢查是否所有 required 變量都已經初始化;

             string DebugString() const; 返回 message的可閱讀的表示,主要用於調試程序;

             void CopyFrom(const Person& from); 使用一個 message的值覆蓋本message;

             void Clear(); 清空 message的所有成員變量值。

3.3 編碼和解碼函數

         每個 message類都提供了寫入和讀取 message數據的方法,包括

                 bool SerializeToString(string* output) const; 把 message編碼進 output 。

                  bool ParseFromString(const string& data); 從 string 解碼到 message

                 bool SerializeToArray(char* buf,int size) const; 把 message編碼進數組 buf. 

                 bool ParseFromArray(const char* buf,int size); 把 buf 解碼到 message。此解 碼方法效率較 ParseFromString高很多,所以一般用這種方法解碼。

                bool SerializeToOstream(ostream* output) const; 把 message編碼進 ostream

                bool ParseFromIstream(istream* input); 從 istream 解碼到 message

備注:發送接收端所使用的加碼解碼方法不一定非得配對,即發送端用 SerializeToString 接收端不一定非得用 ParseFromString ,可以使用其他解碼方法。

例子:

簡單 message 生成的 C++代碼

這里先定義一個最簡單的 message,其中只是包含原始類型的字段。

option optimize_for = LITE_RUNTIME;
message LogonReqMessage {
required int64 acctID = 1; 
required string passwd = 2;
}

由於我們在 MyMessage 文件中定義選項 optimize_for 的值為 LITE_RUNTIME,因此由 該 .proto 文 件 生 成 的 所 有 C++類 的 父 類 均 為 ::google::protobuf::MessageLite , 而 非::google::protobuf::Message。MessageLite類是 Message的父類,在 MessageLite中將缺少 Protocol Buffer 對反射的支持,而此類功能均在 Message類中提供了具體的實現。使用 LITE 版本的 Protocol Buffer。這樣不僅可以得到更高編碼效率,而且生成代碼編譯后所占用的資 源也會更少,至於反射所能帶來的靈活性和極易擴展性。下面我們來看一下由 message LogonReqMessage生成的 C++類的部分聲明,以及常用方法的說明性注釋。

class LogonReqMessage : public ::google::protobuf::MessageLite {
public:
LogonReqMessage();
virtual ~LogonReqMessage();
// implements Message ----------------------------------------------
// 下面的成員函數均實現自 MessageLite 中的虛函數。
// 創建一個新的 LogonReqMessage對象,等同於 clone。
LogonReqMessage* New() const;
// 用另外一個 LogonReqMessage對象初始化當前對象,等同於賦值操作符重載( operator=)
void CopyFrom(const LogonReqMessage& from);
// 清空當前對象中的所有數據,既將所有成員變量置為未初始化狀態。
void Clear();
// 判斷當前狀態是否已經初始化。
bool IsInitialized() const;
// 在給當前對象的所有變量賦值之后,獲取該對象序列化后所需要的字節數。
int ByteSize() const;
// 獲取當前對象的類型名稱。
::std::string GetTypeName() const;
// required int64 acctID = 1;
// 下面的成員函數都是因 message中定義的 acctID 字段而生成。
// 這個靜態成員表示 AcctID 的標簽值。命名規則是 k + FieldName(駝峰規則) + FieldNumber。
static const int kAcctIDFieldNumber = 1;
// 如果 acctID字段已經被設置返回 true ,否則 false。
inline bool has_acctid() const;
// 執行該函數后 has_acctid 函數將返回 false,而下面的 acctid 函數則返回 acctID 的缺省值。
inline void clear_acctid();
// 返回 acctid 字段的當前值,如果沒有設置則返回 int64 類型的缺省值。
inline ::google::protobuf::int64 acctid() const; 
// 為 acctid 字段設置新值,調用該函數后 has_acctid 函數將返回 true。
inline void set_acctid(::google::protobuf::int64 value);
// required string passwd = 2;
// 下面的成員函數都是因 message中定義的 passwd 字段而生成。這里生成的函數和上面 acctid
// 生成的那組函數基本相似。因此這里只是列出差異部分。
static const int kPasswdFieldNumber = 2;
inline bool has_passwd() const;
inline void clear_passwd();
inline const ::std::string& passwd() const;
inline void set_passwd(const ::std::string& value);
// 對於字符串類型字段設置 const char* 類型的變量值。
inline void set_passwd(const char* value);
inline void set_passwd(const char* value, size_t size);
// 可以通過返回值直接給 passwd 對象賦值。在調用該函數之后 has_passwd 將返回 true。
inline ::std::string* mutable_passwd();
// 釋放當前對象對 passwd 字段的所有權,同時返回 passwd 字段對象指針。調用此函數之后, passwd 字段對象
// 的所有權將移交給調用者。此后再調用 has_passwd 函數時將返回 false。
inline ::std::string* release_passwd();
private:
... ...
};

下面是讀寫 LogonReqMessage對象的 C++測試代碼和說明性注釋

void testSimpleMessage()
{
printf("==================This is simple message.================\n");
// 序列化 LogonReqMessage對象到指定的內存區域。
LogonReqMessage logonReq;
logonReq.set_acctid(20);
logonReq.set_passwd("Hello World");
// 提前獲取對象序列化所占用的空間並進行一次性分配,從而避免多次分配
// 而造成的性能開銷。通過該種方式,還可以將序列化后的數據進行加密。
// 之后再進行持久化,或是發送到遠端。
int length = logonReq.ByteSize();
char* buf = new char[length];
logonReq.SerializeToArray(buf,length);
// 從內存中讀取並反序列化 LogonReqMessage對象,同時將結果打印出來。
LogonReqMessage logonReq2;
logonReq2.ParseFromArray(buf,length);
printf("acctID = %I64d, password = %s\n",logonReq2.acctid(),logonReq2.passwd().c_str());
delete [] buf;
}

3.5 嵌套 message 生成的 C++代碼

enum UserStatus {
OFFLINE = 0;
ONLINE = 1;
}
enum LoginResult {
LOGON_RESULT_SUCCESS = 0;
LOGON_RESULT_NOTEXIST = 1;
LOGON_RESULT_ERROR_PASSWD = 2;
LOGON_RESULT_ALREADY_LOGON = 3;
LOGON_RESULT_SERVER_ERROR = 4;
}
message UserInfo {
required int64 acctID = 1;
required string name = 2;
required UserStatus status = 3;
}
message LogonRespMessage {
required LoginResult logonResult = 1;
required UserInfo userInfo = 2; // 這里嵌套了 UserInfo 消息。
}

對於上述消息生成的 C++代碼,UserInfo 因為只是包含了原始類型字段,因此和上例中 的 LogonReqMessage沒有太多的差別,這里也就不在重復列出了。由於 LogonRespMessage 消息中嵌套了 UserInfo類型的字段,在這里我們將僅僅給出該消息生成的 C++代碼和關鍵性 注釋。

class LogonRespMessage : public ::google::protobuf::MessageLite {
public:
LogonRespMessage();
virtual ~LogonRespMessage();
// implements Message ----------------------------------------------
... ... // 這部分函數和之前的例子一樣。
// required .LoginResult logonResult = 1;
// 下面的成員函數都是因 message中定義的 logonResult 字段而生成。
// 這一點和前面的例子基本相同,只是類型換做了枚舉類型 LoginResult。
static const int kLogonResultFieldNumber = 1;
inline bool has_logonresult() const; 
inline void clear_logonresult();
inline LoginResult logonresult() const;
inline void set_logonresult(LoginResult value);
// required .UserInfo userInfo = 2;
// 下面的成員函數都是因 message中定義的 UserInfo 字段而生成。
// 這里只是列出和非消息類型字段差異的部分。
static const int kUserInfoFieldNumber = 2;
inline bool has_userinfo() const;
inline void clear_userinfo();
inline const ::UserInfo& userinfo() const;
// 可以看到該類並沒有生成用於設置和修改 userInfo 字段 set_userinfo 函數,而是將該工作
// 交給了下面的 mutable_userinfo 函數。因此每當調用函數之后, Protocol Buffer 都會認為
// 該字段的值已經被設置了,同時 has_userinfo 函數亦將返回 true。在實際編碼中,我們可以
// 通過該函數返回 userInfo 字段的內部指針,並基於該指針完成 userInfo 成員變量的初始化工作。
inline ::UserInfo* mutable_userinfo();
inline ::UserInfo* release_userinfo();
private:
... ...
}; 

下面是讀寫 LogonRespMessage對象的 C++測試代碼和說明性注釋

void testNestedMessage()
{
printf("==================This is nested message.================\n");
LogonRespMessage logonResp;
logonResp.set_logonresult(LOGON_RESULT_SUCCESS);
// 如上所述,通過 mutable_userinfo 函數返回 userInfo 字段的指針,之后再初始化該對象指針。
UserInfo* userInfo = logonResp.mutable_userinfo();
userInfo->set_acctid(200);
userInfo->set_name("Tester");
userInfo->set_status(OFFLINE);
int length = logonResp.ByteSize();
char* buf = new char[length];
logonResp.SerializeToArray(buf,length);
LogonRespMessage logonResp2;
logonResp2.ParseFromArray(buf,length);
printf("LogonResult = %d, UserInfo->acctID = %I64d, UserInfo->name = %s, UserInfo->status = %d\n"
,logonResp2.logonresult(),logonResp2.userinfo().acctid(),logonResp2.userinfo().name().c_str(),logonResp2.userinfo()
.status());
delete [] buf;
} 

3.6 repeated 嵌套 message 生成的 C++代碼

message BuddyInfo {
required UserInfo userInfo = 1;
required int32 groupID = 2;
}
message RetrieveBuddiesResp {
required int32 buddiesCnt = 1;
repeated BuddyInfo buddiesInfo = 2;
} 

對於上述消息生成的代碼, 我們將只是針對 RetrieveBuddiesResp消息所對應的 C++代碼 進 行 詳 細 說 明 , 其 余 部 分 和 前 面 小 節 的 例 子 基 本 相 同 , 可 直 接 參 照 。 而 對 於 RetrieveBuddiesResp類中的代碼,我們也僅僅是對 buddiesInfo 字段生成的代碼進行更為詳細 的解釋。

class RetrieveBuddiesResp : public ::google::protobuf::MessageLite {
public:
RetrieveBuddiesResp();
virtual ~RetrieveBuddiesResp();
... ... // 其余代碼的功能性注釋均可參照前面的例子。
// repeated .BuddyInfo buddiesInfo = 2;
static const int kBuddiesInfoFieldNumber = 2;
// 返回數組中成員的數量。
inline int buddiesinfo_size() const;
// 清空數組中的所有已初始化成員,調用該函數后, buddiesinfo_size 函數將返回 0。
inline void clear_buddiesinfo();
// 返回數組中指定下標所包含元素的引用。
inline const ::BuddyInfo& buddiesinfo(int index) const;
// 返回數組中指定下標所包含元素的指針,通過該方式可直接修改元素的值信息。
inline ::BuddyInfo* mutable_buddiesinfo(int index);
// 像數組中添加一個新元素。返回值即為新增的元素,可直接對其進行初始化。
inline ::BuddyInfo* add_buddiesinfo();
// 獲取 buddiesInfo 字段所表示的容器,該函數返回的容器僅用於遍歷並讀取,不能直接修改。
inline const ::google::protobuf::RepeatedPtrField< ::BuddyInfo >&
buddiesinfo() const;
// 獲取 buddiesInfo 字段所表示的容器指針,該函數返回的容器指針可用於遍歷和直接修改。
inline ::google::protobuf::RepeatedPtrField< ::BuddyInfo >*
mutable_buddiesinfo(); 
private:
... ...
};

下面是讀寫 RetrieveBuddiesResp對象的 C++測試代碼和說明性注釋

void testRepeatedMessage()
{
printf("==================This is repeated message.================\n");
RetrieveBuddiesResp retrieveResp;
retrieveResp.set_buddiescnt(2);
BuddyInfo* buddyInfo = retrieveResp.add_buddiesinfo();
buddyInfo->set_groupid(20);
UserInfo* userInfo = buddyInfo->mutable_userinfo();
userInfo->set_acctid(200);
userInfo->set_name("user1");
userInfo->set_status(OFFLINE);
buddyInfo = retrieveResp.add_buddiesinfo();
buddyInfo->set_groupid(21);
userInfo = buddyInfo->mutable_userinfo();
userInfo->set_acctid(201);
userInfo->set_name("user2");
userInfo->set_status(ONLINE);
int length = retrieveResp.ByteSize();
char* buf = new char[length];
retrieveResp.SerializeToArray(buf,length);
RetrieveBuddiesResp retrieveResp2;
retrieveResp2.ParseFromArray(buf,length);
printf("BuddiesCount = %d\n",retrieveResp2.buddiescnt());
printf("Repeated Size = %d\n",retrieveResp2.buddiesinfo_size());
// 這里僅提供了通過容器迭代器的方式遍歷數組元素的測試代碼。
// 事實上,通過 buddiesinfo_size 和 buddiesinfo 函數亦可循環遍歷。
RepeatedPtrField<BuddyInfo>* buddiesInfo = retrieveResp2.mutable_buddiesinfo();
RepeatedPtrField<BuddyInfo>::iterator it = buddiesInfo->begin();
for (; it != buddiesInfo->end(); ++it) {
printf("BuddyInfo->groupID = %d\n", it->groupid());
printf("UserInfo->acctID = %I64d, UserInfo->name = %s, UserInfo->status = %d\n"
, it->userinfo().acctid(), it->userinfo().name().c_str(),it->userinfo().status());
}
delete [] buf;
} 

 

 

3.7 寫入 message

#include"addressbook.pb.h"
#include<iostream>
#include<unistd.h>
#include<sys/types.h>
#include<sys/stat.h>
#include<fcntl.h>
#include<stdio.h>
#include<string.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<stdlib.h>
#include<string>
using namespace std;
{
// 填充消息
void PromptInput(tutorial::Person* person){
person->set_id(2008);
person->set_name("Joe");
person->set_email("joepayne@163.com");
int i=0;
while(i<3){
tutorial::Person::PhoneNumber* phone_number=person->add_phone(); 
phone_number->set_number("13051889399");
phone_number->set_type(tutorial::Person::MOBILE);
i++;
}
}
}
int main(){
{
// 建立 SOCKET連接
}
int n=0;
tutorial::AddressBook msg1;
PromptInput(msg1.add_person());
string s;
int uSize;
{
// 發送 1 個消息包
while(n<1){
// 兩次發送過程
{
 msg1.SerializeToString(&s);
// 把消息包的長度發送出去
usize=s.size();
write(sockfd,&uSize,sizeof(uSize));
// 把消息包發送出去
// 注意如果消息數據比較大的話,一次 IO寫操作不能寫完,那就需要自己另作處理了
write(sockfd,s.data(),s.size());
}
// 輸出包的大小
cout<<"Message size:"<<uSize<<endl;
n++;
}
return 0;
} 

3.8 讀出 message

#include"addressbook.pb.h"
#include<iostream>
#include<unistd.h>
#include<sys/types.h> 
#include<sys/stat.h>
#include<fcntl.h>
#include<stdio.h>
#include<string.h>
#include<stdlib.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<stdlib.h>
using namespace std;
// 列出消息中的所有數據
void List(const tutorial::AddressBook& address_book){
for(int i=0;i<address_book.person_size();i++){
const tutorial::Person& person=address_book.person(i);
cout<<"Person ID:"<<person.id()<<endl;
cout<<"Name:"<<person.name()<<endl;
if(person.has_email()){
cout<<"E-mail address:"<<person.email()<<endl;
}
for(int j=0;j<person.phone_size();j++){
const tutorial::Person::PhoneNumber& phone_number=person.phone(j);
switch(phone_number.type()){
case tutorial::Person::MOBILE:
cout<<"Mobile phone:";
break;
case tutorial::Person::HOME:
cout<<"Home phone:";
break;
case tutorial::Person::WORK:
cout<<"WOrk Phone:";
break;
}
cout<<phone_number.number()<<endl;
}
}
}
int main(){
{
// 建立連接
}
tutorial::AddressBook msg2; 
int uLen;
char* uData;
int nRead;
{
// 讀取數據
// 先讀取消息包的長度信息
while((nRead=read(connfd,&uLen,sizeof(uLen)))>0){
cout<<"The length of the message is:"<<uLen<<endl;
// 根據消息包的長度信息,分配適當大小的緩沖區來接收消息包數據
uData=(char*)malloc(uLen);
// 注意此次 read 可能一次性讀不完一個包,如果包比較大的話,這樣的話就得自己再做進一步處
理
read(connfd,uData,uLen);
// 解碼操 作,從 緩沖 區中解 到 msg2 消息空間中去, 此 處用 ParseFromArray 而沒有使用ParseFromString 因為前者的效率相對於后者效率要高很多。
if(!msg2.ParseFromArray(uData,uLen)){
cout<<”Parse failed!”<<endl;
return -1;
}
free(uData);
uData=NULL;
// 輸出消息的數據信息
List(msg2);
}
}
return 0;
}

附錄:駝峰命名法

     駝峰命名法就是當變量名或函式名是由一個或多個單字連結在一起, 而構成的唯一識別 字時,第一個單字以小寫字母開始; 第二個單字的首字母大寫或每一個單字的首字母都采用大寫字母, 例如:myFirstName、 myLastName,這樣的變量名看上去就像駱駝峰一樣此起彼伏,故得名。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM