enum command

{

// 登录请求

CMD_LOGIN_REQ = 501 [(message_name) = "LoginReq"];

// 登录回复

CMD_LOGIN_RSP = 502 [(message_name) = "LoginRsp"];

}

extend google.protobuf.MessageOptions

{

// 协议的协议号

optional gateproto.command protocolid = 51550;

}

// CMD_LOGIN_REQ = 501

message LoginReq

{

option (gateproto.protocolid) = CMD_LOGIN_REQ;

required string account = 1;

required string name = 2;

required bytes token = 3;

required uint64 roleid = 4;

required uint32 is_reconnect = 5[ default = 0];

optional uint32 imgid = 6[ default = 0];

optional string device_id = 7;

}

include <stdio.h>

include <vector>

include <map>

include <iostream>

include "google/protobuf/message.h"

include "google/protobuf/descriptor.h"

include "google/protobuf/descriptor.pb.h"

include "google/protobuf/dynamic_message.h"

include "google/protobuf/compiler/importer.h"

include "google/protobuf/extension_set.h"

include <stdlib.h>

include <stdint.h>

include <ctype.h>

include "stable_test.h"

using namespace std;

using namespace google::protobuf;

using namespace google::protobuf::compiler;

using namespace google::protobuf::internal;

static DiskSourceTree srctree_;

static Importer *importer_;

static DynamicMessageFactory MsgFactory_;

struct MsgDesc

{

const FileDescriptor *filedesc;

const Descriptor *desc;

const Message *prototype;

};

std::map<string, MsgDesc *> descmap_;

std::vector< MsgDesc *> vecDesc_;

const FieldDescriptor * protocolid_des;

class FileErrorCollector : public MultiFileErrorCollector {

public:

void AddError(const string& filename, int line, int column,

const string& message)

{

cout << filename << endl;

cout << line << endl;

cout << column << endl;

cout << message << endl;

}

};

void AddSearchPath(vector<string>& paths)

{

for (size_t i = 0; i < paths.size(); i++)

{

srctree_.MapPath("", paths[i]);

}

FileErrorCollector err;

importer_ = new Importer(&srctree_, &err);

}

void AddMsgDesc(const string& proto_file)

{

const FileDescriptor *file_desc = importer_->Import(proto_file);

int count = file_desc->message_type_count();

if (count <= 0)

return;

int extensiopn_couny = file_desc->extension_count();

printf("extensiopn_couny type: %d\n", extensiopn_couny);

for (int i = 0; i < extensiopn_couny; i++)

{

const FieldDescriptor * msg_desc = file_desc->extension(i);

printf("extension type: %s\n", msg_desc->name().c_str());

printf("extension cpp type: %s\n", msg_desc->cpp_type_name());

printf("extension type: %s\n", msg_desc->type_name());

if ( msg_desc->name() == "protocolid")

{

protocolid_des = msg_desc;

}

}

// string key = proto_file.substr(0, proto_file.find_last_of("."));

for (int i = 0; i < count; i++)

{

const Descriptor * msg_desc = file_desc->message_type(i);

printf("message type: %s\n", msg_desc->name().c_str());

MsgDesc *msgdesc = new MsgDesc;

msgdesc->filedesc = file_desc;

msgdesc->desc = msg_desc;

msgdesc->prototype = MsgFactory_.GetPrototype(msg_desc);

descmap_[msg_desc->name()] = msgdesc;

printf("message type: %s\n", msg_desc->options().DebugString().c_str());

/*bool m = msg_desc->options().GetExtension(gateproto::protocolid);

if (m) {

printf("message type: %s\n", msg_desc->name().c_str());

vecDesc_.push_back(msgdesc);

}*/

}

}

void SendGsRandomMessage()

{

uint32_t index = 10;

auto iter = descmap_.find("EnterPvePassReq");

if (iter!= descmap_.end() ){

printf("SendGsRandomMessage");

MsgDesc *msgdesc = iter->second;

Message *msg = msgdesc->prototype->New();

printf("SendGsRandomMessage field count type: %d\n",msg->GetDescriptor()->field_count());

printf("SendGsRandomMessage extension count type: %d\n",msg->GetDescriptor()->extension_count());

printf("SendGsRandomMessage one count type: %d\n",msg->GetDescriptor()->oneof_decl_count());

printf("SendGsRandomMessage enum count type: %d\n",msg->GetDescriptor()->enum_type_count());

const Descriptor * option_Desc = msg->GetDescriptor()->options().GetDescriptor();

for (int i=0;i<option_Desc->field_count();i++) {

const FieldDescriptor * filed_des = option_Desc->field(i);

printf("FieldDescriptor type: %s\n", filed_des->name().c_str());

}

for (int i=0;i<msg->GetDescriptor()->field_count();i++) {

const FieldDescriptor * filed_des = msg->GetDescriptor()->field(i);

printf("FieldDescriptor type: %s\n", filed_des->name().c_str());

}

MessageOptions msgop= msg->GetDescriptor()->options();

const ::google::protobuf::UnknownFieldSet& unset = msgop.unknown_fields();

for (int i=0;i<unset.field_count();i++) {

UnknownField filed = unset.field(i);

printf("UnknownField %d",filed.varint());

}

}

}

int main(int argc, char *argv[])

{

vector<string> v;

v.push_back("../protocol");

v.push_back("../include");

AddSearchPath(v);

AddMsgDesc("gate.pb/gate.proto");

AddMsgDesc("rank.pb/rank.proto");

AddMsgDesc("immortaldb.pb/immortaldb.proto");

AddMsgDesc("dbproxy.pb/dbproxy.proto");

AddMsgDesc("online.pb/online.proto");

AddMsgDesc("login.pb/login.proto");

SendGsRandomMessage();

return 0;

}
</pre>