springboot 集成mqtt

在Spring Boot中集成MQTT，你可以按照以下步骤进行操作：

1. 添加依赖：在你的`pom.xml`文件中添加以下依赖：

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

2. 创建MQTT配置类：创建一个配置类，用于配置MQTT连接参数和相关的Bean。例如，可以创建一个`MqttConfig`类：

@Configuration
public class MqttConfig {

    @Value("${mqtt.broker}")
    private String broker;

    @Bean
    public MqttClient mqttClient() throws MqttException {
        MqttClient mqttClient = new MqttClient(broker, MqttClient.generateClientId());
        mqttClient.connect();
        return mqttClient;
    }
}

这里使用了`@Value`注解来注入`mqtt.broker`属性值，你可以在`application.properties`或`application.yml`中配置MQTT服务器地址。

3. 发布/订阅消息：在需要使用MQTT功能的地方，可以通过注入`MqttClient`来发布和订阅消息。例如，可以创建一个`MqttService`类：

@Service
public class MqttService {

    private final MqttClient mqttClient;

    public MqttService(MqttClient mqttClient) {
        this.mqttClient = mqttClient;
    }

    public void publish(String topic, String message) throws MqttException {
        MqttMessage mqttMessage = new MqttMessage(message.getBytes());
        mqttClient.publish(topic, mqttMessage);
    }

    public void subscribe(String topic) throws MqttException {
        mqttClient.subscribe(topic, (topic, mqttMessage) -> {
            String payload = new String(mqttMessage.getPayload());
            System.out.println("Received message: " + payload);
        });
    }
}

在上面的例子中，`MqttService`类注入了`MqttClient`，并提供了发布和订阅消息的方法。

4. 配置和使用：在`application.properties`或`application.yml`中配置MQTT服务器地址，例如：

mqtt.broker=tcp://localhost:1883

然后，你可以在需要的地方注入`MqttService`并使用它来发布和订阅消息。

这就是在Spring Boot中集成MQTT的基本步骤。你可以根据自己的需求进行扩展和定制化。希望对你有帮助！