1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
typedef struct
{
    u8  message_Cnt;     //消息的条数
	u16 message_Leng[message_RecMax];
    u8  message[message_RecMax][message_RecLeng];       //消息缓冲区
}publish_RecDataStruct;
之所以这样定义结构体，为了方便数据的读取
void publish_RecPackAnalys(u8 *rec_Data)
{
	u8 i;
	u32 rec_DataLeng; //接受字节总长
	u32 remind_Leng = 0;  //剩余长度
	u8  remind_LengLocal = 1;   //剩余长度 在单个消息中所在当前位置
	u8  remind_LengByteCnt = 0; //剩余字节所占位数
	u16 message_Loacl;
	u8 *rec_DataBkp = rec_Data;
	
//	rec_DataLeng = 15; //测试使用
	rec_DataLeng = mqtt_RxSta & 0X7F; //得到接受数据的总长度
	do
	{
		publish_RecData.message_Cnt++;                   //统计消息的个数
		do
		{
			if(remind_LengByteCnt++)
			{
				remind_Leng += (rec_Data[remind_LengLocal] & 0X7F) * 128;
			}
			else
			{
				remind_Leng += rec_Data[remind_LengLocal] & 0X7F;
			}
		}while(rec_Data[remind_LengLocal++] >> 7);  //为 1 时执行循环，说明此时剩余字节第一位 为 1
		
		publish_RecData.message_Leng[publish_RecData.message_Cnt - 1] = 1 + remind_LengByteCnt + remind_Leng;  //计算当前消息长度
		rec_DataLeng -= publish_RecData.message_Leng[publish_RecData.message_Cnt - 1];                       //接受数据长度减去当前消息长度
		rec_Data = &rec_Data[publish_RecData.message_Leng[publish_RecData.message_Cnt - 1]];                 //rec_Data指向下一个消息的开头
		
/***********************************     为下一次循环做准备             ****************************************/
		remind_LengByteCnt = 0;
		remind_Leng = 0;
		remind_LengLocal = 1;
	}while(rec_DataLeng); //此段循环代码解析出了 消息数量，每个消息的长度
	
	rec_Data = rec_DataBkp;
	for(i = 0; i<publish_RecData.message_Cnt; i++)
	{
		memcpy(*(publish_RecData.message + i),&rec_Data[message_Loacl],publish_RecData.message_Leng[i]);
		*(*(publish_RecData.message + i)+publish_RecData.message_Leng[i]) = '';
		message_Loacl += publish_RecData.message_Leng[i];
	}	
}