springboot集成mqtt

要在Spring Boot中集成MQTT，可以使用 Eclipse Paho 客户端库。以下是集成步骤：

1. 添加 Maven 依赖：

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

2. 创建一个 MqttClient 对象：

MqttClient client = new MqttClient(broker, clientId, persistence);

3. 创建一个 MqttConnectOptions 对象，并设置连接参数：

MqttConnectOptions connOpts = new MqttConnectOptions();
connOpts.setCleanSession(true);
connOpts.setUserName(username);
connOpts.setPassword(password.toCharArray());

4. 连接到 MQTT 代理服务器：

client.connect(connOpts);

5. 订阅主题：

client.subscribe(topic);

6. 发布消息：

MqttMessage message = new MqttMessage(payload.getBytes());
message.setQos(qos);
client.publish(topic, message);