MQTT springboot

### 如何在 Spring Boot 中集成 MQTT 协议实现消息传递

#### 1. 添加依赖项
为了使 Spring Boot 应用程序能够处理 MQTT 消息，需添加 Paho 客户端库作为依赖。此操作通过修改 `pom.xml` 文件完成。

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

该依赖提供了必要的类来建立与 MQTT 经纪人的连接并发送接收消息[^4]。

#### 2. 配置 MQTT 连接参数
接着，在项目的配置文件 (`application.yml`) 中定义 MQTT 的连接设置：

mqtt:
  broker: tcp://broker.hivemq.com:1883
  username: yourUsernameIfRequired
  password: yourPasswordIfRequired
  caDir: pathToCACertificatesIfUsingTLS

这些属性指定了要连接的经纪人 URL 和认证信息等细节。

#### 3. 创建 MQTT 配置类
编写一个 Java 类用于初始化客户端实例以及管理其生命周期的方法（如订阅主题、发布消息）。下面给出的是一个简单的例子：

@Configuration
public class MqttConfig {

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

    @Bean
    public IMqttClient mqttClient() throws Exception {
        IMqttClient client = new MqttAsyncClient(broker, MqttClient.generateClientId());
        // 设置回调处理器...
        return client;
    }

}

这段代码展示了如何利用 Spring 的依赖注入机制获取应用程序上下文中定义好的 Broker 地址，并据此构建异步类型的 MQTT 客户端对象[^2]。

#### 4. 编写控制器以测试功能
最后一步是开发 RESTful API 来触发特定的操作，比如向指定的主题推送数据或者监听某个频道上的更新。这里展示了一个基本的例子：

@RestController
@RequestMapping("/mqtt")
public class MqttController {

    @Autowired
    private MqttConfig mqttConfig;

    @GetMapping("/send")
    public ResponseEntity<String> sendMessage(@RequestParam String topic,@RequestParam String message) {
        try{
            mqttConfig.publish(topic,message);
            return ResponseEntity.ok("Message sent successfully.");
        }catch(Exception e){
            return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(e.getMessage());
        }
    }

}

上述方法允许外部调用者通过 HTTP GET 请求携带目标 Topic 及待发内容来进行信息发布活动；同时返回执行状态给前端使用者知晓结果情况[^3]。