👋 你好，欢迎来到我的博客！我是【菜鸟不学编程】
   我是一个正在奋斗中的职场码农，步入职场多年，正在从“小码农”慢慢成长为有深度、有思考的技术人。在这条不断进阶的路上，我决定记录下自己的学习与成长过程，也希望通过博客结识更多志同道合的朋友。
  
  🛠️ 主要方向包括 Java 基础、Spring 全家桶、数据库优化、项目实战等，也会分享一些踩坑经历与面试复盘，希望能为还在迷茫中的你提供一些参考。
  💡 我相信：写作是一种思考的过程，分享是一种进步的方式。
  
   如果你和我一样热爱技术、热爱成长，欢迎关注我，一起交流进步！

全文目录：

前言

在物联网（IoT）领域，设备与环境之间的数据交换和互动是实现智能化管理的基础。随着鸿蒙操作系统（HarmonyOS）的广泛应用，开发者可以利用鸿蒙提供的传感器 API 集成各种物联网设备，获取环境数据，进行设备通信和控制。通过这些技术，智能设备能够实时获取环境变化并作出反应，从而提高设备的自动化和智能化水平。

本文将介绍 传感器与物联网的集成应用，如何使用鸿蒙的 传感器 API 获取环境数据（如温湿度、加速度、光照等），以及如何通过 网络协议（如 MQTT）实现设备通信和数据同步。最后，我们还将通过代码示例演示如何实现传感器数据采集与物联网设备控制。

传感器与物联网的集成应用

在物联网应用中，传感器是实现环境感知的关键组件。传感器能够获取如温湿度、光照、加速度等环境数据，并将这些数据传输给物联网设备进行处理。鸿蒙系统支持多种传感器数据的获取，并提供了 API 用于获取传感器数据。

此外，物联网设备之间的通信通常使用一些网络协议（如 MQTT、CoAP、HTTP 等）。这些协议帮助设备与云端或其他设备同步数据，从而实现智能控制和远程监控。

使用传感器 API 获取环境数据

鸿蒙系统提供了对各种传感器的支持，开发者可以通过鸿蒙的 SensorManager 来访问不同类型的传感器。以下是常见的传感器类型：

  • 温湿度传感器：获取环境的温度和湿度数据。
  • 加速度传感器：测量设备的加速度。
  • 光照传感器：测量环境的光强。
  • 重力传感器：测量设备的重力变化。

通过使用鸿蒙的传感器 API，开发者可以轻松获取这些数据并进行处理。

1. 读取温湿度、加速度、光照等传感器数据

以下是如何通过鸿蒙的 SensorManager API 获取温湿度、加速度和光照数据的示例。

import ohos.aafwk.ability.Ability;
import ohos.aafwk.content.Intent;
import ohos.sensor.api.Sensor;
import ohos.sensor.api.SensorData;
import ohos.sensor.api.SensorEventListener;
import ohos.sensor.api.SensorManager;

public class SensorAbility extends Ability {
    private SensorManager sensorManager;
    private Sensor temperatureSensor, lightSensor, accelerometerSensor;

    @Override
    public void onStart(Intent intent) {
        super.onStart(intent);

        // 获取 SensorManager 实例
        sensorManager = (SensorManager) getSystemService(SensorManager.class);

        // 获取温湿度传感器
        temperatureSensor = sensorManager.getDefaultSensor(Sensor.TYPE_AMBIENT_TEMPERATURE);
        
        // 获取光照传感器
        lightSensor = sensorManager.getDefaultSensor(Sensor.TYPE_LIGHT);
        
        // 获取加速度传感器
        accelerometerSensor = sensorManager.getDefaultSensor(Sensor.TYPE_ACCELEROMETER);

        // 注册传感器事件监听器
        sensorManager.registerListener(sensorEventListener, temperatureSensor, SensorManager.SENSOR_DELAY_NORMAL);
        sensorManager.registerListener(sensorEventListener, lightSensor, SensorManager.SENSOR_DELAY_NORMAL);
        sensorManager.registerListener(sensorEventListener, accelerometerSensor, SensorManager.SENSOR_DELAY_NORMAL);
    }

