MOOON分布式消息结构

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

1. // 为何要做IPV4和IPV6区分？ 
2. // 是因为如果只需要支持IPV4，则一个IP地址只需要用一个4字节表示， 
3. // 这样源和目的IP地址共节省了24字节； 
4. // 支持IPV6时，同时兼容IPV4，但对于IPV4多浪费24字节； 
5. // 源和目标IP，要么都为IPV4，要么都为IPV6，不允许交叉出现。 
6. #ifdef IPV6_SUPPORTED 
7.     #define IP_BYTES (4*4) // IPV6的地址长度 
8. #else 
9.     #define IP_BYTES 4     // IPV4的地址长度 
10. #endif 
11.  
12. //////////////////////////////////////////////////////////////////////////////// 
13. SCHED_NAMESPACE_BEGIN 
14.  
15. /*** 
16.   * 常量定义 
17.   */ 
18. enum 
19. { 
20.     INVALID_SERVICE_ID = 0, 
21.     INVALID_SESSION_ID = 0,  // 无效的SessionId 
22.     SERVICE_ID_MAX = 100,    // 最大的Service ID值，取值从1开始 
23.     SESSION_ID_MAX = 10000   // 最大的Session ID值，取值从1开始 
24. }; 
25.  
26. // 按4字节对齐 
27. #pragma pack(4) 
28.  
29. /*** 
30.   * 分布式消息Flags结构 
31.   * 为什么Flags要单独定义成一个struct， 
32.   * 是因为nuint32_t类型不支持位表达方式， 
33.   * 所以使用struct做一层转换，以达到相同的目的 
34.   */ 
35. typedef struct TDistributedMessageFlags 
36. { 
37.     // 使用union，方便操作 
38.     union Flags 
39.     { 
40.         uint32_t flags; 
41.         struct TFlagsBits 
42.         { 
43.             uint32_t ip_type:1;      // IP地址类型，取值为net::IP_TYPE_4或net::IP_TYPE_6 
44.             uint32_t reserved:31;    // 保留用的位 
45.         }flags_bits; 
46.     }flags; 
47.  
48.     TDistributedMessageFlags(uint32_t v) 
49.      :flags(v) 
50.     { 
51.     } 
52. }distribted_message_flags_t; 
53.  
54. /*** 
55.   * 分布式消息头结构 
56.   */ 
57. typedef struct TDistributedMessage 
58. { 
59.     net::common_message_header header;     // 消息头 
60.     nuint32_t flags;                       // 标志字段 
61.  
62.     nuint32_t source_ip[IP_BYTES];         // 消息源的IP地址，如果是IPV4地址，则N值为1，否则为4 
63.     nuint32_t destination_ip[IP_BYTES];    // 消息目的地的IP地址，如果是IPV4地址，则N值为1，否则为4 
64.  
65.     nuint16_t source_port;                 // 消息源的端口号 
66.     nuint16_t destination_port;            // 消息目的地的端口号 
67.  
68.     nuint32_t source_service_id;           // destination_Service ID 
69.     nuint32_t destination_service_id;      // 消息目的地的Service ID 
70.  
71.     nuint32_t source_session_id;           // destination_Session ID 
72.     nuint32_t destination_session_id;      // 消息目的地的Session ID 
73.  
74.     nuint32_t source_sequence_number;      // 序列号，从0开始，依次递增，直到重来，用于解决类似于TCP中的timed_wait问题 
75.     nuint32_t destination_sequence_number; // 序列号，从0开始，依次递增，直到重来，用于解决类似于TCP中的timed_wait问题 
76.  
77.     nuint32_t source_thread_affinity;      // 线程亲和值，为的是和线程建立绑定关系 
78.     nuint32_t destination_thread_affinity; // 线程亲和值，为的是和线程建立绑定关系 
79.  
80.     char data[0];                          // 消息内容 
81.  
82.     std::string to_string() const; 
83. }distribted_message_t; 
84.  
85. #pragma pack() 
86.  
87. inline bool is_valid_service(uint32_t service_id) 
88. { 
89.     return service_id > 0 
90.         && service_id <= SERVICE_ID_MAX; 
91. } 
92.  
93. inline bool is_valid_session(uint32_t session_id) 
94. { 
95.     return session_id > 0 
96.         && session_id <= SESSION_ID_MAX; 
97. } 
98.  
99. //////////////////////////////////////////////////////////////////////////////// 
100. SCHED_NAMESPACE_END 

示意图：

    本文转自eyjian 51CTO博客，原文链接：http://blog.51cto.com/mooon/948302如需转载请自行联系原作者