Spring 从 MQTT 出站通道适配器获取事件

Question

我已经在使用 Spring Integration 4.1.0 SNAPSHOT。

我有这个 MQTT 出站适配器：

<int-mqtt:outbound-channel-adapter
        async="true"
        async-events="true"
        id="mqttOutput"
        channel="httpInputChannel"
        client-id="#{controller.mqttPublisherConfig.clientID}"
        url="#{controller.mqttPublisherConfig.completeURL}"
        default-qos="#{controller.mqttPublisherConfig.qosString}"
        default-retained="#{controller.mqttPublisherConfig.retainFlag}"
        default-topic="#{controller.mqttPublisherConfig.topic}"
        />

现在在我的控制器（MVC 应用程序）中，我想接收适配器发出的事件。

我正在实施 ApplicinListener：

    @Controller
    public class ServletController implements ApplicationListener {

        public void onApplicationEvent(ApplicationEvent event)
        {
         //
        }

        ...
    }

仍然，我没有收到来自 MQTT 适配器的任何事件。

实现一个 in-event:inbound-channel-adapter 是可行的，但是：

<int-event:inbound-channel-adapter channel="eventLogger" 
                               error-channel="eventErrorChannel"
                               />

但我真的很想处理代码中的事件！

Answer 1

您的@Controller 是否与 MQTT 适配器位于相同的应用程序上下文中？或者（最常见的情况），控制器位于 web (DispatcherServlet's) 上下文中，而其他 bean 位于由 ContextLoaderListener 加载的根应用程序上下文中。

问题是根上下文中的 bean 无法“看到”servlet 上下文中的 bean，并且在根上下文中发布的事件不会被子上下文中的侦听器接收。

您将不得不颠覆这个可见性问题 - 要么将业务 bean 移动到 Web 上下文中（通常不推荐，但对于小型应用程序来说并不可怕），或者以某种方式将侦听器从根上下文连接到控制器 - 可能通过连接它进入控制器并让控制器在初始化期间将自身传递给侦听器（afterPropertiesSet()）。你会有一个类缠结（相互依赖），但它应该可以工作。

顺便说一句，ApplicationListener 可以接受泛型所以

public class MyListener implements ApplicationListener<MqttIntegrationEvent> { ... }

只会获得 MQTT 事件。

编辑：

另一种解决方案是使用事件通道适配器并将outbound-channel-adapter 添加到 Web 上下文（与控制器相同的上下文）...

@Controller
...

    public void onMqttEvent(MqttIntegrationEvent event) { ... }


<int:outbound-channel-adapter channel="eventLogger"
    ref="myController" method="onMqttEvent" />

它将在根上下文中对通道可见。

确保将事件适配器配置为仅接收 MqttIntegrationEvents。