springboot整合mqtt配置过期断联

Spring Boot 整合 MQTT 时，如果需要实现过期断联的功能，通常涉及到客户端的连接管理和心跳检测机制。MQTT 客户端通过定期发送心跳包给服务器来保持连接，当服务器未收到心跳包超过设定的时间（即超时时间），就会认为客户端已经断开并关闭连接。

在 Spring AMQP 的 MQTT 支持中，你可以通过以下步骤设置过期断联：

1. **配置MQTT连接**：
使用 `org.springframework.cloud.stream.binder.MqttMessageDrivenChannelBinder` 创建消息驱动组件，设置 `connectionFactory` 和 `brokerUri` 等基本属性，例如：

   @Bean
   public MqttMessageDrivenSubscribableChannel mqttInput() {
       return new MqttMessageDrivenSubscribableChannel(binder(), "myTopic");
   }
   
   @Bean
   public PahoMqttConnectionFactory connectionFactory() {
       PahoMqttConnectionFactory factory = new PahoMqttConnectionFactory();
       // 设置MQTT服务器地址
       factory.setBrokerUrl("tcp://your-broker-url:1883");
       // 可选，设置心跳间隔
       factory.setCleanSession(true); // 默认已设为 true，代表连接关闭后会清除所有信息
       // 可选，自定义心跳检查器
       factory.setConnectionChecker(new DefaultMqttConnectionChecker(60000L)); // 每隔60秒检查一次连接
       return factory;
   }

2. **处理连接异常**：
使用 `@ExceptionHandler` 注解捕获 `MqttException`，并在其中处理断线逻辑，比如重新连接、记录日志等。

3. **自动重连**（可选）：
如果希望在连接断开后自动重试，可以实现一个 `MqttReconnectStrategy`，然后设置到 `connectionFactory` 中。

@Bean
public MqttReconnectStrategy reconnectStrategy() {
    return new FixedDelayMqttReconnectStrategy(5000); // 5秒后尝试重连
}