MOOON分布式消息结构

MOOON主要消息结构如下，缺点是消息本身占用字节数较多：

点击(此处)折叠或打开

/***

  * 分布式消息头结构

  */

typedef struct TDistributedMessage

{

    net::common_message_header header; // 消息头

    nuint32_t flags; // 标志字段

    nuint32_t source_ip[IP_BYTES]; // 消息源的IP地址，如果是IPV4地址，则N值为1，否则为4

    nuint32_t destination_ip[IP_BYTES]; // 消息目的地的IP地址，如果是IPV4地址，则N值为1，否则为4

    nuint16_t source_port; // 消息源的端口号

    nuint16_t destination_port; // 消息目的地的端口号

    nuint32_t source_service_id; // destination_Service ID

    nuint32_t destination_service_id; // 消息目的地的Service ID

    nuint32_t source_session_id; // destination_Session ID

    nuint32_t destination_session_id; // 消息目的地的Session ID

    nuint32_t source_sequence_number; // 序列号，从0开始，依次递增，直到重来，用于解决类似于TCP中的timed_wait问题

    nuint32_t destination_sequence_number; // 序列号，从0开始，依次递增，直到重来，用于解决类似于TCP中的timed_wait问题

    nuint32_t source_thread_affinity; // 线程亲和值，为的是和线程建立绑定关系

    nuint32_t destination_thread_affinity; // 线程亲和值，为的是和线程建立绑定关系

    char data[0]; // 消息内容

    std::string to_string() const;

}distribted_message_t;

通信示意图：