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

Binder SPI

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