Java使用mqttv3集成mqtt发送数据完整的代码

在Java中集成MQTT v3.1协议发送数据，通常需要使用第三方库如`org.eclipse.paho.mqtt.client`。以下是一个简单的示例，展示如何创建连接、订阅主题并发布消息：

import org.eclipse.paho.client.mqttv3.*;

public class MqttClientExample {
    private static final String BROKER_URL = "tcp://your_mqtt_broker.com:1883"; // 替换为实际的MQTT服务器地址
    private static final String CLIENT_ID = "client_id"; // 自定义客户端ID
    private static final String TOPIC = "your_topic"; // 想要订阅的主题

    public static void main(String[] args) {
        // 创建MqttClient实例
        MqttClient client = new MqttClient(BROKER_URL, CLIENT_ID);

        try {
            // 连接到MQTT服务器
            System.out.println("Connecting to MQTT broker...");
            client.connect();

            // 订阅主题
            System.out.println("Subscribing to topic: " + TOPIC);
            client.subscribe(TOPIC);

            // 准备发布消息
            String message = "Hello, MQTT!";
            byte[] payload = message.getBytes("UTF-8");

            // 发布消息
            System.out.println("Publishing message: " + message);
            client.publish(TOPIC, payload, QoS.AT_LEAST_ONCE); // 使用QoS.AT_LEAST_ONCE保证消息送达

            // 等待用户中断连接
            Thread.sleep(5000); // 防止无限运行
            client.disconnect();
            System.out.println("Disconnected from the broker.");
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

在这个例子中，你需要替换`BROKER_URL`, `CLIENT_ID`, 和 `TOPIC`为你自己的值。