RT-Thread实战：小熊派上BH1750光照数据采集与MQTT上云完整流程（附源码）

小熊派BH1750光照监测系统开发全指南：从传感器到云端的数据链路构建

在物联网技术快速渗透各行各业的今天，环境监测设备的智能化改造已成为工业自动化、智慧农业和智能家居等领域的基础需求。本文将手把手带您完成一个典型的环境光照监测节点开发全流程，基于广受欢迎的RT-Thread物联网操作系统和小熊派开发板硬件平台，实现从BH1750传感器数据采集到MQTT云端上报的完整解决方案。

这个项目特别适合刚接触嵌入式物联网开发的工程师，您将学到如何将裸机传感器驱动升级为RT-Thread软件包生态中的标准化组件，掌握多线程环境下的传感器数据采集技巧，以及物联网设备中最关键的MQTT协议集成方法。我们不仅提供可直接部署的源码，更会深入解析每个环节的设计思路和调试技巧。

1. 开发环境准备与硬件连接

1.1 硬件组件清单与连接

本项目所需的核心硬件包括：

• 小熊派开发板（BearPi-HM Nano）：基于STM32L4R5ZI微控制器，内置RT-Thread Nano支持
• E53_SC1扩展板：标准E53接口的传感器扩展板，含BH1750光照传感器
• 杜邦线若干：用于必要时的硬件连接调整

BH1750传感器通过I2C总线与主控通信，在E53_SC1扩展板上默认连接如下：

提示：若使用非标准扩展板，需确认I2C引脚定义，必要时通过board.h修改引脚映射

1.2 软件环境配置

RT-Thread的强大之处在于其丰富的软件包生态，我们需要通过Env工具配置项目依赖：

# 在RT-Thread env环境中执行 menuconfig

在配置界面中依次开启以下选项：

1. Hardware Drivers Config → Enable I2C Bus Support
2. RT-Thread online packages → peripheral libraries → Enable BH1750 sensor package
3. IoT - internet of things → Enable Paho MQTT client
4. Enable SAMPLES module for demo applications

保存配置后生成新的MDK/IAR工程：

pkgs --update scons --target=mdk5

2. BH1750传感器驱动集成与调试

2.1 I2C总线初始化验证

在RT-Thread中，I2C总线以设备形式管理，首先在应用代码中初始化总线：

#define BH1750_I2C_BUS_NAME "i2c1" int bh1750_port_init(void) { struct rt_i2c_bus_device *i2c_bus; i2c_bus = rt_i2c_bus_device_find(BH1750_I2C_BUS_NAME); if (i2c_bus == RT_NULL) { rt_kprintf("Failed to find I2C bus %s!\n", BH1750_I2C_BUS_NAME); return -RT_ERROR; } rt_pin_mode(BH1750_POWER_PIN, PIN_MODE_OUTPUT); rt_pin_write(BH1750_POWER_PIN, PIN_HIGH); return RT_EOK; } INIT_APP_EXPORT(bh1750_port_init);

验证I2C总线是否正常工作的快速方法是通过i2c-tools软件包扫描设备：

msh /> i2c_scandev i2c1 [I/I2C] I2C bus [i2c1] found [I/I2C] Found device [0x23] on I2C bus [i2c1]

2.2 传感器数据采集线程实现

RT-Thread的BH1750软件包提供了标准化的传感器接口，我们创建一个独立线程周期性读取数据：

