spring boot集成mqtt

在Spring Boot中集成MQTT可以通过使用 Eclipse Paho 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连接参数，例如服务器地址、端口号、客户端ID等。可以使用 Spring Boot 的配置文件来设置这些参数。

@Configuration
public class MqttConfig {

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

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

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

3. 创建MQTT消息处理类：创建一个消息处理类，用于定义收到消息时的处理逻辑。

@Component
public class MqttMessageHandler implements MqttCallback {

    // 处理收到的消息
    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        // 处理收到的消息逻辑
        System.out.println("Received message: " + new String(message.getPayload()));
    }

    // 其他回调方法省略...
}

4. 创建MQTT消息订阅者：创建一个订阅者类，用于订阅特定的主题，并设置消息处理类。

@Component
public class MqttSubscriber {

    @Autowired
    private MqttClient mqttClient;

    @Autowired
    private MqttMessageHandler messageHandler;

    public void subscribe(String topic) throws MqttException {
        mqttClient.setCallback(messageHandler);
        mqttClient.connect();
        mqttClient.subscribe(topic);
    }
}

5. 启动订阅：在Spring Boot应用的入口类中，注入订阅者类，并调用订阅方法启动消息订阅。

@SpringBootApplication
public class MyApplication implements CommandLineRunner {

    @Autowired
    private MqttSubscriber mqttSubscriber;

    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }

    @Override
    public void run(String... args) throws Exception {
        mqttSubscriber.subscribe("my/topic");
    }
}

这样，当有消息发布到 "my/topic" 主题时，消息处理类中的 `messageArrived` 方法将会被调用，你可以在其中编写自己的处理逻辑。

请确保在配置文件中正确设置了MQTT服务器地址、端口号、客户端ID等参数。另外，还需要处理MQTT连接、异常等的错误情况。以上只是一个简单的示例，你可以根据自己的需求进行进一步的扩展和定制。