无法自动装配Spring Cloud Stream Binding至Integration Flow Bean

针对你遇到的author-publisher-out-0 MessageChannel无法注入到IntegrationFlow的问题，核心原因是Bean初始化顺序冲突：Spring Cloud Stream的绑定通道Bean是在应用上下文初始化的后期创建的，而IntegrationFlow的Bean初始化时机更早，导致创建fileUploadFlow时目标通道还未被实例化。

下面提供几种可行的解决方式：

方式1：使用@Lazy延迟注入 #

通过@Lazy注解让Spring在实际需要使用MessageChannel时才去查找并注入，避免初始化顺序问题：

@Bean
public IntegrationFlow fileUploadFlow(FileRecordSplitter fileRecordSplitter, 
                                      @Lazy @Qualifier("author-publisher-out-0") MessageChannel messageChannel) {
    return IntegrationFlow.from(Files.inboundAdapter(new File(FILE_PATH))
                    .patternFilter("*final.txt")
                    .scanEachPoll(true),
            e -> e.poller(Pollers.fixedDelay(1000)))
            .split(fileRecordSplitter)
            .channel(messageChannel)
            .get();
}

方式2：使用Spring Cloud Stream的Integration出站适配器（推荐） #

放弃直接注入MessageChannel，改用Spring Cloud Stream提供的Stream.outboundAdapter，通过StreamBridge发送消息，这种方式更贴合Spring Cloud Stream的编程模型，也从根源上避免了Bean顺序问题：

@Bean
public IntegrationFlow fileUploadFlow(FileRecordSplitter fileRecordSplitter, 
                                      StreamBridge streamBridge) {
    return IntegrationFlow.from(Files.inboundAdapter(new File(FILE_PATH))
                    .patternFilter("*final.txt")
                    .scanEachPoll(true),
            e -> e.poller(Pollers.fixedDelay(1000)))
            .split(fileRecordSplitter)
            .handle(Stream.outboundAdapter(streamBridge)
                    .bindingName("author-publisher-out-0"))
            .get();
}

方式3：指定Bean依赖顺序（不推荐） #

通过@DependsOn强制让IntegrationFlow在author-publisher-out-0通道之后初始化，但这种方式硬编码了Bean名称，维护性较差：

@Bean
@DependsOn("author-publisher-out-0")
public IntegrationFlow fileUploadFlow(FileRecordSplitter fileRecordSplitter, 
                                      @Qualifier("author-publisher-out-0") MessageChannel messageChannel) {
    // 原集成流代码
    return IntegrationFlow.from(Files.inboundAdapter(new File(FILE_PATH)).patternFilter("*final.txt").scanEachPoll(true),
            e -> e.poller(Pollers.fixedDelay(1000)))
            .split(fileRecordSplitter)
            .channel(messageChannel)
            .get();
}

验证配置正确性 #

你的Spring Cloud Stream配置是正确的：output-bindings: author-publisher对应生成的author-publisher-out-0绑定通道，移除集成流后Actuator能看到该Bean也证明了配置没有问题，核心矛盾还是初始化顺序。

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