springboot项目整合mqtt

可以使用 Eclipse Paho 客户端库来实现 Spring Boot 与 MQTT 的整合。首先需要在 pom.xml 文件中添加以下依赖：

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

然后在 Spring Boot 应用程序中创建一个 MQTT 配置类，例如：

@Configuration
public class MqttConfig {

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

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

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

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

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

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

在这个配置类中，我们定义了一个 MqttConnectOptions bean 和一个 MqttClient bean。MqttConnectOptions bean 用于设置 MQTT 连接选项，例如用户名、密码和清除会话标志。MqttClient bean 用于创建一个 MQTT 客户端并连接到 MQTT 代理。

接下来，我们可以在 Spring Boot 应用程序中使用 MqttClient bean 来发布和订阅 MQTT 消息。例如：

@Autowired
private MqttClient mqttClient;

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

public void subscribe(String topic) throws MqttException {
    mqttClient.subscribe(topic, (topic, message) -> {
        String payload = new String(message.getPayload());
        System.out.println("Received message: " + payload);
    });
}

在这个例子中，我们使用了自动装配来注入 MqttClient bean。然后我们定义了两个方法，一个用于发布 MQTT 消息，另一个用于订阅 MQTT 消息。在订阅方法中，我们使用了 Java 8 的 Lambda 表达式来处理接收到的消息。

以上就是 Spring Boot 与 MQTT 整合的基本步骤。