标题: 分享个自己写的自定义串口协议 附单片机代码 [打印本页]
作者: 范莉萍    时间: 2024-6-12 11:07
标题: 分享个自己写的自定义串口协议 附单片机代码
最近在写一个通过手控器控制设备动作的程序，手控器按键较多，所以通过串口来和外设设备进行通信，由于命令较多，所以做了个小协议以后也能用到，可做主机可做从机，适合近距离单机通讯，第二位功能码可做地址组成多机通讯，但最好加上校验位。新手入门，大佬请多多指教
附上代码
  1. //自定义串口发送协议 例:68 01 00 03 FF ,除去包头包尾，中间为 功能码，数据1，数据2
  2. // 发送数据包函数  功能码，第一位数据，第二位数据
  3. void SendDataPacket(uint8_t function, uint8_t data1, uint8_t data2) {  
  4.     // 发送包头  
  5.     USART1_SendData(PACKET_HEADER);  
  6.       
  7.     // 发送功能码  
  8.     USART1_SendData(function);  
  9.       
  10.     // 发送数据1和数据2  
  11.     USART1_SendData(data1);  
  12.     USART1_SendData(data2);  
  13.       
  14.     // 发送包尾  
  15.     USART1_SendData(PACKET_TAILER);  
  16. }


  19. void Anlsy_Data(uint8_t function, uint8_t data1, uint8_t data2)//所有按键接收解析在这里写
  20. {
  21.     if(function == KEY_STAUS)
  22.     {
  23.         SysChenyuan.mark = QX_MARK;
  24.     switch(data2)
  25.         {
  26.         case KEY1:
  27.             SysChenyuan.Uart_Comd = QX1;
  28.             printf("清洗1按键按下，data2 = %02d,function = %02d", data2, function);
  29.             break;
  30.         case KEY2:
  31.                         SysChenyuan.Uart_Comd = QX2;
  32.             printf("清洗2按键按下，data2 = %02d,function = %02d", data2, function);
  33.             break;
  34.         case KEY3:
  35.                         SysChenyuan.Uart_Comd = QX3;
  36.             printf("清洗3按键按下，data2 = %02d,function = %02d", data2, function);
  37.             break;
  38.                 case KEY_STOP:
  39.                         SysChenyuan.all_stopped = YES;//停止标志
  40.             printf("停止按键按下，data2 = %02d,function = %02d", data2, function);
  41.             break;
  42.                 case KEY_CHONGSHUI:
  43.                         SysChenyuan.QiTa = CHONGSHUI;//冲水标志
  44.             printf("冲水按键按下，data2 = %02d,function = %02d", data2, function);
  45.             break;
  46.                 case KEY_HONGGAN:
  47.                         SysChenyuan.QiTa = HONGGAN;//烘干标志
  48.             printf("烘干按键按下，data2 = %02d,function = %02d", data2, function);
  49.             break;
  50.         default:
  51.             // 处理未知按键情况
  52.             break;
  53.     }
  54.     }
  55. }
  56. extern uint8_t Serial_Rx3Flag,time_out3,time_out3_flag;
  57. // 解析数据包的函数  
  58. int ParseDataPacket(void) {  
  59.     static uint8_t expectingHeader = 1; // 标记是否正在等待包头  
  60.     static uint8_t packetIndex = 0, i = 0; // 当前数据包内的索引  
  61.     uint8_t function, data1, data2;   

  63.         if(Serial_Rx3Flag == 1)
  64.         {
  65.             time_out3 = 0;
  66.             time_out3_flag = 0;
  67.             // 遍历缓冲区中的所有数据（在实际情况中，你可能只处理新接收到的数据）  
  68.             for ( i = 0; i < rxIndex; ++i) {  
  69.                     if (expectingHeader) {  
  70.                             if (rxBuffer[i] == PACKET_HEADER) {  
  71.                                     expectingHeader = 0; // 找到了包头，开始解析数据包  
  72.                                     packetIndex = 0; // 重置数据包索引  
  73.                             }  
  74.                             // 如果不是包头，则忽略该字节或进行错误处理  
  75.                     } else {  
  76.                             switch (packetIndex) {  
  77.                                     case 0: // 功能码  
  78.                                             function = rxBuffer[i];  
  79.                                             break;  
  80.                                     case 1: // 数据1  
  81.                                             data1 = rxBuffer[i];  
  82.                                             break;  
  83.                                     case 2: // 数据2  
  84.                                             data2 = rxBuffer[i];  
  85.         
  86.                                             // 检查包尾  
  87.                                             if (rxBuffer[i+1] == PACKET_TAILER) {  
  88.                                                     // 完整的数据包已接收，可以处理数据  
  89.                                                 Anlsy_Data(function, data1, data2);
  90.                                                     // processPacket(function, data1, data2);  
  91.                                                    
  92.                                                     // 重置状态以接收下一个数据包  
  93.                                                     expectingHeader = 1;  
  94.                                                     packetIndex = 0;  
  95.                                                     rxIndex = 0; // 清除缓冲区（或者只清除已处理的部分）  
  96.                                             } else {  
  97.                                                     // 没有找到包尾，可能是数据损坏或丢失，进行错误处理  
  98.                                                     // TODO: 错误处理代码  
  99.                                                     expectingHeader = 1; // 重置状态以接收下一个数据包  
  100.                                                     packetIndex = 0;  
  101.                                             }  
  102.                                             break;  
  103.                                     default:  
  104.                                             // 无效的数据包索引，进行错误处理  
  105.                                             expectingHeader = 1; // 重置状态以接收下一个数据包  
  106.                                             packetIndex = 0;  
  107.                                             break;  
  108.                             }  
  109.                             if (packetIndex < 3) { // 还未到达包尾，递增索引  
  110.                                     packetIndex++;  
  111.                             }  
  112.                     }  
  113.             }  
  114.             rxIndex = 0;// 清除已处理的数据（如果rxIndex不是自动管理的）  
  115.             Serial_Rx3Flag = 0;
  116.     }  
  117.     return 0; // 返回值可以根据需要来定义，例如表示是否成功解析了一个数据包  
  118. }


  121. //下面是串口超时代码，我放在了10ms定时器里，看需要。
  122. // 定时器回调函数 10ms
  123. void vTimerCallback( TimerHandle_t xTimer )  
  124. {  
  125.     if(time_out3 < 10 && time_out3_flag == 1) {
  126.             time_out3++;
  127.     }

  129.     // 检查是否超时
  130.     if(time_out3 >= 10) {
  131.         time_out3 = 0;
  132.         time_out3_flag = 0;
  133.             // 执行超时处理，例如发送确认信息或者进行数据处理
  134.         Serial_Rx3Flag = 1;
  135.     }
  136.    
  137. }

  139. //串口中断

  141. void USART1_IRQHandler(void)
  142. {
  143.     if(USART_GetITStatus(USART1,USART_IT_RXNE)==SET)   //RXNE 标志位为1 表示可以接收数据
  144.     {
  145.         uint8_t ucReceivedChar;
  146.          // 读取接收到的字符
  147.         ucReceivedChar = USART_ReceiveData(USART1);
  148.                 if (rxIndex < RX_BUFFER_SIZE) {
  149.                     rxBuffer[rxIndex++] = ucReceivedChar;
  150.                     time_out3 = 0;
  151.                     time_out3_flag = 1;
  152.                 }
  153. //                if(Serial_Rx3Flag == 1)
  154. //                {
  155. //                    rxIndex  = 0;
  156. //                }
  157.         USART_ClearITPendingBit(USART1,USART_IT_RXNE);  //清除RXNE标志位
  158.     }
  159. }
复制代码






欢迎光临 (http://www.51hei.com/bbs/) Powered by Discuz! X3.1