通过Mass Transit向Azure Service Bus发送消息：设置分区键方法咨询

嘿，刚好做过相关配置，来给你详细唠唠怎么操作～

Azure Service Bus Premium默认启用分区，Mass Transit提供了几种灵活的方式来设置分区键，确保同键的消息路由到同一个分区，保证消息的顺序性：

1. 发送单条消息时手动指定分区键 #

如果需要针对特定消息自定义分区键，可以在发送时通过上下文直接设置：

// 假设bus是你的IBus实例
await bus.Send(new OrderSubmittedEvent
{
    OrderId = "ORD-12345",
    CustomerId = "CUST-9876"
}, context =>
{
    // 这里可以用业务字段作为分区键，比如用CustomerId保证同一客户的消息在同一分区
    context.SetPartitionKey(context.Message.CustomerId);
});

2. 为消息类型配置默认分区键规则 #

如果某类消息都需要遵循相同的分区键生成逻辑，可以在Mass Transit的全局配置阶段设置默认格式化器：

busFactoryConfigurator.ConfigureEndpoints(host);

// 为OrderSubmittedEvent类型设置默认分区键规则
busFactoryConfigurator.Message<OrderSubmittedEvent>(x =>
{
    // 自动用消息中的CustomerId字段作为分区键
    x.SetPartitionKeyFormatter(context => context.Message.CustomerId);
});

这样后续发送这类消息时，不用每次手动设置，Mass Transit会自动应用这个规则生成分区键。

3. 结合Session使用（SessionId自动作为分区键） #

如果你的场景需要会话（Session）特性，那SessionId会自动被用作分区键，此时只需要设置SessionId即可：

await bus.Send(new OrderSubmittedEvent(), context =>
{
    context.SessionId = "CUST-9876"; // 这个SessionId会直接作为分区键使用
});

这种方式适合需要会话一致性的场景，同时能天然利用分区的顺序保障特性。

一些关键注意事项 #

• 分区键的长度不能超过256个字符，否则Azure Service Bus会直接拒绝消息
• 同一分区键的消息会被严格按顺序处理，但不同分区的消息是并行处理的
• 一旦确定了分区键规则，尽量避免中途修改，否则可能破坏已有的消息顺序性

内容的提问来源于stack exchange，提问作者ravi shanker