Protocol Buffer技术详解(C++实例)
这篇Blog仍然是以Google的官方文档为主线，代码实例则彻底取自于咱们正在开发的一个Demo项目，经过前一段时间的尝试，感受这种结合的方式比较有利于培训和内部的技术交流。仍是那句话，没有最好的，只有最适合的。我想写Blog也是这一道理吧，不一样的技术主题可能须要采用不一样的风格。好了，仍是让咱们尽早切入主题吧。
1、生成目标语言代码。
下面的命令帮助咱们将MyMessage.proto文件中定义的一组Protocol Buffer格式的消息编译成目标语言（C++）的代码。至于消息的内容，咱们会在后面以分段的形式逐一列出，同时也会在附件中给出全部源代码。
protoc -I=./message --cpp_out=./src ./MyMessage.proto
从上面的命令行参数中能够看出，待编译的文件为MyMessage.proto，他存放在当前目录的message子目录下。--cpp_out参数则指示编译工具咱们须要生成目标语言是C++，输出目录是当前目录的src子目录。在本例中，生成的目标代码文件名是MyMessage.pb.h和MyMessage.pb.cc。
2、简单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类中提供了具体的实现。对于咱们的项目而言，整个系统相对比较封闭，不会和更多的外部程序进行交互，与此同时，咱们的客户端部分又是运行在Android平台，有鉴于此，咱们考虑使用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、嵌套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;
}
4、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++测试代码和说明性注释。ui
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;
}
- 1. Protocol Buffer技术详解(C++实例)
- 2. Protocol Buffer技术详解(Java实例)
- 3. Protocol Buffer技术
- 4. Protocol Buffer技术详解(语言规范)
- 5. Protocol Buffer技术详解(数据编码)
- 6. Protocol Buffer详解
- 7. windows10 Protocol buffer配置详解
- 8. 详解 Google Protocol Buffer 协议
- 9. grpc和protocol buffer介绍&实例
- 10. Protocol Buffer搭建及示例
- 更多相关文章...
- • XML 相关技术 - XML 教程
- • Hibernate的快照技术 - Hibernate教程
- • 三篇文章了解 TiDB 技术内幕 —— 说计算
- • Docker容器实战(一) - 封神Server端技术
-
每一个你不满意的现在，都有一个你没有努力的曾经。