给我一个基于 springboot mqtt starter

好的，这里给你一个基于 Spring Boot 和 Eclipse Paho 的 MQTT Starter 的示例代码：

首先，在 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>
<dependency>
    <groupId>org.eclipse.paho</groupId>
    <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
    <version>1.2.5</version>
</dependency>

接下来，在 application.properties 文件中添加 MQTT 服务器相关的配置：

spring.mqtt.username=your-username
spring.mqtt.password=your-password
spring.mqtt.url=tcp://your-mqtt-server:1883

然后，创建一个名为 MqttConfig 的类，用于配置 MQTT 连接工厂：

@Configuration
@EnableIntegration
public class MqttConfig {

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

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

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

    @Bean
    public MqttConnectOptions mqttConnectOptions() {
        MqttConnectOptions options = new MqttConnectOptions();
        options.setCleanSession(true);
        options.setUserName(mqttUserName);
        options.setPassword(mqttPassword.toCharArray());
        return options;
    }

    @Bean
    public MqttPahoClientFactory mqttClientFactory() {
        DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
        factory.setConnectionOptions(mqttConnectOptions());
        return factory;
    }

    @Bean
    public MessageChannel mqttInputChannel() {
        return new DirectChannel();
    }

    @Bean
    public MessageProducer inbound() {
        MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter(
                mqttBrokerUrl, "clientId", mqttClientFactory(), "topic");
        adapter.setCompletionTimeout(5000);
        adapter.setConverter(new DefaultPahoMessageConverter());
        adapter.setQos(1);
        adapter.setOutputChannel(mqttInputChannel());
        return adapter;
    }

    @Bean
    public MessageHandler mqttOutbound() {
        MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler(
                mqttBrokerUrl, "clientId", mqttClientFactory());
        messageHandler.setAsync(true);
        messageHandler.setDefaultTopic("topic");
        messageHandler.setDefaultQos(1);
        messageHandler.setCompletionTimeout(5000);
        return messageHandler;
    }
}

在上面的代码中，我们定义了一个名为 mqttInputChannel 的消息通道，用于接收从 MQTT 服务器发来的消息；还定义了一个名为 mqttOutbound 的消息处理器，用于将消息发送到 MQTT 服务器。

最后，在你的服务类中，你可以注入 mqttInputChannel 和 mqttOutbound，并使用它们发送和接收 MQTT 消息：

@Service
public class MyService {

    @Autowired
    private MessageChannel mqttInputChannel;

    @Autowired
    private MessageHandler mqttOutbound;

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

    @ServiceActivator(inputChannel = "mqttInputChannel")
    public void handleMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

这样，你就可以使用 Spring Boot 和 Eclipse Paho 开发基于 MQTT 的应用了。