MQTT和springboot连接

MQTT和Spring Boot可以通过Paho MQTT客户端库进行连接。

首先，需要在Spring Boot项目中添加Paho MQTT客户端库的依赖。可以在Maven或Gradle中添加以下依赖：

Maven：

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

Gradle：

implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5'

接下来，需要创建一个MQTT连接，并且使用该连接进行订阅或发布消息。可以在Spring Boot中使用`@Bean`注解创建一个MQTT连接：

@Configuration
public class MqttConfig {
    @Value("${mqtt.broker}")
    private String brokerUrl;

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

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

    @Bean
    public MqttClient mqttClient() throws MqttException {
        MqttClient mqttClient = new MqttClient(brokerUrl, clientId);
        mqttClient.connect();
        mqttClient.subscribe(topic);
        return mqttClient;
    }
}

在上面的例子中，`brokerUrl`是MQTT代理服务器的URL，`clientId`是客户端的ID，`topic`是要订阅的MQTT主题。

然后，可以使用`@Autowired`注解将`MqttClient`注入到需要使用它的类中，例如：

@Service
public class MyMqttService {
    @Autowired
    private MqttClient mqttClient;

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

在上面的例子中，`sendMessage`方法使用`MqttClient`发布了一条消息到`my_topic`主题。

需要注意的是，需要在应用程序退出时关闭MQTT连接。可以在`@PreDestroy`注解的方法中关闭连接，例如：

@Configuration
public class MqttConfig {
    // ...

    @PreDestroy
    public void cleanUp() throws MqttException {
        mqttClient.disconnect();
        mqttClient.close();
    }
}

在上面的例子中，`cleanUp`方法在应用程序退出时关闭了MQTT连接。