单片机嵌入式字符流数据解析库

kw_charProtocol库阐明

本库针对字符数据流范例装备，吸收发送特定协议帧制作的微库。可以裸机运行，也可以共同实时操作系统运行。
本库开源连接地址：gitee连接
实现思绪

本库采用C语言进行编程，方便移植，用户通过调用库接口函数即可使用。
以[YY6500传感器]为例，对应，该传感器采用串口作为通讯接口。
重要接口函数如下：
项目函数功能备注1kw_CPInitPara初始化注册协议变量对象，包罗：
1. 异步队列数组
2. 吸收数组
3. 发送数组2kw_CPSetHead注册协议包头3kw_CPRegisterTailCB注册协议包尾4kw_CPRegisterCheckCB注册校验和回调5kw_CPRegisterFrameCB注册解完整数据包回调6kw_CPDecode周期解码7kw_CPReceiveByte吸收字符流数据 重要变量如下
项目变量范例阐明1_g_cpYY6500kw_charProtocol_s协议对象2_g_YY6500Queue吸收队列数组unsigned char[]3_g_YY6500RBuf吸收数组缓存unsigned char[]4_g_Head包头unsigned char[] 必要实现的协议接口如下：
项目接口阐明1_IsTail包尾判断2_IsCheckOK校验和判断3_frame完整数据包回调 测试代码

协议代码

1. #include "CP_YY6500.h"
3. #ifdef CONFIG_KW_CP
5. kw_charProtocol_s _g_cpYY6500;
6. unsigned char _g_YY6500Queue[128];
7. unsigned char _g_YY6500RBuf[128];
8. unsigned char _g_Head[1] = {0x16};
9. unsigned char _YY6500_Tmp[4] = {0};
10. cp_YY6500_e _g_YY6500_Flag = CP_YY6500_NONE;
12. cp_YY6500_s _g_YY6500;
14. static bool _IsTail(kw_frame_s *p, unsigned char in);
15. static bool _IsCheckOK(kw_frame_s *p);
16. static void _frame(kw_frame_s *p);
18. void CP_YY6500Init()
19. {
20.     kw_CPInitPara(&_g_cpYY6500,
21.                   _g_YY6500Queue, sizeof(_g_YY6500Queue),
22.                   _g_YY6500RBuf, sizeof(_g_YY6500RBuf),
23.                   0, 0);
24.     kw_CPSetHead(&_g_cpYY6500, _g_Head, sizeof(_g_Head));
25.     kw_CPRegisterTailCB(&_g_cpYY6500, _IsTail);
26.     kw_CPRegisterCheckCB(&_g_cpYY6500, _IsCheckOK);
27.     kw_CPRegisterFrameCB(&_g_cpYY6500, _frame);
28. }
30. void CP_YY6500Decode()
31. {
32.     kw_CPDecode(&_g_cpYY6500);
33. }
35. void CP_YY6500SendResult(cp_YY6500_e type, int (*send)(unsigned char *datas, unsigned int len))
36. {
37.     if (send != 0 && type < CP_YY6500_MAX && type > CP_YY6500_NONE)
38.     {
39.         _YY6500_Tmp[0] = 0x11;
40.         _YY6500_Tmp[1] = 0x01;
41.         if(type == CP_YY6500_RESULT)
42.         {
43.             _YY6500_Tmp[2] = 0x01;
44.             _YY6500_Tmp[3] = 0xED;
45.         }
46.         else if(type == CP_YY6500_VERSION)
47.         {
48.             _YY6500_Tmp[2] = 0x1E;
49.             _YY6500_Tmp[3] = 0xD0;
50.         }
51.         else if(type == CP_YY6500_NO)
52.         {
53.             _YY6500_Tmp[2] = 0x1F;
54.             _YY6500_Tmp[3] = 0xCF;
55.         }
56.         send(_YY6500_Tmp, 4);
57.         _g_YY6500_Flag = type;
58.     }
59. }
61. void CP_YY6500Receive(unsigned char in)
62. {
63.     kw_CPReceiveByte(&_g_cpYY6500, in);
64. }
66. static bool _IsTail(kw_frame_s *p, unsigned char in)
67. {
68.     return p->wIdx > 4 && p->wIdx == p->buf.buffer[1] + 2;
69. }
71. static bool _IsCheckOK(kw_frame_s *p)
72. {
73.     unsigned char sum = 0;
74.     for (unsigned char i = 0; i < p->wIdx - 1; i++)
75.     {
76.         sum += p->buf.buffer[i];
77.     }
79.     return (p->buf.buffer[p->wIdx - 1] + (sum)) & (0xFF) == 0xFF;
80. }
82. static void _frame(kw_frame_s *p)
83. {
84.     if (_g_YY6500_Flag == CP_YY6500_RESULT)
85.     {
86.         _g_YY6500.nongdu = (p->buf.buffer[3] << 8) + p->buf.buffer[4];
87.         _g_YY6500.liuliang = (p->buf.buffer[5] << 8) + p->buf.buffer[6];
88.         _g_YY6500.wendu = ((p->buf.buffer[7] << 8) + p->buf.buffer[8] - 500);
89.         _g_YY6500.res = (p->buf.buffer[9] << 8) + p->buf.buffer[10];
90.         _g_YY6500_Flag = CP_YY6500_NONE;
91.     }
92.     else if(_g_YY6500_Flag == CP_YY6500_VERSION)
93.     {
94.         for (unsigned char i = 0; i < 8; i++)
95.         {
96.             _g_YY6500.version[i] = p->buf.buffer[i + 3];
97.         }
98.         _g_YY6500_Flag = CP_YY6500_NONE;
99.     }
100.     else if(_g_YY6500_Flag == CP_YY6500_NO)
101.     {
102.         for (unsigned char i = 0; i < 10; i++)
103.         {
104.             _g_YY6500.NO[i] = p->buf.buffer[i + 3];
105.         }
106.         _g_YY6500_Flag = CP_YY6500_NONE;
107.     }
108. }
110. #endif

复制代码

1. #ifndef _CP_YY6500_H
2. #define _CP_YY6500_H
4. #ifdef __cplusplus
5. extern "C"
6. {
7. #endif
8. #include "kw_baseDrvCFG.h"
9. #ifdef CONFIG_KW_CP
11.     typedef enum _cp_YY6500_e
12.     {
13.         CP_YY6500_NONE,
14.         CP_YY6500_RESULT,
15.         CP_YY6500_VERSION,
16.         CP_YY6500_NO,
17.         CP_YY6500_MAX,
18.     } cp_YY6500_e;
20.     typedef struct _cp_YY6500_s
21.     {
22.         unsigned short nongdu;
23.         unsigned short liuliang;
24.         short wendu;
25.         unsigned short res;
26.         unsigned char version[8];
27.         unsigned char NO[10];
28.     } cp_YY6500_s;
30.     void CP_YY6500Init();
31.     void CP_YY6500SendResult(cp_YY6500_e type, int (*send)(unsigned char *datas, unsigned int len));
32.     void CP_YY6500Decode();
33.     void CP_YY6500Receive(unsigned char in);
35. #endif
37. #ifdef __cplusplus
38. }
39. #endif
41. #endif

复制代码

主函数调用

2. #include "CP_YY6500.h"
4. static void _hal_uartRecv(unsigned char data)
5. {
6.     CP_YY6500Receive(data);
7. }
9. void main()
10. {
11.     HAL_UARTInit();
12.     CP_YY6500Init();
13.     while (1)
14.     {
15.         CP_YY6500Decode();
16.     }
17. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。