java mqtt

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;

public class MqttExample {

    public static void main(String[] args) {
        String broker = "tcp://mqtt.eclipse.org:1883";
        String clientId = "JavaSampleClient";
        try {
            // 创建MQTT客户端
            MqttClient client = new MqttClient(broker, clientId);

            // 设置回调函数
            client.setCallback(new MqttCallback() {
                @Override
                public void connectionLost(Throwable cause) {
                    System.out.println("Connection lost!");
                }

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

                @Override
                public void deliveryComplete(IMqttDeliveryToken token) {
                    System.out.println("Delivery complete!");
                }
            });

            // 连接到MQTT代理
            client.connect();
            System.out.println("Connected to MQTT broker!");

            // 订阅主题
            client.subscribe("test/topic");

            // 发布消息
            MqttMessage message = new MqttMessage("Hello MQTT".getBytes());
            client.publish("test/topic", message);
            System.out.println("Message published!");

            // 断开连接
            client.disconnect();
            System.out.println("Disconnected from MQTT broker!");

        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

代码解释：

1. 导入库：使用Eclipse Paho库来实现MQTT协议的通信。
2. 创建客户端：通过MqttClient类创建一个MQTT客户端实例，指定MQTT代理地址和客户端ID。
3. 设置回调：通过setCallback方法设置回调函数，处理连接丢失、消息到达和消息发送完成等事件。
4. 连接代理：调用connect()方法连接到MQTT代理。
5. 订阅主题：使用subscribe()方法订阅一个或多个主题。
6. 发布消息：使用publish()方法向指定主题发布消息。
7. 断开连接：完成通信后调用disconnect()方法断开与代理的连接。

这个示例展示了如何使用Java和Eclipse Paho库进行基本的MQTT通信。