后台使用websocket连接mqtt订阅主题代码 java

以下是一个使用 Java 后台连接 MQTT 服务器并订阅主题的示例代码：

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

public class MqttSubscriber {

    public static void main(String[] args) {

        String broker = "tcp://localhost:1883"; // MQTT 服务器地址
        String clientId = "JavaMqttSubscriber"; // 客户端 ID，可以任意指定
        String topic = "my/topic"; // 订阅的主题

        // 创建 MQTT 客户端实例
        try {
            MqttClient mqttClient = new MqttClient(broker, clientId, new MemoryPersistence());

            // 设置回调函数，处理接收到的消息
            mqttClient.setCallback(new MqttCallback() {
                public void connectionLost(Throwable throwable) {
                    // 连接丢失时的处理逻辑
                }

                public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
                    // 接收到消息时的处理逻辑
                    String messageContent = new String(mqttMessage.getPayload());
                    System.out.println("Received message: " + messageContent);
                }

                public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
                    // 消息发送完成时的处理逻辑
                }
            });

            // 连接到 MQTT 服务器
            mqttClient.connect();

            // 订阅主题
            mqttClient.subscribe(topic);

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

在这个示例代码中，我们使用了 Eclipse Paho MQTT 客户端库来连接 MQTT 服务器并订阅主题。你需要将 `broker` 变量设置为 MQTT 服务器的地址，将 `clientId` 变量设置为客户端 ID，将 `topic` 变量设置为订阅的主题。然后通过调用 `MqttClient` 类的 `connect()` 方法来连接到 MQTT 服务器，再调用 `subscribe()` 方法来订阅主题。在 `MqttCallback` 回调函数中，我们处理接收到的消息。