SQS 队列监听器（Spring Boot）

Question

如何使用 SQS 控制请求。假设在 SQS 中同时提交了 4 个请求，那么一次只需要处理一个。一旦第一个完成，从进程中的队列中获取第二个请求，这个过程需要继续。

我在 springboot 中使用 @SqsListener 来获取消息负载。

Answer 1

您可以定义一个SimpleMessageListenerContainerFactory bean 并配置监听器行为如下：

@Bean
public SimpleMessageListenerContainerFactory simpleMessageListenerContainerFactory(AmazonSQSAsync amazonSqs) {
    SimpleMessageListenerContainerFactory factory = new SimpleMessageListenerContainerFactory();
    [...]
    factory.setAmazonSqs(amazonSqs);
    factory.setMaxNumberOfMessages(1);
    [...]

    return factory;
}