不同项目同名消费者订阅同一SQS队列仅生成一个队列如何处理？

问题根因 #

该问题本质是两个服务的消费者生成的SQS队列名重复冲突：事件总线框架默认的队列命名规则仅基于消费者类名/事件类名生成队列名，没有区分不同的服务，导致两个不同服务的消费者生成了完全相同的SQS队列名，最终两个服务都监听同一个队列，事件只会被其中一个服务竞争消费到，不符合事件广播的业务预期。

最优解决方案 #

核心思路是为每个服务的所有消费队列加入唯一的服务标识前缀，确保不同服务的队列名全局唯一，同时符合事件广播的架构语义。

如果使用MassTransit作为事件总线组件，推荐使用全局端点名格式化器的方案，一次性配置全服务生效：

1. 在Payments.Api的服务注册配置中，添加带服务前缀的端点名格式化器：

services.AddMassTransit(busConfigurator =>
{
    // 第一个参数为当前服务的唯一标识，会自动作为所有队列的前缀
    busConfigurator.SetEndpointNameFormatter(new KebabCaseEndpointNameFormatter("payments", false));
    
    // 原有消费者注册、SQS配置等逻辑保持不变
    busConfigurator.AddConsumer<UserCreatedConsumer>();
    // ... 其他配置
});

2. 在Notification.Api的服务注册配置中，将前缀替换为当前服务的唯一标识：

services.AddMassTransit(busConfigurator =>
{
    busConfigurator.SetEndpointNameFormatter(new KebabCaseEndpointNameFormatter("notification", false));
    
    // 原有配置保持不变
});

如果使用其他事件总线框架，核心逻辑一致，只要确保每个服务的消费队列名包含当前服务的唯一标识即可。

方案优势 #

• 无需修改现有消费者、事件类的定义，改造成本极低
• 全局配置一次生效，后续新增消费者自动生成带服务前缀的唯一队列名，无需单独配置
• 符合SQS队列命名规则，队列名全局唯一不会冲突
• 两个服务的队列会分别绑定到UserCreated事件对应的SNS主题，事件发布后会同时推送到两个队列，两个服务互不干扰独立消费，完全符合业务需求

注意事项 #

• SQS队列名长度限制为80字符，服务前缀和事件名组合后不要超出限制
• 不要复用同一个队列供不同服务消费同个事件，否则会出现竞争消费导致事件遗漏

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