此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 spring-cloud-stream 4.1.3！spring-doc.cn

此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 spring-cloud-stream 4.1.3！spring-doc.cn

Binder SPI 由许多接口、开箱即用的实用程序类和发现策略组成，它们为连接到外部中间件提供了可插拔的机制。spring-doc.cn

SPI 的关键点是接口，这是一种将输入和输出连接到外部中间件的策略。下面的清单显示了接口的定义：BinderBinderspring-doc.cn

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);
}

该接口是参数化的，提供了许多扩展点：spring-doc.cn

  • 输入和输出绑定目标。spring-doc.cn

  • 扩展了使用者和生产者属性，允许特定的 Binder 实现添加可以以类型安全方式支持的补充属性。spring-doc.cn

典型的 Binder 实现包括以下内容：spring-doc.cn

  • 实现接口的类;Binderspring-doc.cn

  • 一个 Spring 类，用于创建 Bean 类型以及中间件连接基础结构。@ConfigurationBinderspring-doc.cn

  • 在 Classpath 上找到的文件，包含一个或多个 Binder 定义，如以下示例所示：META-INF/spring.bindersspring-doc.cn

    kafka:\
org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration
如前所述，Binder 抽象也是框架的扩展点之一。因此，如果你在前面的列表中找不到合适的 Binder，你可以在 Spring Cloud Stream 上实现自己的 Binder。 在如何从头开始创建 Spring Cloud Stream Binder 中，发布社区成员文档 具体来说，通过一个示例，实现自定义 Binder 所需的一组步骤。 该部分还会突出显示这些步骤。Implementing Custom Binders
如前所述，Binder 抽象也是框架的扩展点之一。因此，如果你在前面的列表中找不到合适的 Binder，你可以在 Spring Cloud Stream 上实现自己的 Binder。 在如何从头开始创建 Spring Cloud Stream Binder 中，发布社区成员文档 具体来说，通过一个示例，实现自定义 Binder 所需的一组步骤。 该部分还会突出显示这些步骤。Implementing Custom Binders