1

我用 PB 创建我的 RPC 协议，例如：

enum EMessages {
  E_MSG_METHOD_CONNECT = 0x8001,
  E_MSG_EVENT_CONNECT  = 0xA001,
 ...
}

struct MsgHeader {
  required int32  sessionRef    = 1;
  required int32  transactionId = 2;
  required int32  status        = 3;
}

struct MSG_METHOD_CONNECT {
  optional Messages    opCode  = 1 [default = E_MSG_METHOD_CONNECT];
  required MsgHeader   header  = 2;
  .. other fields ..
}

现在，我定义了一个接口和一个模板类来添加一个间接级别：

class IMessage {
  virtual INT     getOpCode() = 0;
  virtual STRING  getName() = 0;
  virtual size_t  getSize() = 0;
  virtual INT     SerializeToString(STRING& out) = 0;
  virtual INT     ParseFromString(STRING& in) = 0;
  ....
}

template<class MESSAGE>
class IMessageImpl : public IMessage {
  protected:
    MESSAGE   m_Message;  ///< The Message Implementation
  public:
    virtual MESSAGE&  getMessage() = 0;
};

我会将它用作：

IMessageImpl<MSG_METHOD_CONNECT> MsgConnect;

现在，当我从端点接收数据时，我当然需要根据消息 opCode 反序列化它。
阅读这篇文章我正在考虑使用像 boost::mpl::map 这样的类型映射，但是由于我从不使用它，所以我正在寻找一些建议。

<< ------------ [编辑] --------- --- >>

关于上面的代码，我尝试按以下方式对其进行编码：

template<class MESSAGE>
class PBMessage : public IMessageImpl<MESSAGE>
{
public:
  PBMessage() {};
  /* ... other methods ... */
};


// Map of types. The key is the Message opCode
typedef typename mpl::map< mpl::pair<mpl::int_[100], PBMessage<MSG_METHOD_CONNECT> >, 
                           mpl::pair<mpl::int_[101], PBMessage<MSG_EVENT_CONNECT> >,
                         > TMessageMap;

// The Message type
template < typename MessageMap, int opCode >
typedef typename mpl::at<MessageMap, mpl::int_<opCode> >::type::value  TMessage;

而且，为了从接收到的缓冲区创建消息，我尝试编写代码（将其作为伪代码）：

  class PBMessageFactory : public IMessageFactory {
  public:
    IMessage* createMessage(CHAR* buff, UINT size) {
      int opCode = buff[0]; 
      TMessage<TMessageMap, opCode> msg;
      msg.ParseFromString( STRING(buff) );
    }        
  };

但是没有成功...有没有人可以给我一些建议如何从 mpl::map 中检索类型？

谢谢，
丹尼尔。

4

0 回答 0