在 spring-integration 中使用有效负载类型路由器通过列表通用有效负载路由消息

Question

我正在尝试在旧版应用程序的基于 xml 的配置中使用有效负载类型路由器，并且该应用程序既不会路由到特定通道，也不会在该实例中引发任何错误。我们可以使用 XML 配置使用 payload-type-router 路由 List> 类型的消息吗？我在文档中没有找到太多示例，因为它只提到了使用 Integer、String 类而不是 List 的路由。

 <int:payload-type-router input-channel="run-router-channel">
        <int:mapping type="com.foo.req.BlRunnerRequest" channel="runner-channel"/>
        <int:mapping type="java.util.List" channel="run-channel"/>  <!-- can spring integration support this approach-->
 </int:payload-type-router> 

提前致谢。 XML 中这种路由的替代方案是什么？

Answer 1

是的。我们可以。我刚刚将项目中的单元测试修改成这样：

<payload-type-router id="router" input-channel="routingChannel">
    <mapping type="java.lang.String" channel="channel1" />
    <mapping type="java.lang.Integer" channel="channel2" />
    <mapping type="java.lang.Number[]" channel="channel3" />
    <mapping type="java.lang.Long[]" channel="channel4" />
    <mapping type="java.util.List" channel="channel5" />
</payload-type-router>

我在测试方法中这样做：

testService.foo(new GenericMessage<>(new ArrayList()));
PollableChannel channel5 = (PollableChannel) context.getBean("channel5");
assertThat(channel5.receive(100).getPayload()).isInstanceOf(List.class);

在您的情况下可能发生了其他事情，并且该请求有效负载实际上不是java.util.List。

当路由器无法将消息传递到某个通道时，它也有这个逻辑：

    if (!sent) {
        getDefaultOutputChannel();
        if (this.defaultOutputChannel != null) {
            this.messagingTemplate.send(this.defaultOutputChannel, message);
        }
        else {
            throw new MessageDeliveryException(message, "No channel resolved by router '" + this
                    + "' and no 'defaultOutputChannel' defined.");
        }
    }

由于我没有从您的代码 sn-p 中看到 defaultOutputChannel 配置，这仅意味着抛出了 MessageDeliveryException。如果你没有在你的盒子里看到它，那么你会以某种方式吞下它。