MOOON分布式消息结构

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

// 为何要做IPV4和IPV6区分？
// 是因为如果只需要支持IPV4，则一个IP地址只需要用一个4字节表示，
// 这样源和目的IP地址共节省了24字节；
// 支持IPV6时，同时兼容IPV4，但对于IPV4多浪费24字节；
// 源和目标IP，要么都为IPV4，要么都为IPV6，不允许交叉出现。
#ifdef IPV6_SUPPORTED
    #define IP_BYTES (4*4) // IPV6的地址长度
#else
    #define IP_BYTES 4     // IPV4的地址长度
#endif     

////////////////////////////////////////////////////////////////////////////////
SCHED_NAMESPACE_BEGIN     

/***
  * 常量定义
  */
enum
{
    INVALID_SERVICE_ID = 0,
    INVALID_SESSION_ID = 0,  // 无效的SessionId
    SERVICE_ID_MAX = 100,    // 最大的Service ID值，取值从1开始
    SESSION_ID_MAX = 10000   // 最大的Session ID值，取值从1开始
};     

// 按4字节对齐
#pragma pack(4)     

/***
  * 分布式消息Flags结构
  * 为什么Flags要单独定义成一个struct，
  * 是因为nuint32_t类型不支持位表达方式，
  * 所以使用struct做一层转换，以达到相同的目的
  */
typedef struct TDistributedMessageFlags
{
    // 使用union，方便操作
    union Flags
    {
        uint32_t flags;
        struct TFlagsBits
        {
            uint32_t ip_type:1;      // IP地址类型，取值为net::IP_TYPE_4或net::IP_TYPE_6
            uint32_t reserved:31;    // 保留用的位
        }flags_bits;
    }flags;     

    TDistributedMessageFlags(uint32_t v)
     :flags(v)
    {
    }
}distribted_message_flags_t;     

/***
  * 分布式消息头结构
  */
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;

#pragma pack()

inline bool is_valid_service(uint32_t service_id)
{
    return service_id > 0
        && service_id <= SERVICE_ID_MAX;
}

inline bool is_valid_session(uint32_t session_id)
{
    return session_id > 0
        && session_id <= SESSION_ID_MAX;
}

////////////////////////////////////////////////////////////////////////////////
SCHED_NAMESPACE_END

示意图：

本文出自 “飞月” 博客，请务必保留此出处 http://mooon.blog.51cto.com/1246491/948302

以上是小编为您精心准备的的内容，在的博客、问答、公众号、人物、课程等栏目也有的相关内容，欢迎继续使用右上角搜索按钮进行搜索线程
， ipv4
， 地址
， 字节
， 消息
32
分布式消息中间件、分布式消息队列、分布式消息系统、java 分布式消息队列、分布式事务 消息队列，以便于您获取更多的相关知识。