springboot 使用mqtt发送消息

Spring Boot是一个用于创建独立的、基于Spring框架的Java应用程序的框架。它简化了Spring应用程序的开发过程，并提供了一种快速构建可部署的应用程序的方式。

MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息传输协议，它适用于物联网设备和应用程序之间的通信。Spring Boot提供了对MQTT的支持，可以方便地使用MQTT发送消息。

要在Spring Boot中使用MQTT发送消息，首先需要添加相关的依赖。在`pom.xml`文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-mqtt</artifactId>
</dependency>

接下来，需要配置MQTT连接信息。在`application.properties`文件中添加以下配置：

spring.mqtt.url=tcp://localhost:1883
spring.mqtt.username=username
spring.mqtt.password=password

然后，创建一个MQTT消息发送者的Bean。可以使用`MqttPahoMessageHandler`类来发送消息。例如：

@Configuration
public class MqttConfig {

    @Value("${spring.mqtt.url}")
    private String mqttUrl;

    @Value("${spring.mqtt.username}")
    private String mqttUsername;

    @Value("${spring.mqtt.password}")
    private String mqttPassword;

    @Bean
    public MessageHandler mqttOutbound() {
        MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler("clientId", MqttClientFactory.defaultOptions(mqttUrl, mqttUsername, mqttPassword));
        messageHandler.setAsync(true);
        messageHandler.setDefaultTopic("topic");
        return messageHandler;
    }
}

最后，可以在需要发送消息的地方注入`MessageHandler`并使用它发送消息。例如：

@Service
public class MessageService {

    @Autowired
    private MessageHandler mqttOutbound;

    public void sendMessage(String message) {
        mqttOutbound.handleMessage(MessageBuilder.withPayload(message).build());
    }
}

以上就是使用Spring Boot发送MQTT消息的简单介绍。