Spring Integration DSL-带网关块线程的组合

Question

我试图了解如何将IntegrationFlow构建为单元，并将它们连接起来。

我设置了一个非常简单的处理集成流：

IntegrationFlow processingFlow = f -> f
                .<String>handle((p, h) -> process(p))
                .log();

        flowContext.registration(processingFlow)
                .id("testProcessing")
                .autoStartup(false)
                .register();

处理非常简单：

   public String process(String process) {
            return process + " has been processed";
    }

然后，使用.gateway()从一个源组成一个流，将该源加入到处理中：

  MessageChannel beginningChannel = MessageChannels.direct("beginning").get();

        StandardIntegrationFlow composedFlow = IntegrationFlows
                .from(beginningChannel)
                .gateway(processingFlow)
                .log()
                .get();

        flowContext.registration(composedFlow)
                .id("testComposed")
                .autoStartup(false)
                .addBean(processingFlow)
                .register();

 composedFlow.start();

 beginningChannel.send(MessageBuilder.withPayload(new String("first string")).build());
 beginningChannel.send(MessageBuilder.withPayload(new String("second string")).build());

日志处理程序确认已经为第一条消息调用了handle方法，但是主线程随后处于空闲状态，并且永远不会处理第二条消息。

这难道不是从构建块组成集成流的正确方法吗？在通道中这样做需要将通道注册为bean，我试图动态地完成所有这些。

Answer 1

它必须是processingflow中的logandreply()。看看他们的JavaDocs有什么不同。流末尾的log()使其成为单向的。这就是为什么您被阻止，因为网关等待回复，但没有人符合您当前的流定义。不幸的是，我们不能从框架级别确定这一点：可能会有一些情况，当您确实没有根据路由或过滤逻辑返回时。网关可以配置应答超时。默认情况下，它是无限的。