Spring Boot中如何为@SQSListener指定对应AWS账户的SQS配置？

1. 为每个SqsAsyncClient配置添加限定符 #

在两个SQS配置类中，给各自的SqsAsyncClient Bean加上@Qualifier注解，明确区分不同账户的客户端：

账户A的配置示例：

@Configuration
public class AwsAccountASqsConfig {

    @Bean
    @Qualifier("accountA")
    public SqsAsyncClient sqsAsyncClientAccountA() {
        // 配置账户A的IAM凭据、区域等信息
        return SqsAsyncClient.builder()
                .credentialsProvider(accountACredentialsProvider())
                .region(Region.of("us-east-1"))
                .build();
    }
}

账户B的配置示例：

@Configuration
public class AwsAccountBSqsConfig {

    @Bean
    @Qualifier("accountB")
    public SqsAsyncClient sqsAsyncClientAccountB() {
        // 配置账户B的IAM凭据、区域等信息
        return SqsAsyncClient.builder()
                .credentialsProvider(accountBCredentialsProvider())
                .region(Region.of("eu-west-1"))
                .build();
    }
}

2. 为每个账户创建独立的SqsListenerContainerFactory #

针对每个SqsAsyncClient，创建对应的SqsListenerContainerFactory，绑定对应客户端并添加限定符：

账户A的容器工厂：

@Configuration
public class AwsAccountASqsConfig {

    // 上述SqsAsyncClient Bean...

    @Bean
    @Qualifier("accountAQueueFactory")
    public SqsListenerContainerFactory<?> sqsListenerContainerFactoryAccountA(
            @Qualifier("accountA") SqsAsyncClient sqsAsyncClient) {
        return SqsListenerContainerFactory.builder()
                .sqsAsyncClient(sqsAsyncClient)
                // 可按需添加并发数、重试策略等容器配置
                .build();
    }
}

账户B的容器工厂：

@Configuration
public class AwsAccountBSqsConfig {

    // 上述SqsAsyncClient Bean...

    @Bean
    @Qualifier("accountBQueueFactory")
    public SqsListenerContainerFactory<?> sqsListenerContainerFactoryAccountB(
            @Qualifier("accountB") SqsAsyncClient sqsAsyncClient) {
        return SqsListenerContainerFactory.builder()
                .sqsAsyncClient(sqsAsyncClient)
                .build();
    }
}

3. 在@SQSListener中指定对应容器工厂 #

在监听类的方法上，通过factory属性指定对应账户的容器工厂，必须使用队列完整ARN（避免跨账户时框架自动拼接错误的账户ID）：

账户A的监听类：

@Component
public class AccountAQueueListener {

    @SQSListener(value = "arn:aws:sqs:us-east-1:ACCOUNT_A_ID:queue-a", factory = "accountAQueueFactory")
    public void handleAccountAMessage(String message) {
        // 处理账户A队列的消息
    }
}

账户B的监听类：

@Component
public class AccountBQueueListener {

    @SQSListener(value = "arn:aws:sqs:eu-west-1:ACCOUNT_B_ID:queue-b", factory = "accountBQueueFactory")
    public void handleAccountBMessage(String message) {
        // 处理账户B队列的消息
    }
}

额外优化（可选） #

如果不想让框架自动创建队列，可在容器工厂中关闭该功能：

return SqsListenerContainerFactory.builder()
        .sqsAsyncClient(sqsAsyncClient)
        .configure(options -> options.setAutoCreateQueue(false))
        .build();

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