java mqttv3

Java MQTTv3 是一个用于在 Java 应用程序中实现 MQTT（Message Queuing Telemetry Transport）通信协议的库。MQTT 是一种轻量级的发布/订阅消息传输协议，广泛用于物联网和即时通讯应用中。

在 Java 中使用 MQTTv3，你需要添加相关的依赖库。以下是一个使用 Eclipse Paho MQTTv3 客户端库的示例代码：

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

public class MQTTClient {
    public static void main(String[] args) {
        String broker = "tcp://mqtt.example.com:1883";
        String clientId = "JavaMQTTClient";
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            MqttClient mqttClient = new MqttClient(broker, clientId, persistence);
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);

            System.out.println("Connecting to broker: " + broker);
            mqttClient.connect(connOpts);
            System.out.println("Connected");

            String topic = "example/topic";            int qos = 1;

            mqttClient.subscribe(topic, qos);
            System.out.println("Subscribed to topic: " + topic);

            mqttClient.setCallback(new MqttCallback() {
                public void connectionLost(Throwable cause) {
                    System.out.println("Connection lost");
                }

                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    System.out.println("Received message: " + new String(message.getPayload()));
                }

                public void deliveryComplete(IMqttDeliveryToken token) {
                    // Not used in this example
                }
            });

            // Publish a test message
            String content = "Hello, MQTT";
            MqttMessage message = new MqttMessage(content.getBytes());
            message.setQos(qos);
            mqttClient.publish(topic, message);
            System.out.println("Message published");

            // Disconnect from the broker
            mqttClient.disconnect();
            System.out.println("Disconnected");
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

上述代码示例中，我们创建了一个 MQTT 客户端，并连接到指定的 MQTT 代理（broker）。然后，我们订阅一个主题，并设置一个回调函数来处理接收到的消息。最后，我们发布一条测试消息，并断开与代理的连接。

请注意，你需要根据实际情况修改代码中的 broker 地址、主题名称等参数。

希望这能帮助到你！如果有任何其他问题，请随时问。