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

以下是使用 Eclipse Paho MQTT 客户端库在 Java 中订阅 MQTT 主题的示例代码：

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

public class MQTTSubscriber implements MqttCallback {

    private MqttClient client;
    private String brokerUrl;
    private String clientId;
    private MemoryPersistence persistence;
    private MqttConnectOptions connOpts;

    public MQTTSubscriber(String brokerUrl, String clientId) {
        this.brokerUrl = brokerUrl;
        this.clientId = clientId;
        this.persistence = new MemoryPersistence();
        this.connOpts = new MqttConnectOptions();
        this.connOpts.setCleanSession(true);
    }

    public void connect() throws MqttException {
        this.client = new MqttClient(this.brokerUrl, this.clientId, this.persistence);
        this.client.setCallback(this);
        this.client.connect(this.connOpts);
    }

    public void disconnect() throws MqttException {
        this.client.disconnect();
    }

    public void subscribe(String topic) throws MqttException {
        this.client.subscribe(topic);
    }

    @Override
    public void connectionLost(Throwable cause) {
        System.out.println("Connection lost: " + cause.getMessage());
    }

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

    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {
        // Not used in subscriber
    }
}

在上面的代码中，我们使用 `MqttClient` 类创建一个 MQTT 客户端，并使用 `MqttConnectOptions` 类配置连接选项。我们还实现了 `MqttCallback` 接口来处理连接丢失、消息到达和传输完成事件。

使用 `connect` 方法连接到 MQTT 代理，使用 `subscribe` 方法订阅一个或多个主题。

要使用以上代码，您需要添加 Eclipse Paho MQTT 客户端库的依赖项。这可以通过以下 Maven 依赖项来完成：

<dependency>
    <groupId>org.eclipse.paho</groupId>
    <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
    <version>1.2.5</version>
</dependency>

您还需要替换代码中的 `brokerUrl` 和 `clientId` 与您自己的值。