如何使用@SqsListener读取其他AWS账户的SQS队列消息

1. 问题根因 #

你之前的配置错误在于：SQS服务的endpoint仅需指定区域级服务地址，不需要拼接账户ID。账户ID是队列资源路径的一部分，不需要在客户端全局endpoint配置中定义。

2. 两种可行实现方案 #

方案一：直接在@SqsListener中填写完整队列URL #

无需修改全局配置，直接将带目标账户ID的完整队列URL填入注解的value参数即可，示例：

// 替换为实际的区域、目标账户ID、队列名称
@SqsListener(value = ["https://sqs.us-east-1.amazonaws.com/123456789012/third-party-queue"], deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS)
fun consumeMessage(message: String) {
    // 消息处理逻辑
}

同时修正你的SQS客户端Bean配置，endpoint不需要带账户ID：

@Bean
fun amazonSQSAsyncClient(): AmazonSQSAsync = AmazonSQSAsyncClientBuilder.standard()
.withCredentials(AWSStaticCredentialsProvider(BasicAWSCredentials(awsProperties.accessKey, awsProperties.secretKey)))                
.withEndpointConfiguration(AwsClientBuilder.EndpointConfiguration("https://sqs.us-east-1.amazonaws.com", awsProperties.region))                
.build() 

方案二：全局配置队列所属账户ID（Spring Cloud AWS 2.0+支持） #

如果需要消费多个同账户下的跨账户队列，可以通过全局配置默认队列所属账户ID，注解仅需填写队列名称即可：
首先在application.yml中添加配置：

spring:
  cloud:
    aws:
      sqs:
        queue-owner-account-id: 第三方AWS账户ID

之后直接在注解中填写队列名即可：

@SqsListener(value = ["third-party-queue"], deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS)
fun consumeMessage(message: String) {
    // 消息处理逻辑
}

3. 必要权限校验 #

配置完成后如果仍报错，需确认双向权限配置正确：

• 第三方队列的资源访问策略已授权你的IAM用户ARN，开放sqs:ReceiveMessage、sqs:DeleteMessage、sqs:GetQueueAttributes等必要操作权限
• 你的IAM用户的身份策略已允许访问第三方队列的完整ARN，对应操作权限无限制

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