|
此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 spring-cloud-stream 4.1.4！ |
Binder SPI
Binder SPI 由许多接口、开箱即用的实用程序类和发现策略组成，它们为连接到外部中间件提供了可插拔的机制。
SPI 的关键点是Binder接口，这是一种将输入和输出连接到外部中间件的策略。下面的清单显示了Binder接口：
public interface Binder<T, C extends ConsumerProperties, P extends ProducerProperties> {
Binding<T> bindConsumer(String bindingName, String group, T inboundBindTarget, C consumerProperties);
Binding<T> bindProducer(String bindingName, T outboundBindTarget, P producerProperties);
}该接口是参数化的，提供了许多扩展点：
-
输入和输出绑定目标。
-
扩展了使用者和生产者属性，允许特定的 Binder 实现添加可以以类型安全方式支持的补充属性。
典型的 Binder 实现包括以下内容：
-
实现
Binder接口; -
弹簧
@Configuration类创建类型为Binder以及中间件连接基础设施。 -
一个
META-INF/spring.binders文件，如以下示例所示：kafka:\ org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration
如前所述，Binder 抽象也是框架的扩展点之一。因此，如果你在前面的列表中找不到合适的 Binder，你可以在 Spring Cloud Stream 上实现自己的 Binder。
在如何从头开始创建 Spring Cloud Stream Binder 中，发布社区成员文档
具体来说，通过一个示例，实现自定义 Binder 所需的一组步骤。
这些步骤也会在Implementing Custom Binders部分。 |