//
//??main.cpp
//??ProtoBuf
//
//??Created?by?yangdamin?on?3/25/15.
//??Copyright?（c）?2015?yangdamin.?All?rights?reserved.
//

#include?
#include?
#include?
#include?

#include?“person.pb.h“
#include?“test.pb.h“

using?namespace?std;

class?ProtoMsgHandle
{
????public:
????/*??注冊消息處理函數?*/
????void????initHandles（）
????{
????????registerHandle（&ProtoMsgHandle::handleProtoPerson）;
????????registerHandle（&ProtoMsgHandle::handleProtoTest）;
????}
????
????/*??處理網絡消息
?????*??data?為一個完整的數據包
?????*/
????void????handle（const?char*?data）
????{
????????bool?ret?=?false;
????????
????????const?char?*?current=data;
????????
????????//在網絡上傳輸的一個數據包總長度
????????int?packetLength=0;
????????
????????//從第一個位置上獲取到數據包總長度
????????memcpy（&packetLength?data?sizeof（int32_t））;
????????
????????//指針后移
????????current+=sizeof（int32_t）;
????????
????????//Message名字的長度
????????int?protoNameLength=0;
????????
????????//從第二個位置上獲取Message的名字的長度
????????memcpy（&protoNameLength?current?sizeof（int32_t））;
????????
????????//指針后移
????????current+=sizeof（int32_t）;
????????
????????//從第三個位置上獲取Message的名字
????????string?name（currentprotoNameLength）;
????????
????????//指針后移
????????current+=protoNameLength;
????????
????????//取得Message的字節數
????????int?messageSize=packetLength-（sizeof（int32_t）+sizeof（int32_t）+protoNameLength）;
????????
????????do{
????????????
????????????msg_handle?callback?=?m_callbacks[name];
????????????
????????????assert（callback?!=?NULL）;
????????????
????????????if（callback?==?NULL）
????????????{
????????????????std::cout<<“proto?“<????????????????break;
????????????}
????????????const?::google::protobuf::Descriptor*?descriptor?=?m_descriptors[name];
????????????assert（descriptor?!=?NULL）;
????????????if（descriptor?==?NULL）
????????????{
????????????????std::cout<<“proto?“<riptor“<????????????????break;
????????????}
????????????const?google::protobuf::Message*?prototype?=?google::protobuf::MessageFactory::generated_factory（）->GetPrototype（descriptor）;
????????????assert（prototype?!=?NULL）;
????????????if（prototype?==?NULL）
????????????{
????????????????std::cout<<“proto?“<????????????????break;
????????????}
????????????google::protobuf::Message*?msg?=?prototype->New（）;
????????????ret?=?msg->ParseFromArray（currentmessageSize）;
????????????if（ret）
????????????{
????????????????（this->*callback）（msg）;
????????????}
????????????else
????????????{
????????????????std::cout<<“proto?“<????????????}
?????????
????????}while（0）;
????}
private:
????void?handleProtoTest（test*?test）
????{
????????cout?<<“test->price（）=“<price（）?<????????cout?<userid（）=“<userid（）?<????????cout?<time（）=“<time（）?<????}
????void?handleProtoPerson（person*?person）
????{
????????cout?<age（）=“<age（）?<????????cout?<