java - 使用@SqsListener 注释为 FIFO 配置消息组 ID

Question

我正在使用 Spring 云 API 提供的@SqsListener 来使用来自 FIFO 队列的消息。我想使用基于特定消息组 ID 的消息。不确定在哪里配置此设置。

我尝试阅读 AWS spring cloud 文档并进行了一些谷歌搜索，但找不到答案或示例。

我的注释看起来像这样:

@SqsListener(value = orderQueue, deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS)

我有以下 SQS 配置:

        public QueueMessagingTemplate queueMessagingTemplate(AmazonSQSAsync amazonSQSAsync) {
            return new QueueMessagingTemplate(amazonSQSAsync);
        }

并使用以下依赖项:

            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-aws</artifactId>
            <version>2.0.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-aws-messaging</artifactId>
            <version>2.0.0.RELEASE</version>
        </dependency>

我主要是在寻找有关如何配置@SqsListener 以根据消息组 ID 读取消息的答案。

Answer 1

我不认为即使是 AWS sdk 也提供了一种通过 groupId 消费消息的方法。 groupId 基本上只是一种在 Fifo 队列中构建消息集群的机制。然后保证集群内的消息按发送顺序传送。