java框架与物联网低功耗设备的开发

import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.MqttTopic;
import java.util.UUID;

public class IotDevice {

    private static final String BROKER_URL = "tcp://mqtt.eclipse.org:1883";
    private static final String TOPIC = "/iot/temperature";
    private static final int QOS = 1;

    public static void main(String[] args) throws MqttException {
        // 创建 MQTT 客户端
        String clientId = UUID.randomUUID().toString();
        MqttClient client = new MqttClient(BROKER_URL, clientId);

        // 设置连接选项
        MqttConnectOptions connOpts = new MqttConnectOptions();
        connOpts.setCleanSession(true);

        // 连接到代理
        client.connect(connOpts);

        // 创建 MQTT 主题
        MqttTopic topic = client.getTopic(TOPIC);

        // 无限循环读取温度数据并发送到云
        while (true) {
            // 读取温度数据（模拟）
            float temperature = (float) Math.random() * 100;

            // 创建 MQTT 消息
            MqttMessage message = new MqttMessage(String.valueOf(temperature).getBytes());
            message.setQos(QOS);

            // 发布消息到主题
            topic.publish(message);

            // 暂停 5 秒
            try {
                Thread.sleep(5000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        // 断开连接
        client.disconnect();
    }
}