PSM：协议状态机(Protocol State Machine)，一款用于流式传输的数据协议解析组件

typedef struct psm psm_t;
struct psm
{
	uint8_t* buf;                     // 指向数据缓存
	uint32_t bufsize;                 // 数据缓存大小

	uint32_t wpos;                    // 写指针
	uint32_t rpos;                    // 读指针

	uint32_t match_start;             // 数据匹配索引

	psm_state_t state;                // 当前协议状态机的状态

	int (*recv_callback)(psm_t* psm, const void* buf, uint32_t len);  // 数据回调函数

	uint8_t  delimiter[4];             // 协议尾分隔符
	uint32_t delimiter_bytes;          // 协议尾分隔符长度
	uint32_t delimiter_index;          // 协议尾分隔符匹配索引

	uint8_t  identifier[4];            // 协议头标识符
	uint32_t identifier_bytes;         // 协议头标识符长度
	uint32_t identifier_index;         // 协议头标识符匹配索引

	uint32_t body_offset;              // 主体数据偏移地址
	uint32_t body_length;              // 主体数据长度

	uint32_t length_field_offset;                 // 长度字段偏移地址
	uint32_t length_field_bytes;                  // 长度字段所占字节数
	psm_unpack_coding_t length_field_coding;      // 长度字节编码方式

	void* arg;                                    // 可用于携带附加参数
};

int psm_recv(psm_t* psm, const void* buf, uint32_t len);
int psm_recv_byte(psm_t* psm, uint8_t c);
void psm_reset(psm_t* psm);
int psm_unpack(psm_t* psm);

psm_t psm_usart =
{
	...
	...
	...
	...
};

void UART1_IRQHandler(void)
{
	static uint8_t RxData;
	...
	psm_recv_byte(&psm_usart, RxData);  // 接收一个字节
	...
}

int main()
{
	...
	...
	...

	while (1)
	{
		psm_unpack(&psm_usart);  // 解析
	}
}

void UART1_IRQHandler(void)
{
	static uint8_t RxData;
	...
	psm_recv_byte(&psm_usart, RxData);  // 接收一个字节
	psm_unpack(&psm_usart);  // 解析
	...
}

int recv_callback(psm_t * psm, const void* buf, uint32_t len)
{
	// 在此函数中对完整的数据包进行使用
	return 0;
}

uint8_t buffer[512];

psm_t psm =
{
	.buf                = buffer,
	.bufsize            = sizeof(buffer),

	.recv_callback      = recv_callback,

	.delimiter[0]       = '\r',  // 结束符第一个字节
	.delimiter[1]       = '\n',  // 结束符第二个字节
	.delimiter_bytes    = 2,     // 结束符大小
};

psm_t psm =
{
	.buf              = buffer,
	.bufsize          = sizeof(buffer),

	.recv_callback    = recv_callback,

	.identifier[0]    = 0XB0,  // 包头低字节
	.identifier[1]    = 0XA1,  // 包头高字节
	.identifier_bytes = 2,     // 包头的大小

	.length_field_bytes  = 2,  // 协议头中数据长度字段的大小
	.length_field_offset = 4,  // 协议头中数据长度字段的位置偏移
	.length_field_coding = PSM_UNPACK_ENCODE_BY_LITTEL_ENDIAN,   // 编码方式：小端

	.body_offset = 8,  // 主体数据的位置偏移
};

psm_t psm =
{
	.buf              = buffer,
	.bufsize          = sizeof(buffer),

	.recv_callback    = recv_callback,

	.identifier[0]    = 0XAA,  // 包头低字节
	.identifier[1]    = 0X55,  // 包头高字节
	.identifier_bytes = 2,     // 包头的大小

	.delimiter[0]     = 0X55,  // 包尾低字节
	.delimiter[1]     = 0XAA,  // 包尾高字节
	.delimiter_bytes  = 2,     // 包尾的大小
};