午夜精品在线观看,久久久7777,一区二区三区高清不卡

用protobuf定義消息及處理

用protobuf定義消息及處理

（金慶的專欄）

消息定義：

package MsgPb;

message Msg {
required string type = 1; // Full type name of data.
required bytes data = 2; // Serialized bytes fo concrete msg.
}

消息發(fā)送代碼：

void MsgSender::Send(const std::string & sDest, const MsgPb::Msg & msg)
{
    std::string s;
   bool bSuc = msg.SerializeToString(&s);
   BOOST_ASSERT(bSuc);
   Send(sDest, s);
}

void MsgSender::Send(const std::string & sDest,
    const google::protobuf::Message & msg) const
{
   MsgPb::Msg msgSend;
   msgSend.set_type(msg.GetTypeName());
   bool bSuc = msg.SerializeToString(msgSend.mutable_data());
   BOOST_ASSERT(bSuc);
   Send(sDest, msgSend);
}

消息接收后分發(fā)：

void HandleOneMsg(const string & sFrom, const string & sMsg)
{
   MsgPb::Msg msg;
   bool bSuc = msg.ParseFromString(sMsg);
   if (!bSuc) return;
   MsgDispatcher::Dispatch(sFrom, msg);
}

void MsgDispatcher::Dispatch(const string & sFrom, const MsgPb::Msg & msg)
{
   HandlerMap::const_iterator itr = s_mapHandlers.find(msg.type());
   if (itr == s_mapHandler.end()) return;
   MsgPb::GoogleMsgPtr pMsg = MsgPb::ParseMsg(msg.type(), msg.data());
   if (pMsg)
       (*itr).second(sFrom, *pMsg);
}

消息解析：

typedef google::protobuf::Message GoogleMsg;
typedef boost::shared_ptr<GoogleMsg> GoogleMsgPtr;

// ParseMsg.cpp
#include "ParseMsg.h"

#include <google/protobuf/descriptor.h>
#include <googlt/protobuf/message.h>

namespace {

using MsgPb::GoogleMsgPtr;
GoogleMsgPtr GreateMsg(const string & sTypeName)
{
   using namespace google::protobuf;
   const Descriptor * pDescriptor = DescriptorPool::generated_pool();
       ->FindMessageTypeByName(sTypeName);
   if (NULL == pDescriptor)
       return GoogleMsgPtr();
   const Message * pPrototype = MessageFcatory::generated_factory();
       ->GetPrototype(pDescriptor);
   if (NULL == pPrototype)
       return GoogleMsgPtr();
   return GoogleMsgPtr(pPrototype->New());
}

} // namespace

namespace MsgPb {

GoogleMsgPtr ParseMsg(const string & sTypeName, const string & sData)
{
   GoogleMsgPtr pMsg = CreateMsg(sTypeName);
   if (!pMsg) return GoogleMsgPtr();
   bool bSuc = pMsg->ParseFromString(sData);
   if (bSuc) return pMsg;
   return GoogleMsgPtr();
}

} // namespce MsgPb

注冊處理器：

void MsgDispatcher::Init()
{
   using namespace MsgPb;
   InsertHandler(LobbyRegisterMsg(), LobbyRegisterMsgHandler());
   InsertHandler(LoginMsg(), LoginMsgHandler());
   ...
}

void MsgDispatcher::InsertHandler(const MsgPb::GoogleMsg & msg,
                                   const MsgHandler & h)
{
   s_mapHandlers[msg.GetTypeName()] = h;
}

MsgPb::LoginMsg是個具體的消息。MsgPb::Msg是個消息封裝。
它們都是google::protobuf::Message的子類。

posted on 2012-08-02 18:18 金慶閱讀(6270) 評論(0) 編輯收藏引用所屬分類: 1. C/C++ 、2. 網游開發(fā)

只有注冊用戶登錄后才能發(fā)表評論。
【推薦】100%開源！大型工業(yè)跨平臺軟件C++源碼提供，建模，組態(tài)！

相關文章: How are dtLinks created in NavMesh C++ parameter passing rules Naming Conventions for Accessors Visual Studio 2019 Compiler Hangs Fbx File Format Identifier 查找內存錯誤 std::thread 中的異常會丟失調用棧用賦值代替 protobuf CopyFrom() vs2017 linux 編譯輸出改成 vs 格式為 LiteIDE 添加選中標記

網站導航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