Spring消息驱动通道适配器：处理连接被拒绝错误答案

【问题标题】：Spring message-driven-channel-adapter: handling connection refused errorSpring消息驱动通道适配器：处理连接被拒绝错误
【发布时间】：2015-11-05 01:06:39
【问题描述】：

我想配置我的消息驱动通道适配器，以便在以下情况下我可以抓住“连接被拒绝”错误： 1) 消息代理已关闭或 2) 指定了错误的代理 URL

我尝试使用下面的代码执行此操作，但没有成功：

<int:channel id="invalidChannel" />

<int-mqtt:message-driven-channel-adapter 
     id="myAdapter" 
     client-id="${inbound.client.id}"
     url="${host.url}"
     topics="${inbound.topic}"
     channel="incomingChannel"
     error-channel="errorChannel"
     client-factory="clientFactory" />

<int:exception-type-router input-channel="errorChannel">
        <int:mapping exception-type="java.net.ConnectException" channel="invalidChannel" />
    </int:exception-type-router>


<int:service-activator id="ErrorActivator" 
            input-channel="invalidChannel" 
            ref="errorListener" 
            method="processError" />


<bean id="errorListener" class="com.ErrorListener"  />

processError() 方法定义如下：

public void processError(Message<MessageHandlingException> message)
    {
        System.out.println("an error / exception occured");
    }

我正在尝试获取连接异常情况下记录如下的异常：

Unable to connect to server (32103) - java.net.ConnectException: Connection refused: connect
        at org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule.start(TCPNetworkModule.java:79)
        at org.eclipse.paho.client.mqttv3.internal.ClientComms$ConnectBG.run(ClientComms.java:590)
        at java.lang.Thread.run(Thread.java:745)
Caused by: java.net.ConnectException: Connection refused: connect
        at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)
        at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85)
        at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
        at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
        at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
        at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
        at java.net.Socket.connect(Socket.java:579)
        at org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule.start(TCPNetworkModule.java:70)
        ... 2 more

有人可以帮忙吗？

问候

【问题讨论】：

标签： spring-integration mqtt

【解决方案1】：

Connection refused 错误不是消息流的一部分，因此errorChannel 不会处理它。 M-m-m...只是因为它是在任何Message出现之前引起的。

更新

从 Spring Integration 4.2.2 开始，MqttConnectionFailedEvent 可用于这些情况。

在参考手册中查看更多信息：http://docs.spring.io/spring-integration/reference/html/mqtt.html

【讨论】：

无操作。 MqttPahoMessageDrivenChannelAdapter 中有这样一个钩子。不过，您可以通过相同的MqttPahoClientFactory 在其他组件中手动使用client.connect(connectionOptions)。
感谢您的意见。当启动应用程序时代理不可用时，您建议的方法将起作用。但是，如果代理在应用程序运行时出现故障，则需要以其他方式进行处理
目前没有任何通知。您必须循环运行连接检查器。我打开了一个JIRA Issue，让框架在连接失败时发出一个ApplicationEvent。
谢谢@GaryRussell！这就是我今晚的梦想:-)
另一种解决方法是使用自定义日志附加程序来检测此日志条目 logger.error("Error connecting or subscribing to " + Arrays.asList(this.getTopic()), e);。