写一个springboot连接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>

然后，你需要在application.properties文件中配置mqtt的连接信息，例如：

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

最后，你可以编写一个简单的Controller来测试连接：

@RestController
public class MqttController {

    @Autowired
    private MqttPahoMessageDrivenChannelAdapter mqttAdapter;

    @GetMapping("/mqtt")
    public String sendMessage() {
        String message = "Hello, MQTT!";
        mqttAdapter.getOutputChannel().send(MessageBuilder.withPayload(message).build());
        return "Message sent: " + message;
    }
}

在上面的代码中，我们使用`MqttPahoMessageDrivenChannelAdapter`来连接mqtt，并通过`OutputChannel`发送消息。当我们访问`/mqtt`接口时，它将发送一条消息到mqtt服务器。

当然，这只是一个简单的示例。在实际应用中，你需要考虑更多的细节，例如如何处理mqtt服务器返回的消息等。