Spring Integration Java DSL中IntegrationFlow与服务层通信的推荐方式

我正在研究Spring Integration，更具体地说是Java DSL。

DSL由IntegrationFlows工厂提供的IntegrationFlowBuilder实现，它会生成IntegrationFlow组件，该组件需通过@Bean注解注册为Spring Bean。构建器模式用于将任意复杂结构表示为可接受lambda作为参数的方法层级。

我理解需要在配置类中定义@Bean，比如下面这段代码：

@Bean
fun ftpInboundIntegrationFlow(ftpSf: DefaultFtpSessionFactory?): IntegrationFlow {
    val ftpSpecification = Ftp
        .inboundStreamingAdapter(template())
        .patternFilter("*.csv")
        .remoteDirectory(fromFolder)

    return IntegrationFlows
        .from(ftpSpecification) { pc: SourcePollingChannelAdapterSpec ->
            pc.poller { pm: PollerFactory ->
                pm.cron(cronSyncExpression)
            }
        }
        .transform(StreamTransformer())
        .channel(doSomeBusinessLogic)
        .get()
}

但我困惑的是，如何在具体的服务层中处理这条消息。我目前的做法是在服务类中创建另一个@Bean，并且似乎可以正常工作：

@Bean
fun handleDoSomeBusinessLogicFlow(): IntegrationFlow {
    return IntegrationFlows.from("doSomeBusinessLogic")
        .handle { customers: List<SomeDomainModel>, headers: MessageHeaders ->
            //Some repository and service logic
        }
        .get()
}

我查阅了官方示例，但几乎所有示例都将所有逻辑写在同一位置。我觉得在@Service类中定义@Bean的做法很奇怪，想了解推荐的通信方式。

推荐实现方案 #

你不需要在@Service类中定义IntegrationFlow类型的@Bean，这种做法确实违背了分层设计的原则。以下两种方式更符合Spring生态的最佳实践：

1. 配置类直接引用服务类方法 #

在配置类的集成流程中，通过.handle()直接调用服务类的业务方法，保持流程编排与业务逻辑的分离：

// 集成配置类
@Configuration
class IntegrationConfig {

    @Bean
    fun ftpInboundIntegrationFlow(ftpSf: DefaultFtpSessionFactory?, businessService: BusinessService): IntegrationFlow {
        val ftpSpecification = Ftp
            .inboundStreamingAdapter(template())
            .patternFilter("*.csv")
            .remoteDirectory(fromFolder)

        return IntegrationFlows
            .from(ftpSpecification) { pc: SourcePollingChannelAdapterSpec ->
                pc.poller { pm: PollerFactory ->
                    pm.cron(cronSyncExpression)
                }
            }
            .transform(StreamTransformer())
            .handle(businessService, "processCustomers") // 绑定服务类的指定方法
            .get()
    }
}

// 业务服务类
@Service
class BusinessService {
    // 专门处理消息的业务方法
    fun processCustomers(customers: List<SomeDomainModel>, headers: MessageHeaders) {
        // 这里编写仓库操作、业务逻辑等代码
    }
}

2. 使用@ServiceActivator注解绑定通道 #

在服务类的业务方法上添加@ServiceActivator注解，指定要监听的通道名称，Spring会自动将通道中的消息路由到该方法处理，无需额外定义IntegrationFlow Bean：

// 业务服务类
@Service
class BusinessService {

    @ServiceActivator(inputChannel = "doSomeBusinessLogic")
    fun processCustomers(customers: List<SomeDomainModel>, headers: MessageHeaders) {
        // 这里编写仓库操作、业务逻辑等代码
    }
}

这种方式下，你原来配置类中的ftpInboundIntegrationFlow代码可以完全保留，无需修改。

核心设计原则 #

• 配置类负责集成流程编排：专注于适配器、转换器、通道路由等集成相关的配置
• 服务类专注业务逻辑：只处理具体的业务规则，通过注解或方法引用与集成流程对接
• 避免跨层混合职责：不在服务类中定义集成Bean，保持分层清晰，代码更易维护

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