NServiceBus同一SQS队列多消息类型订阅异常问题咨询

NServiceBus端点监听SQS队列时，不会自动过滤消息类型——只要队列内存在消息，端点就会尝试拉取并处理。你的三个订阅服务均监听同一Queue1，而SQS本身是按随机/轮询逻辑分发消息给消费者的，因此MessageType1会被任意一个服务获取，无对应处理器的服务自然会报错。

有两种可行方案，可根据架构需求选择：

方案一：为每种消息类型单独创建队列 #

这是最直接的职责隔离方式：

• 给Subscriber1配置专属Queue1，仅处理MessageType1
• Subscriber2对应Queue2，处理MessageType2
• Subscriber3对应Queue3，处理MessageType3
• Subscriber1处理完MessageType1后，直接将MessageType2发送至Queue2、MessageType3发送至Queue3

该方式职责清晰，彻底避免消息错配问题，也便于单独监控每个队列的消息流转状态。

方案二：配置消息过滤，让服务仅接收指定类型 #

若不想拆分队列，可结合SQS的消息过滤功能与NServiceBus配置实现：

1. 发送消息时，为不同类型的消息添加自定义属性（例如MessageType: MessageType1）
2. 给每个订阅服务对应的SQS消费者配置过滤策略，仅接收带有对应属性的消息
3. 同时在NServiceBus端点配置中，仅注册对应消息类型的处理器，形成双重保障

示例代码（发送消息时添加属性）：

var message = new MessageType1();
var options = new SendOptions();
options.SetMessageHeader("MessageType", "MessageType1");
await endpoint.Send(message, options);

之后给Subscriber1的SQS消费者设置过滤规则：MessageType = "MessageType1"即可。

这种方式可在同一队列内实现消息定向分发，但需要额外维护过滤规则，复杂度比拆分队列更高。

你之前的误解源于对NServiceBus消息分发逻辑的不熟悉：NServiceBus的自动消息过滤仅在订阅发布模式（基于主题/订阅）下生效，而你当前使用的是直接发送到队列的点对点模式，该模式下NServiceBus不会自动过滤消息，完全依赖队列的分发规则。

内容的提问来源于stack exchange，提问作者Mr. Spock