static void bh1750_read_thread_entry(void *parameter) { rt_device_t sensor = RT_NULL; struct rt_sensor_data sensor_data; sensor = rt_device_find("li_bh1750"); if (sensor == RT_NULL) { rt_kprintf("BH1750 sensor not found!\n"); return; } if (rt_device_open(sensor, RT_DEVICE_FLAG_RDONLY) != RT_EOK) { rt_kprintf("Failed to open BH1750 sensor!\n"); return; } while (1) { if (rt_device_read(sensor, 0, &sensor_data, 1) == 1) { rt_kprintf("Light intensity: %d lux\n", sensor_data.data.light); } else { rt_kprintf("Sensor read failed!\n"); } rt_thread_mdelay(2000); // 2秒采样间隔 } }

关键参数调优建议：

• 测量模式：BH1750支持0.5lx到65535lx量程，推荐初始使用BH1750_CONTINUE_H_RES_MODE
• 采样周期：根据应用场景调整，智能家居建议2-5秒，工业环境可缩短至500ms
• 数据滤波：添加简单的滑动窗口滤波提升数据稳定性

3. MQTT客户端集成与数据上报

3.1 EMQX云服务配置

我们选用EMQX作为MQTT代理服务器，其免费版完全满足开发需求。注册后创建以下关键资源：

1. 部署实例：选择就近区域的共享版实例
2. 设备认证：启用"用户名+密码"认证方式
3. 主题规划：
   • 上行主题：device/bh1750/${device_id}/uplink
   • 下行主题：device/bh1750/${device_id}/downlink

注意：生产环境应启用TLS加密，本文为简化流程使用TCP直连

3.2 MQTT客户端实现

RT-Thread的Paho MQTT软件包已做好深度适配，下面是关键实现片段：

static void mqtt_connect_callback(void *client) { rt_kprintf("MQTT connected!\n"); mqtt_subscribe(client, DOWNLINK_TOPIC); } static int mqtt_publish_light_data(int light_value) { char payload[64]; snprintf(payload, sizeof(payload), "{\"dev_id\":\"%s\",\"lux\":%d,\"ts\":%d}", DEVICE_ID, light_value, rt_tick_get()); return mqtt_publish(&client, UPLINK_TOPIC, payload, strlen(payload), 0, 0); } static void mqtt_thread_entry(void *parameter) { while (1) { if (!mqtt_client_is_connected(&client)) { mqtt_reconnect(&client); } rt_thread_mdelay(1000); } }

3.3 数据格式与QoS策略

物联网项目中数据格式设计直接影响后期处理效率，推荐采用紧凑型JSON格式：

{ "dev_id": "BP-01A23", "lux": 1250, "ts": 1634567890, "bat": 3.7, "rssi": -65 }

MQTT服务质量等级选择建议：

4. 系统优化与生产部署

4.1 低功耗设计技巧

对于电池供电的应用场景，需特别关注功耗优化：

1. 传感器工作模式：将BH1750配置为# 1. 题目

93. 复原 IP 地址

难度中等870

有效 IP 地址正好由四个整数（每个整数位于0到255之间组成，且不能含有前导0），整数之间用'.'分隔。

• 例如："0.1.2.201"和"192.168.1.1"是有效IP 地址，但是"0.011.255.245"、"192.168.1.312"和"192.168@1.1"是无效IP 地址。

给定一个只包含数字的字符串s，用以表示一个 IP 地址，返回所有可能的有效 IP 地址，这些地址可以通过在s中插入'.'来形成。你不能重新排序或删除s中的任何数字。你可以按任何顺序返回答案。

示例 1：

输入：s = "25525511135" 输出：["255.255.11.135","255.255.111.35"]

示例 2：

输入：s = "0000" 输出：["0.0.0.0"]

示例 3：

输入：s = "101023" 输出：["1.0.10.23","1.0.102.3","10.1.0.23","10.10.2.3","101.0.2.3"]

提示：

• 1 <= s.length <= 20
• s仅由数字组成

2. 题解

3. code

class Solution { public: vector<string> ans; bool isValid(const string& s, int start, int end) { if (start > end) { return false; } if (s[start] == '0' && start != end) { return false; } int num = 0; for (int i = start; i <= end; i++) { if (s[i] > '9' || s[i] < '0') { return false; } num = num * 10 + (s[i] - '0'); if (num > 255) { return false; } } return true; } void backtracking(string s, int startIdx, int pointNum) { if (pointNum == 3) { if (isValid(s, startIdx, s.size() - 1)) { ans.push_back(s); } return; } for (int i = startIdx; i < s.size(); i++) { if (isValid(s, startIdx, i)) { s.insert(s.begin() + i + 1, '.'); pointNum++; backtracking(s, i + 2, pointNum); pointNum--; s.erase(s.begin() + i + 1); } else { break; } } return; } vector<string> restoreIpAddresses(string s) { backtracking(s, 0, 0); return ans; } };

4. 心得

回溯法，注意终止条件，以及插入和删除的位置。