为什么 Spring 不能自动装配我的云流处理器？

Question

我正在尝试从 spring-cloud-stream 实现一个基本处理器。我以前在其他项目上做过这个，所以我以为我很熟悉它。但是这次 Spring 在通过 @Autowire 创建 @Service 组件中的我的处理器引用时遇到了问题。

我认为重要的部分是应用程序上的@EnableBinding(my.class)，但我有。

错误是

No qualifying bean of type 'com.mycompany.config.BizSyncProcessor' available

我还尝试将@Component 添加到BizSyncProcessor，但这没有任何区别。

以下是碎片：

public interface BizSyncProcessor {

    String BUSINESS_IDS_INPUT = "updatedBusinessIdsIn";
    String BUSINESS_IDS_OUTPUT = "updatedBusinessIdsOut";

    @Output(BizSyncProcessor.BUSINESS_IDS_OUTPUT)
    MessageChannel writeUpdatedBusinessIds();

    @Input(BizSyncProcessor.BUSINESS_IDS_INPUT)
    MessageChannel readUpdatedBusinessIds();

}

@Service
public class BusinessService {

    @Autowired
    private BizSyncProcessor bizSyncProcessor;

    // methods which reference bizSyncProcessor's input and outputs
}

@EnableBinding(BizSyncProcessor.class)
@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

Answer 1

如果没有应用程序类路径中提供的一些 Binder 实现，@EnableBinding(BizSyncProcessor.class) 没有任何意义。正是该工具执行实际绑定并为我们提供特定的 bean 以进行依赖注入。

是的...看起来文档中没有明确的句子必须存在Binder实现才能触发绑定接口代理并将其注册为bean：http://cloud.spring.io/spring-cloud-static/spring-cloud-stream/2.1.0.RC3/single/spring-cloud-stream.html#_destination_binders

随时提出 GitHub 问题来询问这样的文档改进！