spring-integration-mqtt MqttPahoMessageHandler 如何判断是否连接上mqtt服务器

在Spring Integration中使用MqttPahoMessageHandler连接MQTT服务器时，可以通过以下方式检查连接是否建立成功：

1. 在MqttPahoMessageHandler的bean定义中，设置一个MqttConnectOptions对象，该对象可以设置连接Mqtt服务器的选项，包括连接超时时间、会话心跳间隔等。

2. 通过MqttPahoMessageHandler的isRunning()方法判断是否已经开始运行。如果isRunning()方法返回false，则说明MqttPahoMessageHandler还没有启动。

3. 通过MqttPahoMessageHandler的getConnection()方法获取MqttClient连接对象，然后调用MqttClient.isConnected()方法判断连接状态。

示例代码：

@Autowired
private MqttPahoMessageHandler mqttHandler;

// 检查连接是否成功建立
boolean isConnected = mqttHandler.getConnection().isConnected();
if (!isConnected) {
    // 连接未成功建立，进行相应处理
    ...
}

注意：在检查连接状态时，需要确保MqttPahoMessageHandler已经启动。如果未启动，可以使用Spring的ApplicationListener接口监听ContextRefreshedEvent事件，在事件被触发时进行检查。