|
此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 spring-cloud-stream 4.1.4！ |
绑定属性
绑定属性通过使用spring.cloud.stream.bindings.<bindingName>.<property>=<value>.
这<bindingName>表示正在配置的绑定的名称。
例如，对于以下函数
@Bean
public Function<String, String> uppercase() {
return v -> v.toUpperCase();
}有两个名为uppercase-in-0for input 和uppercase-out-0用于输出。有关详细信息，请参阅 [Binding 和 Binding names]。
为避免重复，Spring Cloud Stream 支持以spring.cloud.stream.default.<property>=<value>和spring.cloud.stream.default.<producer|consumer>.<property>=<value>了解常见的绑定属性。 |
当涉及到避免扩展绑定属性的重复时，应使用此格式 -spring.cloud.stream.<binder-type>.default.<producer|consumer>.<property>=<value>.
通用绑定属性
这些属性通过org.springframework.cloud.stream.config.BindingProperties
以下绑定属性可用于输入和输出绑定，并且必须以spring.cloud.stream.bindings.<bindingName>.（例如，spring.cloud.stream.bindings.uppercase-in-0.destination=ticktock).
可以使用spring.cloud.stream.default前缀（例如spring.cloud.stream.default.contentType=application/json).
- 目的地
-
绑定中间件上绑定的目标目标（例如，RabbitMQ 交换或 Kafka 主题）。 如果 binding 表示使用者绑定（输入），则可以将其绑定到多个目标，并且可以将目标名称指定为逗号分隔
String值。 否则，则改用实际的绑定名称。 无法覆盖此属性的默认值。 - 群
-
绑定的 consumer 组。 仅适用于入站绑定。 请参见 Consumer Groups。
违约：
null（表示匿名使用者）。 - contentType
-
此绑定的内容类型。 看
Content Type Negotiation.违约：
application/json. - 粘结 剂
-
此绑定使用的 Binder。 看
Multiple Binders on the Classpath了解详情。违约：
null（如果存在，则使用默认 Binder）。
消费者属性
这些属性通过org.springframework.cloud.stream.binder.ConsumerProperties
以下绑定属性仅适用于输入绑定，并且必须以spring.cloud.stream.bindings.<bindingName>.consumer.（例如，spring.cloud.stream.bindings.input.consumer.concurrency=3).
可以使用spring.cloud.stream.default.consumer前缀（例如spring.cloud.stream.default.consumer.headerMode=none).
- 自动启动
-
指示此使用者是否需要自动启动
违约：
true. - 并发
-
入站使用者的并发性。
违约：
1. - 分区
-
Consumer 是否从分区的 producer 接收数据。
违约：
false. - headerMode
-
当设置为
none，在输入时禁用标头解析。 仅对本机不支持消息标头且需要标头嵌入的消息中间件有效。 在不支持本机 Headers 的情况下使用来自非 Spring Cloud Stream 应用程序的数据时，此选项非常有用。 当设置为headers，它使用中间件的原生 header 机制。 当设置为embeddedHeaders，它将标头嵌入到消息负载中。Default：取决于 Binder 实现。
- 最大尝试次数
-
如果处理失败，则为尝试处理消息的次数（包括第一次）。 设置为
1以禁用重试。违约：
3. - backOffInitialInterval
-
重试时的回退初始间隔。
违约：
1000. - backOffMaxInterval
-
最大回退间隔。
违约：
10000. - backOffMultiplier 的
-
回退乘数。
违约：
2.0. - defaultRetryable
-
侦听器引发的异常是否未在
retryableExceptions是可重试的。违约：
true. - instanceCount
-
当设置为大于等于零的值时，它允许自定义此使用者的实例计数（如果不同于
spring.cloud.stream.instanceCount). 当设置为负值时，它默认为spring.cloud.stream.instanceCount. 看Instance Index and Instance Count了解更多信息。违约：
-1. - instanceIndex 实例索引
-
当设置为大于等于零的值时，它允许自定义此 Consumer 的实例索引（如果不同于
spring.cloud.stream.instanceIndex). 当设置为负值时，它默认为spring.cloud.stream.instanceIndex. 如果 IgnoredinstanceIndexList。 看Instance Index and Instance Count了解更多信息。违约：
-1. - instanceIndexList 实例索引列表
-
与不支持本机分区的 Binders（例如 RabbitMQ）一起使用;允许应用程序实例使用多个分区。
默认值：空。
- retryableExceptions
-
键中 Throwable 类名的映射，值中有一个布尔值。 指定将要或不会重试的异常 （和子类）。 另请参阅
defaultRetriable. 例：spring.cloud.stream.bindings.input.consumer.retryable-exceptions.java.lang.IllegalStateException=false.默认值：空。
- useNative解码
-
当设置为
true，入站消息由客户端库直接反序列化，该库必须进行相应的配置（例如，设置适当的 Kafka 生产者值反序列化器）。 使用此配置时，入站消息解组不是基于contentType的绑定。 使用本机解码时，创建者有责任使用适当的编码器（例如，Kafka 生产者值序列化器）来序列化出站消息。 此外，当使用本机编码和解码时，headerMode=embeddedHeaders属性，并且标头不会嵌入到消息中。 请参阅 producer 属性useNativeEncoding.违约：
false. - 多重
-
当设置为 true 时，底层 Binder 将在同一 input 绑定上本地多路复用目标。
违约：
false.
高级消费者配置
要为消息驱动的使用者添加底层消息侦听器容器的高级配置，请添加单个ListenerContainerCustomizerbean 添加到应用程序上下文中。
它将在应用上述属性后调用，并可用于设置其他属性。
同样，对于轮询的使用者，添加MessageSourceCustomizer豆。
以下是 RabbitMQ Binder 的示例：
@Bean
public ListenerContainerCustomizer<AbstractMessageListenerContainer> containerCustomizer() {
return (container, dest, group) -> container.setAdviceChain(advice1, advice2);
}
@Bean
public MessageSourceCustomizer<AmqpMessageSource> sourceCustomizer() {
return (source, dest, group) -> source.setPropertiesConverter(customPropertiesConverter);
}生产者属性
这些属性通过org.springframework.cloud.stream.binder.ProducerProperties
以下绑定属性仅适用于输出绑定，并且必须以spring.cloud.stream.bindings.<bindingName>.producer.（例如，spring.cloud.stream.bindings.func-out-0.producer.partitionKeyExpression=headers.id).
可以使用前缀spring.cloud.stream.default.producer（例如，spring.cloud.stream.default.producer.partitionKeyExpression=headers.id).
- 自动启动
-
指示此使用者是否需要自动启动
违约：
true. - partitionKeyExpression 的
-
一个 SPEL 表达式，用于确定如何对出站数据进行分区。 如果设置，则对此绑定上的出站数据进行分区。
partitionCount必须设置为大于 1 的值才能生效。 看Partitioning.默认值：null。
- partitionKeyExtractorName
-
实现
PartitionKeyExtractorStrategy.用于提取用于计算的 key 分区 ID（参见 'partitionSelector*'）。与 'partitionKeyExpression' 互斥。默认值：null。
- partitionSelectorName （分区选择器名称）
-
实现
PartitionSelectorStrategy.用于确定基于分区 ID 在分区键上（参见 'partitionKeyExtractor*'）。与 'partitionSelectorExpression' 互斥。默认值：null。
- partitionSelectorExpression 的
-
用于自定义分区选择的 SPEL 表达式。 如果两者都未设置，则选择分区作为
hashCode(key) % partitionCount哪里key是通过partitionKeyExpression.违约：
null. - partitionCount
-
数据的目标分区数 （如果启用了分区）。 如果生产者已分区，则必须设置为大于 1 的值。 在 Kafka 上，它被解释为提示。改用 this 和目标主题的分区计数中的较大者。
违约：
1. - 必需组
-
一个以逗号分隔的组列表，创建者必须确保将消息传送到这些组，即使它们在创建消息后启动（例如，通过在 RabbitMQ 中预先创建持久队列）。
- headerMode
-
当设置为
none，它会在输出时禁用标头嵌入。 它仅对本机不支持消息标头且需要嵌入标头的消息中间件有效。 在不支持本机标头的情况下为非 Spring Cloud Stream 应用程序生成数据时，此选项非常有用。 当设置为headers，它使用中间件的原生 header 机制。 当设置为embeddedHeaders，它将标头嵌入到消息负载中。Default：取决于 Binder 实现。
- useNativeEncoding
-
当设置为
true，出站消息由客户端库直接序列化，该库必须进行相应的配置（例如，设置适当的 Kafka 生产者值序列化器）。 使用此配置时，出站消息封送处理不基于contentType的绑定。 使用本机编码时，使用者有责任使用适当的解码器（例如，Kafka 使用者值反序列化器）来反序列化入站消息。 此外，当使用本机编码和解码时，headerMode=embeddedHeaders属性，并且标头不会嵌入到消息中。 请参阅 consumer 属性useNativeDecoding.违约：
false. - errorChannelEnabled
-
当设置为 true 时，如果 Binders 支持异步发送结果，则发送失败将发送到目标的错误通道。有关更多信息，请参阅错误处理。
默认值：false。
高级 Producer 配置
在某些情况下，Producer Properties 不足以在 Binder 中正确配置生产 MessageHandler，或者您可能更喜欢编程方法
在配置此类生成 MessageHandler 时。无论出于何种原因，spring-cloud-stream 都提供了ProducerMessageHandlerCustomizer来完成它。
@FunctionalInterface
public interface ProducerMessageHandlerCustomizer<H extends MessageHandler> {
/**
* Configure a {@link MessageHandler} that is being created by the binder for the
* provided destination name.
* @param handler the {@link MessageHandler} from the binder.
* @param destinationName the bound destination name.
*/
void configure(H handler, String destinationName);
}如您所见，它允许您访问生产MessageHandler您可以根据需要进行配置。
您需要做的就是提供此策略的实现并将其配置为@Bean.