    // 定义传感器事件监听器
    private SensorEventListener sensorEventListener = new SensorEventListener() {
        @Override
        public void onSensorChanged(SensorData sensorData) {
            // 获取传感器数据
            float[] values = sensorData.getValues();
            switch (sensorData.getType()) {
                case Sensor.TYPE_AMBIENT_TEMPERATURE:
                    float temperature = values[0];  // 温度数据
                    System.out.println("Temperature: " + temperature + "°C");
                    break;

                case Sensor.TYPE_LIGHT:
                    float lightIntensity = values[0];  // 光照强度数据
                    System.out.println("Light Intensity: " + lightIntensity + " lux");
                    break;

                case Sensor.TYPE_ACCELEROMETER:
                    float accelerationX = values[0];  // 加速度数据
                    float accelerationY = values[1];
                    float accelerationZ = values[2];
                    System.out.println("Acceleration - X: " + accelerationX + ", Y: " + accelerationY + ", Z: " + accelerationZ);
                    break;
            }
        }

        @Override
        public void onAccuracyChanged(Sensor sensor, int accuracy) {
            // 处理传感器精度变化
        }
    };

    @Override
    public void onStop() {
        super.onStop();
        // 注销传感器事件监听器
        sensorManager.unregisterListener(sensorEventListener);
    }
}

在这段代码中：

  • 使用 SensorManager 获取了温湿度传感器、光照传感器和加速度传感器。
  • 注册了一个 SensorEventListener 来监听传感器数据变化。
  • 在 onSensorChanged() 方法中，处理了不同传感器的数据，并打印了温度、光照强度和加速度。
2. 读取其他类型的传感器数据

鸿蒙系统支持其他类型的传感器，如重力传感器、陀螺仪等。获取这些传感器的数据与上述过程类似，只需替换不同的传感器类型即可。

设备通信与数据同步

在物联网应用中，设备之间的数据同步非常重要，特别是在多个设备或传感器之间共享数据时。常用的设备通信协议包括 MQTT（消息队列遥测传输）和 CoAP（约束应用协议）。其中，MQTT 是最常用的轻量级协议，适用于低带宽、高延迟的网络环境。

1. 使用 MQTT 协议同步设备数据

MQTT 是一种发布/订阅模式的消息传输协议，非常适用于 IoT 场景。使用 MQTT 协议可以实现设备间的数据通信和同步。

在鸿蒙中，你可以使用 Eclipse Paho MQTT 库来实现 MQTT 协议的通信。

代码示例：使用 MQTT 同步设备数据
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttMessage;

public class MqttExample {
    private static final String BROKER_URL = "tcp://broker.hivemq.com:1883";  // MQTT 服务器地址
    private static final String TOPIC = "iot/sensors/data";

