嘿，刚好我对Spring Integration DSL这块比较熟，我来给你捋捋怎么把原来的XML工作流转成DSL，实现转换器输出分发到多个端点的功能～

首先，你原来的XML流程核心是转换器处理后把消息广播到三个独立通道，每个通道绑定一个端点，对应DSL里最适合的就是用「发布-订阅通道」或者「多接收者路由」来实现，下面给你两种常用的实现方式：

方式一：用publishSubscribeChannel（最贴近原XML结构） #

这种方式完全对应你原来的“一个转换器输出，分发给多个通道+端点”的逻辑，每个订阅的子流就相当于原来的一个内部通道加端点：

@Configuration
@EnableIntegration
public class JmsIntegrationFlowConfig {

    @Autowired
    private ConnectionFactory jmsConnectionFactory;

    // 核心流程定义
    @Bean
    public IntegrationFlow jmsMessageProcessingFlow() {
        return IntegrationFlows.from(
                // 对应原XML的int-jms:message-driven-channel-adapter
                Jms.messageDrivenChannelAdapter(jmsConnectionFactory)
                        .destination("your-target-jms-queue") // 替换成你的JMS队列/主题名
        )
        // 对应原XML的转换器
        .transform(customMessageTransformer())
        // 发布订阅通道：转换器输出会广播给所有订阅的子流
        .publishSubscribeChannel(subscribeConfig -> subscribeConfig
                // 第一个端点：对应原XML的第一个内部通道+端点
                .subscribe(subFlow -> subFlow
                        .handle("firstProcessingEndpoint", "processMessage")
                )
                // 第二个端点
                .subscribe(subFlow -> subFlow
                        .handle("secondProcessingEndpoint", "processMessage")
                )
                // 第三个端点
                .subscribe(subFlow -> subFlow
                        .handle("thirdProcessingEndpoint", "processMessage")
                )
        )
        .get();
    }

    // 自定义转换器Bean（替换成你自己的转换器实现）
    @Bean
    public GenericTransformer<Object, Object> customMessageTransformer() {
        return message -> {
            // 这里写你的消息转换逻辑
            return transformedMessage;
        };
    }

    // 三个处理端点的Bean示例（替换成你自己的端点实现）
    @Bean
    public FirstProcessingEndpoint firstProcessingEndpoint() {
        return new FirstProcessingEndpoint();
    }

    @Bean
    public SecondProcessingEndpoint secondProcessingEndpoint() {
        return new SecondProcessingEndpoint();
    }

    @Bean
    public ThirdProcessingEndpoint thirdProcessingEndpoint() {
        return new ThirdProcessingEndpoint();
    }
}

方式二：用routeToRecipients（更灵活的路由控制） #

如果后续你需要给不同端点加条件判断（比如只给满足特定属性的消息发送到某个端点），用routeToRecipients会更方便，基础用法如下：

// 替换上面流程中的publishSubscribeChannel部分
.routeToRecipients(routeConfig -> routeConfig
        .recipient("firstProcessingEndpoint", "processMessage")
        .recipient("secondProcessingEndpoint", "processMessage")
        .recipient("thirdProcessingEndpoint", "processMessage")
        // 可选：给某个端点加条件，比如只有消息包含特定标记才发送
        // .recipientWhen("specialProcessingEndpoint", "processMessage", msg -> msg.getPayload().toString().contains("special"))
)

额外说明 #

• 如果你不想单独定义端点Bean，也可以直接在handle里用lambda表达式写处理逻辑，比如：

  .subscribe(subFlow -> subFlow
          .handle((payload, headers) -> {
              // 直接写第一个端点的处理逻辑
              System.out.println("处理第一个端点：" + payload);
              return null; // 不需要返回结果的话可以返回null
          })
  )
  

• 两种方式都能实现消息的多端点分发，publishSubscribeChannel更贴近你原来的XML结构，而routeToRecipients适合需要灵活路由规则的场景。

内容的提问来源于stack exchange，提问作者user1052610