如何实现Amazon SQS消息投递至服务的所有运行实例？

你遇到的轮询分发现象是SQS的原生特性导致的：SQS为点对点消息队列模型，同一条消息仅会被同一消费组中的一个消费者消费，天然不支持广播消费模式，因此多实例订阅同一队列时只能轮流收到消息，不符合所有实例接收全量消息的需求。

方案1：AWS官方推荐 SNS+SQS 扇出模式（生产级最优解） #

这是AWS原生支持的广播场景标准实现，改造成本低、可靠性高，适配动态扩缩容场景：

• 新建SNS主题，调整Service A的生产者逻辑，将原发送到SQS队列的消息改为发送到该SNS主题。Spring Cloud AWS环境下仅需修改消息目的地配置为SNS主题ARN，上层发送代码无需改动：

  // Spring Cloud AWS SNS发送示例
  snsTemplate.sendNotification("arn:aws:sns:区域:账号ID:主题名", 消息内容, "消息标题");
  

• 每个Service B实例启动时自动创建专属SQS队列，队列名可带上实例唯一标识（如ECS任务ID、实例IP、随机UUID）避免重复，再将该专属队列订阅到上述SNS主题。SNS会自动将收到的每条消息复制推送到所有关联订阅的SQS队列，实现消息扇出。
• 每个Service B实例仅消费自身专属的SQS队列消息，即可保证所有运行实例都能收到全量消息。Spring Boot中可通过@SqsListener注解指定消费队列：

  // Spring Cloud AWS SQS消费示例
  @SqsListener("${spring.application.name}-queue-${instance.id}")
  public void consumeMessage(String message) {
    // 执行业务处理逻辑
  }
  

• 补充配置：设置SQS队列的生命周期规则，实例下线时自动删除对应队列和SNS订阅，避免无效资源占用。

方案2：轻量改造方案（仅适合固定实例数的小体量场景） #

如果不希望引入SNS组件，且Service B的实例数长期固定无动态扩缩容需求，可直接为每个Service B实例创建独立的SQS队列，Service A发送消息时同时向所有Service B对应的SQS队列各发送一次。该方案扩展性差，实例数量变更时需要同步修改生产者逻辑，不建议生产环境使用。

注意事项 #

• 若对消息可靠性要求高，不要使用临时SQS队列，可配置队列消息保留周期最长至14天，实例异常重启后仍可消费未处理的历史消息。
• 提前配置好SNS到SQS的消息发送权限，以及Service B实例对专属队列的消费权限，避免权限不足导致消息丢失。

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