2

我正在尝试使用spring集成实现路由单，配置如下

@Bean
@Transformer(inputChannel = "inputChannel", outputChannel = "replyChannel")
public HeaderEnricher headerEnricher() {
    return new HeaderEnricher(Collections.singletonMap(IntegrationMessageHeaderAccessor.ROUTING_SLIP,
            new RoutingSlipHeaderValueMessageProcessor("channel1", "channel2", "channel3"
                    , "channel4"
            )));

}

和

 @Bean
public MessageChannel inputChannel() {
    return new DirectChannel();
}


@Bean
@BridgeTo
public MessageChannel replyChannel() {
    return new DirectChannel();
}

为了在我添加了标题丰富器后查阅路由单

@BridgeTo

此实现有效，但在 2 次中有效，在调试了 spring 代码后，我偶然发现了这段代码并找出了问题所在。

在 UnicastingDispatcher 类中

private boolean doDispatch(Message<?> message) {
    if (this.tryOptimizedDispatch(message)) {
        return true;
    }
    boolean success = false;
    Iterator<MessageHandler> handlerIterator = this.getHandlerIterator(message);
    if (!handlerIterator.hasNext()) {
        throw new MessageDispatchingException(message, "Dispatcher has no subscribers");
    }
    List<RuntimeException> exceptions = new ArrayList<RuntimeException>();
    while (!success && handlerIterator.hasNext()) {
        MessageHandler handler = handlerIterator.next();
        try {
            handler.handleMessage(message);
            success = true; // we have a winner.
        }
        catch (Exception e) {
            RuntimeException runtimeException = this.wrapExceptionIfNecessary(message, e);
            exceptions.add(runtimeException);
            this.handleExceptions(exceptions, message, !handlerIterator.hasNext());
        }
    }
    return success;
}


Iterator<MessageHandler> handlerIterator = this.getHandlerIterator(message);

给出 [org.springframework.integration.jms.JmsSendingMessageHandler#11, routingSlip.replyChannel.bridgeTo.handler]

它是循环采摘的。因此，一旦它选择了 BridgeHandler 和 JmsSendingMessageHandler 下一个。

是否有任何我一直错过咨询 BridgeHandler 的配置？

4

1 回答 1

2

看起来您的频道上有两个订阅者。

当一个通道上有多个消费者时，循环调度是正常的。

于 2016-05-24T13:39:17.620 回答