MmCp 我的信息通讯控制协议 V1.0

Question

/*
MmCp 我的信息通讯控制协议 V1.0
一、目的：作为低层的信息传输控制协议，保证信息传输的完整性和不被篡改
二、结构：
1、4字节HEAD FLAG:0x0D, 0x0D, 0x03, 0x10(即Ctrl+"MMCP"的ASCII码)
2、2字节版本:0x01,0x00(表示V01.00)(也可用一字节作为加密的key index)
3、2字节信息长度（下面第6部分信息块的长度):网络顺序,
   可用htons(),ntohs()处理
4、4字节CRC32(下面第6部分的CRC32):网络顺序,
   可用htonl(),ntohl()处理
5、4字节保留:目前填0x00000000(也可以保存前面CRC32的加密结果)
6、N字节信息块:1<=N<=0xFFFF
使用网络顺序是为了保证在异构机器通讯的时候可以用同一段程序，
不必关心它们CPU/操作系统的字节顺序的差别
*/

2. [font=新宋体]
3. #ifndef  USG_TYPE
4. # define USG_TYPE
5.   typedef unsigned char  USGC;
6.   typedef unsigned short USGS;
7.   typedef unsigned int   USGI;
8.   typedef unsigned long  USGL;
9. #endif
11. char gc_MmCp_HeadFlag[4] = {0x0D, 0x0D, 0x03, 0x10};
12. char gc_MmCp_Ver1[2] = {0x01, 0x00};
14. #ifndef MMCP_STRUCT_V1
15. #define MMCP_STRUCT_V1          1
16. struct MmCp_V1
17. {
18.   char HeadFlag[4];
19.   char Ver[2];
20.   USGS MsgLen;
21.   USGL CRC32;
22.   char Resv[4];
23. };
24. #endif
27. /* ------------------------------------------------------------------------- */
28. int  MmCp_Send(int sock, void *buf, int len_msg, int timeout_ms, int retry,
29.                int msg_code)
30. /*
31.    使用MmCp协议发送信息
33.    参数：
34.    sock: socket handle
35.    buf: msg buffer to be sent
36.    len_msg: msg length
37.    timeout_ms: timeout msec
38.    retry: retry number
39.    msg_code: ASCII_CODE or EBCDIC_CODE
41.    Return: <0  --- error
42.            >=0 --- send msg len
43. */
44. {
45.   struct MmCp_V1 MCB; /* msg control block */
46.   int  n_send = 0, rc;
47.   USGS MsgLen;
48.   USGL CRC32;
50.   MsgLen = len_msg;
51.   CRC32 = CalculateStringCRC32(buf, MsgLen);
52.   memmove(MCB.HeadFlag, gc_MmCp_HeadFlag, sizeof(gc_MmCp_HeadFlag));
53.   memmove(MCB.Ver, gc_MmCp_Ver1, sizeof(gc_MmCp_Ver1));
54.   MCB.MsgLen = htons(MsgLen);
55.   MCB.CRC32 = htonl(CRC32);
57.   rc = SendMsg(sock, (USGC *)&MCB, sizeof(MCB),
58.                timeout_ms, retry, msg_code, &n_send);
59.   if(rc != sizeof(MCB))
60.     return LogErrPos(rc, 0, __FILE__, __LINE__,
61.                      "Send MCB=%d <> %d, n_send=%d",
62.                      rc, sizeof(MCB), n_send);
63.   rc = SendMsg(sock, (USGC *)buf, len_msg,
64.                timeout_ms, retry, msg_code, &n_send);
65.   if(rc != len_msg)
66.     return LogErrPos(rc, 0, __FILE__, __LINE__,
67.                      "SendMsg()=%d <> len_msg(%d), n_send=%d",
68.                      rc, len_msg, n_send);
69.   return rc;
70. }
72. /* ------------------------------------------------------------------------- */
73. int  MmCp_Recv(int sock, void *buf, USGI max_len, int timeout_ms, int retry,
74.                int msg_code)
75. /*
76.    使用MmCp协议接收信息
78.    参数：
79.    sock: socket handle
80.    buf: buffer for receive msg
81.    max_len: receive max length
82.    timeout_ms: timeout msec
83.    retry: retry number
84.    msg_code: ASCII_CODE or EBCDIC_CODE
86.    Return: <0 --- error
87.            >0 --- recv msg len
88.            =0 --- timeout
89. */
90. {
91.   struct MmCp_V1 MCB; /* msg control block */
92.   int  n_recv = 0, rc;
93.   USGS MsgLen;
94.   USGL CRC32;
96.   rc = RecvMsg(sock, (USGC *)&MCB, sizeof(MCB), sizeof(MCB),
97.                timeout_ms, retry, msg_code, &n_recv);
98.   WrtLog("!!- %s, @MmCp_Recv: recv MCB rc=%d, n_recv=%dn", NOW(), rc, n_recv);
99.   if(rc == 0)
100.     return LogErrPos(GAE_SELECT_TIMEOUT, 0, __FILE__, __LINE__,
101.                      "recv MCB timeout");
102.   if(rc < 0)
103.     return LogErrPos(rc, 0, __FILE__, __LINE__, "recv MCB error");
104.   if(rc != sizeof(MCB))
105.     return LogErrPos(GAE_RECV, 0, __FILE__, __LINE__,
106.                      "recv MCB rc <> %d", sizeof(MCB));
107.   if(memcmp(MCB.HeadFlag, gc_MmCp_HeadFlag, sizeof(gc_MmCp_HeadFlag)) != 0)
108.     return LogErrPos(GAE_RECV, 0, __FILE__, __LINE__, "error MmCp_HeadFlag!");
109.   MsgLen = ntohs(MCB.MsgLen);
110.   CRC32 = ntohl(MCB.CRC32);
111.   if(MsgLen > max_len)
112.     return LogErrPos(GAE_RECV, 0, __FILE__, __LINE__,
113.                      "MsgLen(%d) > max_len(%d)!", MsgLen, max_len);
115.   rc = RecvMsg(sock, (USGC *)buf, MsgLen, MsgLen,
116.                timeout_ms, retry, msg_code, &n_recv);
117.   WrtLog("!!- %s, @MmCp_Recv: recv msg body, rc=%d, n_recv=%dn",
118.          NOW(), rc, n_recv);
119.   if(rc == 0)
120.     return LogErrPos(GAE_SELECT_TIMEOUT, 0, __FILE__, __LINE__,
121.                      "recv msg body timeout");
122.   if(rc < 0)
123.     return LogErrPos(rc, 0, __FILE__, __LINE__, "recv msg body error");
124.   if(rc != MsgLen)
125.     return LogErrPos(GAE_RECV, 0, __FILE__, __LINE__,
126.                      "recv msg body rc <> MsgLen(%d)", MsgLen);
127.   if(CRC32 != CalculateStringCRC32(buf, MsgLen))
128.     return LogErrPos(GAE_RECV, 0, __FILE__, __LINE__, "CRC32 check error!");
129.   return rc;
130. }[/font]

复制代码

Answer 1

谢谢！
在32位机器没问题
在64位机器（HP-UX、AIX等）需要修改

Answer 2

你的结构体定义时没有对齐，有问题的。