    public void publishData(String data) {
        try {
            // 创建 MQTT 客户端
            MqttClient client = new MqttClient(BROKER_URL, MqttClient.generateClientId());
            
            // 配置连接选项
            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(true);
            
            // 连接到 MQTT 代理
            client.connect(options);
            
            // 创建消息并发布
            MqttMessage message = new MqttMessage(data.getBytes());
            message.setQos(0);  // 设置 QoS（服务质量等级）
            client.publish(TOPIC, message);  // 发布消息到指定主题
            
            System.out.println("Data published to topic: " + TOPIC);
            
            // 断开连接
            client.disconnect();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

在这个例子中：

  • 使用 MqttClient 连接到 MQTT 代理（服务器）。
  • 使用 publish() 方法将传感器数据发布到指定的主题（iot/sensors/data）。
  • 通过 MQTT 协议实现设备数据的同步与传输。

代码示例：实现传感器数据采集与物联网设备控制

结合传感器数据采集与物联网设备控制，我们可以使用以下代码来采集传感器数据并控制设备（例如，基于温度控制风扇的开关）。

import ohos.aafwk.ability.Ability;
import ohos.aafwk.content.Intent;
import ohos.sensor.api.Sensor;
import ohos.sensor.api.SensorData;
import ohos.sensor.api.SensorEventListener;
import ohos.sensor.api.SensorManager;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttMessage;

public class IoTAbility extends Ability {
    private static final String MQTT_BROKER_URL = "tcp://broker.hivemq.com:1883";
    private static final String TOPIC = "iot/sensors/temperature";
    
    private SensorManager sensorManager;
    private Sensor temperatureSensor;

    @Override
    public void onStart(Intent intent) {
        super.onStart(intent);
        
        // 初始化传感器
        sensorManager = (SensorManager) getSystemService(SensorManager.class);
        temperatureSensor = sensorManager.getDefaultSensor(Sensor.TYPE_AMBIENT_TEMPERATURE);
        
        // 注册传感器事件监听器
        sensorManager.registerListener(sensorEventListener, temperatureSensor, SensorManager.SENSOR_DELAY_NORMAL);
    }

    // 定义传感器事件监听器
    private SensorEventListener sensorEventListener = new SensorEventListener() {
        @Override
        public void onSensorChanged(SensorData sensorData) {
            float[] values = sensorData.getValues();
            float temperature = values[0];

            System.out.println("Current Temperature: " + temperature);

            // 根据温度值控制设备（例如，温度超过 30°C 开启风扇）
            if (temperature > 30) {
                publishData("Fan ON");
            } else {
                publishData("Fan OFF");
            }
        }

        @Override
        public void onAccuracyChanged(Sensor sensor, int accuracy) {
        }
    };

    private void publishData(String message) {
        try {
            MqttClient client = new MqttClient(MQTT_BROKER_URL, MqttClient.generateClientId());
            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(true);
            client.connect(options);

            MqttMessage mqttMessage = new MqttMessage(message.getBytes());
            mqttMessage.setQos(0);  // QoS 0
            client.publish(TOPIC, mqttMessage);
            client.disconnect();

            System.out.println("Data sent: " + message);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public void onStop() {
        super.onStop();
        // 注销传感器监听器
        sensorManager.unregisterListener(sensorEventListener);
    }
}

在这个示例中：

  • 获取环境温度数据，并通过 MQTT 发布温度数据到云端。
  • 根据温度值控制风扇的开关，温度超过 30°C 时，发送控制命令 "Fan ON"，否则发送 "Fan OFF"。

总结

通过鸿蒙的传感器 API 和物联网通信协议（如 MQTT），开发者可以方便地实现设备数据采集和控制。鸿蒙提供了完整的传感器支持，允许开发者获取各种环境数据（如温湿度、加速度、光照等），并通过网络协议同步这些数据。通过这些技术，智能设备能够实时获取环境信息并作出反应，推动智能家居、健康监测等应用的发展。

  • 传感器 API 使得环境数据的采集变得简单。
  • MQTT 协议为设备间的数据同步提供了高效、低延迟的解决方案。
  • 通过结合传感器数据采集与物联网设备控制，可以实现更智能的设备管理。

📝 写在最后

如果你觉得这篇文章对你有帮助，或者有任何想法、建议，欢迎在评论区留言交流！你的每一个点赞 👍、收藏 ⭐、关注 ❤️，都是我持续更新的最大动力！

我是一个在代码世界里不断摸索的小码农，愿我们都能在成长的路上越走越远，越学越强！

感谢你的阅读，我们下篇文章再见～👋

✍️ 作者：某个被流“治愈”过的 Java 老兵
📅 日期：2025-07-25
🧵 本文原创，转载请注明出处。

# harmonyos # 物联网 # 华为
Logo
HarmonyOS开发者社区

讨论HarmonyOS开发技术，专注于API与组件、DevEco Studio、测试、元服务和应用上架分发等。

更多推荐

cover

前端成功转鸿蒙开发者真实案例，教大家如何开发鸿蒙APP--ArkTS 卡片页面开发核心能力

avatar HarmonyOS开发者社区
cover

从入门小白到精通，玩转 React Native 鸿蒙跨平台开发：ScrollView 滚动视图组件

avatar HarmonyOS开发者社区
cover

前端成功转鸿蒙开发者真实案例，教大家如何开发鸿蒙APP--ArkTS 卡片刷新机制

avatar HarmonyOS开发者社区