Spring 集成 Java DSL - 动态设置 RecepientListRouter 收件人？

Question

我有一个方法需要异步执行多个任务。我已经设法使用以下 IntegrationFlow 实现了这一点：

@Bean
public IntegrationFlow startJobTask() {
    return IntegrationFlows.from("TaskRoutingChannel")
            .handle("jobService", "executeTasks")
            .routeToRecipients(r -> r
                .recipient("testTaskChannel")
                .recipient("test2TaskChannel"))
            .get();
}

@Bean ExecutorChannel testTaskChannel(){
    return new ExecutorChannel(this.getAsyncExecutor());
}

@Bean ExecutorChannel test2TaskChannel(){
    return new ExecutorChannel(this.getAsyncExecutor());
}

@Bean
public Executor getAsyncExecutor() {
    SimpleAsyncTaskExecutor executor = new SimpleAsyncTaskExecutor();
    return executor;
}

@Bean
public IntegrationFlow testTaskFlow() {
    return IntegrationFlows.from("testTaskChannel")
            .handle("testTaskService", "executeAsync")
            .get();
}

@Bean
public IntegrationFlow test2TaskFlow() {
    return IntegrationFlows.from("test2TaskChannel")
            .handle("test2TaskService", "executeAsync")
            .get();
}

以上流程基本如下：

TaskRoutingChannel 调用 serviceActivator 方法 executeTasks

executeTasks returns 类似于 Message<List<myTask>>

这个 Message 被路由到频道 testTaskChannel 和 test2TaskChannel 它调用自己的异步 serviceActivator 方法。

现在，问题是我不想硬编码收件人频道。我可以通过将目标通道设置为 header 来避免使用普通路由器进行硬编码。但是，recepientListRouters 似乎无法使用表达式获取收件人通道名称。

有什么方法可以动态设置收件人频道吗？

Answer 1

首先抱歉耽搁了。

实际上常规 .route() 可以为您做到这一点，因为它恰好有这个选项：

protected abstract Collection<MessageChannel> determineTargetChannels(Message<?> message);

因此，如果您header提取returns频道列表，HeaderValueRouter将能够将消息发送给所有频道。

Spring 集成 Java DSL - 动态设置 RecepientListRouter 收件人？

Spring Integration Java DSL - Set RecepientListRouter recipients dynamically?

java

dsl

router

asynchronous

spring-integration