Binder 抽象

Spring Cloud Stream 为 Kafka 和 Rabbit MQ 提供了 Binder 实现。 该框架还包括一个测试 Binder，用于将应用程序作为 spring-cloud-stream 应用程序进行集成测试。有关更多详细信息，请参阅 [测试] 部分。spring-doc.cn

Binder 抽象也是框架的扩展点之一，这意味着您可以在 Spring Cloud Stream 之上实现自己的 Binder。 在如何从头开始创建 Spring Cloud Stream Binder 中，发布社区成员文档 具体来说，通过一个示例，实现自定义 Binder 所需的一组步骤。 该部分还会突出显示这些步骤。Implementing Custom Bindersspring-doc.cn

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

Spring Cloud Stream 会自动检测并使用在 Classpath 上找到的 Binder。 您可以将不同类型的中间件与相同的代码一起使用。 为此，请在构建时包含不同的 Binder。 对于更复杂的用例，您还可以将多个 Binder 与应用程序打包在一起，并让它在运行时选择 Binder（甚至是否为不同的绑定使用不同的 Binder）。spring-doc.cn