Spring Cloud Stream 为 KafkaRabbit MQ 提供了 Binder 实现。 该框架还包括一个测试绑定器,用于将应用程序作为 spring-cloud-stream 应用程序进行集成测试。有关详细信息,请参阅 [测试] 部分。Spring中文文档

Binder 抽象也是框架的扩展点之一,这意味着您可以在 Spring Cloud Stream 之上实现自己的 Binder。 在如何从头开始创建Spring Cloud Stream Binder中,发布社区成员文档 详细地,举例说明实现自定义活页夹所需的一组步骤。 该部分还突出显示了这些步骤。Implementing Custom BindersSpring中文文档

Spring Cloud Stream 使用 Spring Boot 进行配置,而 Binder 抽象使 Spring Cloud Stream 应用程序能够灵活地连接到中间件。 例如,部署人员可以在运行时动态选择外部目标(如 Kafka 主题或 RabbitMQ 交换)和输入之间的映射 以及消息处理程序的输出(例如函数的输入参数及其返回参数)。 此类配置可以通过外部配置属性以及 Spring Boot 支持的任何形式(包括应用程序参数、环境变量和/或文件)提供。 在 Spring Cloud Stream 简介部分的接收器示例中,将 application 属性设置为使其从 Kafka 主题或绑定到 RabbitMQ 交换的队列中读取。application.ymlapplication.propertiesspring.cloud.stream.bindings.input.destinationraw-sensor-dataraw-sensor-dataraw-sensor-dataSpring中文文档

Spring Cloud Stream 会自动检测并使用类路径上的绑定器。 您可以使用不同类型的中间件和相同的代码。 为此,请在构建时包含不同的活页夹。 对于更复杂的用例,您还可以将多个绑定器打包到应用程序中,并让它在运行时选择绑定器(甚至是否为不同的绑定使用不同的绑定器)。Spring中文文档