Spring Cloud Stream 提供了一个 Binder 抽象,用于连接到外部中间件的物理目标。 本节提供有关 Binder SPI 背后的主要概念、其主要组件和特定于实现的详细信息的信息。Spring中文文档

生产者和消费者

下图显示了生产者和消费者的一般关系:Spring中文文档

生产者 消费者
图 1.生产者和消费者

生产者是将消息发送到绑定目标的任何组件。 绑定目标可以绑定到具有该代理实现的外部消息代理。 调用该方法时,第一个参数是代理中目标的名称,第二个参数是生产者向其发送消息的本地目标实例,第三个参数包含要在为该绑定目标创建的适配器中使用的属性(例如分区键表达式)。BinderbindProducer()Spring中文文档

使用者是从绑定目标接收消息的任何组件。 与生产者一样,使用者可以绑定到外部消息代理。 调用该方法时,第一个参数是目标名称,第二个参数提供使用者的逻辑组的名称。 由给定目标的使用者绑定表示的每个组都会收到生产者发送到该目标的每条消息的副本(即,它遵循正常的发布-订阅语义)。 如果有多个使用者实例绑定了相同的组名,则消息将在这些使用者实例之间进行负载均衡,以便生产者发送的每条消息仅由每个组中的单个使用者实例使用(即,它遵循正常的排队语义)。bindConsumer()Spring中文文档