你可以配置输出绑定以通过设置其 partitionKeyExpression 或 partitionKeyExtractorName 属性中的一个（也是唯一一个）及其 partitionCount 属性来发送分区数据。

例如，以下是一个有效且典型的配置：

spring.cloud.stream.bindings.output.producer.partitionKeyExpression=payload.id
spring.cloud.stream.bindings.output.producer.partitionCount=5

基于该示例配置，数据通过以下逻辑发送到目标分区。

根据 partitionKeyExpression 为发送到分区输出通道的每条消息计算分区键的值。partitionKeyExpression 是一个 SpEL 表达式，根据用于提取分区键的出站消息进行计算。

如果一个 SpEL 表达式不足以满足你的需要，可以通过提供 org.springframework.cloud.stream.binder.PartitionKeyExtractorStrategy 的实现并将其配置为 bean（通过使用 @Bean 注解）来计算分区键值。如果在应用程序上下文中有多个类型为 org.springframework.cloud.stream.binder.PartitionKeyExtractorStrategy 的 bean，则可以通过使用 partitionKeyExtractorName 属性指定其名称来进一步筛选它，如下例所示：

--spring.cloud.stream.bindings.output.producer.partitionKeyExtractorName=customPartitionKeyExtractor
--spring.cloud.stream.bindings.output.producer.partitionCount=5
. . .
@Bean
public CustomPartitionKeyExtractorClass customPartitionKeyExtractor() {
    return new CustomPartitionKeyExtractorClass();
}

计算完消息键后，分区选择过程将目标分区确定为介于 0 和 partitionCount - 1 之间的值。适用于大多数方案的默认计算基于以下公式：key.hashCode() % partitionCount。这可以在绑定上自定义，方法是设置要根据 'key'（通过 partitionSelectorExpression 属性）对其进行计算的 SpEL 表达式，或者将 org.springframework.cloud.stream.binder.PartitionSelectorStrategy 的实现配置为 bean（通过使用 @Bean 注解）。与 PartitionKeyExtractorStrategy 类似，当应用程序上下文中有多个此类 bean 可用时，可以使用 spring.cloud.stream.bindings.output.producer.partitionSelectorName 属性进一步筛选它，如下例所示：

--spring.cloud.stream.bindings.output.producer.partitionSelectorName=customPartitionSelector
. . .
@Bean
public CustomPartitionSelectorClass customPartitionSelector() {
    return new CustomPartitionSelectorClass();
}

通过设置分区属性以及应用程序本身的 instanceIndex 和 instanceCount 属性，将输入绑定（使用通道名称 input）配置为接收 partitioned 数据，如下例所示：

spring.cloud.stream.bindings.input.consumer.partitioned=true
spring.cloud.stream.instanceIndex=3
spring.cloud.stream.instanceCount=5

instanceCount 值表示应用程序实例的总数，应在这些实例之间对数据进行分区。instanceIndex 必须是多个实例之间的唯一值，其值介于 0 和 instanceCount - 1 之间。实例索引帮助每个应用程序实例识别从中接收数据的唯一分区。使用不支持本地分区的技术的绑定器需要它。例如，对于 RabbitMQ，每个分区都有一个队列，队列名称包含实例索引。对于 Kafka，如果 autoRebalanceEnabled 为 true（默认值），则 Kafka 负责跨实例分布分区，而不需要这些属性。如果 autoRebalanceEnabled 设置为 false，绑定器将使用 instanceCount 和 instanceIndex 来确定实例订阅的分区（必须至少拥有与实例相同的分区）。绑定器分配分区而不是 Kafka。如果你希望特定分区的消息总是转到同一个实例，这可能很有用。当绑定器配置需要它们时，必须正确设置这两个值，以确保使用所有数据，并且应用程序实例接收互斥的数据集。

虽然在独立情况下使用多个实例进行分区数据处理的场景可能很复杂，但 Spring Cloud 数据流可以通过正确填充输入和输出值以及让你依赖运行时基础结构提供有关实例索引和实例计数的信息来显著简化该过程。