Spring Cloud 2020.0.0中的Spring Cloud总线/流问题

Question

我们有一个Spring Boot Microservice，它不仅有HTTPendpoint使用Spring Cloud Bus来获取刷新事件（从兔子），还有一个Spring Cloud Stream Sink可以从另一个兔子主题获取自定义消息。

更新到Spring Boot 2.4.1和Spring Cloud 2020.0.0后，一切似乎都在正常工作，直到我们发现Spring Cloud Bus不再接收事件。深入研究后，发现一些Spring Cloud Bus内部通道没有被创建。

这在另一个没有流功能的服务中没有发生，所以我们测试了禁用流功能，然后总线功能开始工作。因此，很明显，旧的流模型和新的Spring云总线之间存在某种干扰。

在更新我们的接收器以使用新的功能模型之后，我仍然存在问题，并最终通过在应用程序中包含以下几行代码来实现这两个功能。yml：

spring:
  cloud:
    stream:
      bindings.mySink-in-0.destination: mytopic
      function.definition: busConsumer;mySink

所以我有以下问题

1. 我是否错过了一些东西，或者是否应该有更好的文档来说明流/总线如何相互影响以及迁移到2020.0.0
2. 我当前的配置看起来正确吗
3. 在这里必须包含总线消费者似乎是不对的——它的自动配置是否应该不能与任何其他流配置“组合在一起”
4. Spring之间的区别是什么。云流动作用定义和Spring。云作用定义？我在文档中看到，Spring云总线似乎也在设置Spring。云作用定义=总线消费者

Answer 1

在org.springframework.cloud.stream.function.FunctionConfiguration中，它会搜索@Enable绑定。

if（ObjectUtils.isEmpty（applicationContext.getBeanNamesForAnnotation（EnableBinding.class））

如果找到，则禁用功能绑定。看到这个了吗

logger.info（"由于配置中@EnableBinda注释的存在，禁用了函数绑定"）；

升级后，我们需要将Listener类转换为使用功能接口以激活功能绑定。之后，也将创建云总线消费者绑定。