Java spring Mqtt 接收消息

要在Java Spring中接收MQTT消息，您需要执行以下步骤：

1. 添加MQTT依赖项：在Maven或Gradle中添加Eclipse Paho MQTT客户端库的依赖项。

2. 创建一个MQTT客户端对象：使用Eclipse Paho MQTT客户端库，您可以使用MqttClient类创建一个新的MQTT客户端对象。

3. 实现MqttCallback接口：这个接口用于处理MQTT消息。您需要实现它并将其附加到您的MQTT客户端对象。

4. 创建一个连接：使用您的MQTT客户端对象，您可以使用connect（）方法连接到MQTT代理。

5. 订阅主题：使用subscribe（）方法订阅您感兴趣的MQTT主题。

6. 处理消息：一旦您的MQTT客户端接收到消息，您的MqttCallback实现将被调用。您可以在此处处理消息。

以下是一个简单的Java Spring代码示例，演示如何接收MQTT消息：

import org.eclipse.paho.client.mqttv3.*;
import org.springframework.stereotype.Component;

@Component
public class MqttSubscriber implements MqttCallback {
    private MqttClient mqttClient;

    public void init() throws MqttException {
        mqttClient = new MqttClient("tcp://localhost:1883", "mqtt-subscriber");
        mqttClient.setCallback(this);
        mqttClient.connect();
        mqttClient.subscribe("my/topic");
    }

    @Override
    public void connectionLost(Throwable throwable) {}

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

    @Override
    public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {}
}

在上面的代码中，MqttSubscriber类实现了MqttCallback接口，并使用init（）方法创建了一个新的MQTT客户端对象。它还订阅了名为“my/topic”的主题，并在messageArrived（）方法中处理接收到的消息。

请注意，在Spring中，您还需要将这个类声明为一个组件，以便Spring可以管理它的生命周期。