基于STM32MP157的工业网关实战：Modbus RTU转MQTT协议转换器设计

摘要

本教程详解基于STM32MP157双核处理器的工业物联网网关开发，实现Modbus RTU设备数据采集、协议转换及MQTT云端通信。包含Linux驱动配置、协议栈移植、数据转换逻辑及压力测试方案，提供完整代码和部署指南（约6500字）。

一、项目架构设计

硬件连接示意图

传感器 <--RS485--> STM32MP157 <--Ethernet--> 云端 │ │ └--UART4--┘ └--ETH1--┘

二、开发环境搭建

关键组件版本：

• Buildroot 2022.02
• arm-none-linux-gnueabihf-gcc 9.3
• Linux kernel 5.10

系统配置命令：

# 启用UART和ETH驱动makemenuconfig>Kernel: Device Drivers ->Character devices ->STM32 USART support[*]>Networking support ->Ethernet driver support ->STMicroelectronics STMMAC[*]

三、Modbus驱动实现

文件：modbus_driver.c

#include<modbus/modbus.h>#defineMODBUS_SLAVE_ID1#defineUART_DEV"/dev/ttySTM4"modbus_t*init_modbus_rtu(){modbus_t*ctx=modbus_new_rtu(UART_DEV,// 串口设备115200,// 波特率'N',// 无校验8,// 数据位1// 停止位);if(ctx==NULL){fprintf(stderr,"RTU上下文创建失败\n");returnNULL;}// 设置从机地址modbus_set_slave(ctx,MODBUS_SLAVE_ID);// 设置响应超时（秒+微秒）structtimevaltimeout={1,0};modbus_set_response_timeout(ctx,&timeout);if(modbus_connect(ctx)==-1){fprintf(stderr,"Modbus连接失败: %s\n",modbus_strerror(errno));modbus_free(ctx);returnNULL;}returnctx;}intread_holding_regs(modbus_t*ctx,intaddr,uint16_t*dest){returnmodbus_read_registers(ctx,addr,1,dest);// 读取单个寄存器}

四、MQTT客户端开发

文件：mqtt_client.c

#include<MQTTClient.h>#defineBROKER_URL"tcp://192.168.1.100:1883"#defineCLIENT_ID"stm32_gateway_01"#defineQOS1volatileMQTTClient_deliveryToken deliveredtoken;voidconnlost(void*context,char*cause){printf("连接丢失: %s\n",cause);// 自动重连逻辑reconnect_client(context);}intmsgarrvd(void*context,char*topicName,inttopicLen,MQTTClient_message*message){// 消息回调（本网关无需订阅）MQTTClient_freeMessage(&message);MQTTClient_free(topicName);return1;}MQTTClientcreate_mqtt_client(){MQTTClient client;MQTTClient_create(&client,BROKER_URL,CLIENT_ID,MQTTCLIENT_PERSISTENCE_NONE,NULL);MQTTClient_connectOptions conn_opts=MQTTClient_connectOptions_initializer;conn_opts.keepAliveInterval=60;conn_opts.cleansession=1;// 设置回调MQTTClient_setCallbacks(client,NULL,connlost,msgarrvd,NULL);intrc;if((rc=MQTTClient_connect(client,&conn_opts))!=MQTTCLIENT_SUCCESS){fprintf(stderr,"MQTT连接失败: %d\n",rc);returnNULL;}returnclient;}voidpublish_sensor_data(MQTTClient client,constchar*topic,floatvalue){charpayload[50];snprintf(payload,sizeof(payload),"{\"sensor_value\":%.2f}",value);MQTTClient_message pubmsg=MQTTClient_message_initializer;pubmsg.payload=payload;pubmsg.payloadlen=(int)strlen(payload);pubmsg.qos=QOS;pubmsg.retained=0;MQTTClient_deliveryToken token;MQTTClient_publishMessage(client,topic,&pubmsg,&token);}

五、协议转换核心逻辑

数据映射表示例

文件：gateway_main.c

#include"data_mapper.h"// 线程函数：Modbus轮询void*modbus_poll_thread(void*arg){modbus_t*ctx=init_modbus_rtu();MQTTClient mqtt_client=create_mqtt_client();while(1){for(inti=0;i<MAPPING_ENTRIES;i++){uint16_traw_data;if(read_holding_regs(ctx,mapping_table[i].modbus_addr,&raw_data)>0){floatconverted=raw_data*mapping_table[i].scale_factor;// 推送到消息队列SensorData data={.topic=mapping_table[i].mqtt_topic,.value=converted};mq_send(data_queue,&data,sizeof(data),0);}}sleep(1);// 1秒采集周期}}// 线程函数：MQTT发布void*mqtt_pub_thread(void*arg){MQTTClient client=create_mqtt_client();SensorData data;while(1){if(mq_receive(data_queue,&data,sizeof(data),0)>0){publish_sensor_data(client,data.topic,data.value);}}}

六、系统测试方案

压力测试结果

七、完整技术图谱

常见问题处理：

1. 串口数据乱码

   stty -F /dev/ttySTM4 raw115200# 检查终端配置

2. MQTT频繁断连
   添加心跳检测机制：

   conn_opts.keepAliveInterval=15;// 15秒心跳