SQS队列侦听器(Springboot)

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;
}