### 基于Modbus协议的传感器数据采集实现方法 #### 1. Modbus协议简介 Modbus是一种广泛应用于工业自动化领域的通信协议，支持多种物理层接口（如RS-232、RS-485）以及网络层协议（如TCP/IP）。它主要分为两种类型：Modbus RTU 和 Modbus TCP。前者适用于串口通信场景，后者则用于以太网环境下的设备互联。 在工业物联网(IIoT)中，Modbus因其简单易用的特点被普遍采用来完成传感器数据的采集工作[^1]。 #### 2. 数据采集流程概述 基于Modbus协议的数据采集过程可以概括为以下几个方面： - **初始化配置** 配置Modbus主站或从站的相关参数，例如波特率、校验方式（对于RTU）、IP地址和端口号（针对TCP），以及其他特定需求设置。 - **建立连接** 对于Modbus RTU，需确保硬件线路正确无误并激活相应的UART/USART外设；而对于Modbus TCP，则要创建Socket链接到目标服务器。 - **请求帧构建与发送** 构造符合标准格式的功能码及其对应寄存器地址范围的消息包，并将其传递给远程节点。 - **响应解析** 收到来自对方的回答后，按照既定规则提取有效负载部分作为实际测量值展示或者进一步处理。 #### 3. 不同平台下具体实践案例分享 ##### (a). MFC + Modbus-Tcp 温湿度传感实例 此方案展示了如何借助微软基础类库(Microsoft Foundation Classes,简称MFC)，配合流行的Modbus-Tcp协议去获取指定型号(RS-WS-ETH-6系列)温湿度感应装置所记录下来的数值信息[^2]。 以下是简化版的核心代码片段： ```cpp // 初始化客户端套接字 CClientSocket sock; sock.Connect(_T("192.168.1.10"), 502); BYTE request[] = { /* 构建查询命令 */ }; int nSentBytes = sock.Send(request, sizeof(request)); if(nSentBytes != SOCKET_ERROR){ BYTE response[256]; int nRecvBytes = sock.Receive(response, sizeof(response)); if(nRecvBytes > 0){ float temperature = ParseTemperatureFromResponse(response); CString strTemp; strTemp.Format(_T("%.2f°C"), temperature); SetDlgItemText(IDC_STATIC_TEMP, strTemp); } } ``` ##### (b). STM32嵌入式开发板搭配RS485总线接入液压感测单元示范 在这个例子当中，我们选用意法半导体推出的高性能微控制器——STM32F103ZE为核心处理器件，结合具备RS485电气特性的液位探测仪器共同搭建了一套完整的解决方案[^3]。 值得注意的是，在这里为了简化逻辑控制结构，特别设计了一种自动切换接收状态跟发射状态机制，从而避免频繁手动干预可能带来的错误风险。 下面是关键部位摘录： ```c void UART_Init(void){ GPIO_InitTypeDef GPIO_InitStruct = {0}; USART_InitTypeDef USART_InitStruct = {0}; RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOA | RCC_APB2Periph_USART1, ENABLE); // 设置PA9为TX引脚 PA10为RX引脚 GPIO_InitStruct.GPIO_Pin = GPIO_Pin_9|GPIO_Pin_10; GPIO_InitStruct.GPIO_Mode = GPIO_Mode_AF_PP; GPIO_InitStruct.GPIO_Speed = GPIO_Speed_50MHz; GPIO_Init(GPIOA,&GPIO_InitStruct); USART_InitStruct.USART_BaudRate = 9600; USART_InitStruct.USART_WordLength = USART_WordLength_8b; USART_InitStruct.USART_StopBits = USART_StopBits_1; USART_InitStruct.USART_Parity = USART_Parity_No ; USART_InitStruct.USART_HardwareFlowControl = USART_HardwareFlowControl_None; USART_InitStruct.USART_Mode = USART_Mode_Rx | USART_Mode_Tx; USART_Init(USART1,&USART_InitStruct); } uint8_t modbus_read_holding_registers(uint8_t slave_id,uint16_t start_addr,uint8_t quantity,uint16_t *data_ptr){ uint8_t tx_buffer[8],rx_buffer[256]; uint16_t i=0,j=0,k=0,l=0,m=0,n=0,o=0,p=0,q=0,r=0,s=0,t=0,u=0,v=0,w=0,x=0,y=0,z=0; memset(tx_buffer,0,sizeof(tx_buffer)); memset(rx_buffer,0,sizeof(rx_buffer)); tx_buffer[0]=slave_id;// 设备ID tx_buffer[1]=0x03 ; // 功能码 - 读保持寄存器 tx_buffer[2]=(start_addr>>8)&0xFF; tx_buffer[3]=start_addr&0xFF; tx_buffer[4]=(quantity>>8)&0XFF; tx_buffer[5]=quantity&0XFF; Calculate_CRC(&tx_buffer[0],6,(unsigned char*)&tx_buffer[6]); HAL_UART_Transmit(&huart1,tx_buffer,8,HAL_MAX_DELAY); HAL_Delay(100); HAL_UART_Receive(&huart1,rx_buffer,((quantity*2)+5),HAL_MAX_DELAY); memcpy(data_ptr,&rx_buffer[3],sizeof(*data_ptr)*quantity); return rx_buffer[2]/2; } ``` ##### (c). Python环境下通用型多任务并发框架举例说明 最后再来看一段利用Python语言编写的跨平台兼容性强的应用程序样本，它可以同时满足周期性轮询多个不同种类感知元件的要求之外还能即时响应来自外部的人机交互动作指令[^4]。 下面给出一小段伪代码供参考学习之用： ```python import threading,time,socketstruct class SensorPoller(threading.Thread): def __init__(self,target_ip,port,function_code,start_address,count): super().__init__() self.target_ip=target_ip self.port=port self.function_code=function_code self.start_address=start_address self.count=count def run(self): while True: try: with socket.socket(socket.AF_INET,socket.SOCK_STREAM) as s: s.connect((self.target_ip,self.port)) payload=[device_identifier, function_code, ((self.start_address >> 8 ) & 0xff), (self.start_address & 0xff ), ((self.count >> 8 ) & 0xff), (self.count & 0xff )] crc_value=crc_modbus(payload[:-2]) payload.extend(crc_value) s.send(bytes(payload)) reply=s.recv(buffer_size) parsed_data=parse_reply(reply) time.sleep(interval_in_seconds) except Exception as e: print(f'Error occurred during polling:{e}') def main(): threads=[] devices=[ ('192.168.1.1',502,3,0,10,'temperature'), ('192.168.1.2',502,3,0,10,'pressure') ] for d in devices: t=SensorPoller(d[0],d[1],d[2],d[3],d[4]) t.daemon=True t.start() threads.append(t) command_thread=threading.Thread(target=get_user_commands,args=(devices,)) command_thread.daemon=True command_thread.start() for t in threads: t.join() if __name__=='__main__': main() ``` 以上三个典型范例分别代表了桌面级GUI应用、单片机固件工程以及现代高级动态解释执行环境中各自独特的风格特点和技术要点。 ---