amazon-web-services - Amazon Java SQS 客户端：如何有选择地从队列中删除消息？

Question

我有一个 Spring Boot 类，它从（当前）FIFO SQS 队列接收消息，如下所示：

ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest()
        .withQueueUrl(queueUrl)
        .withMaxNumberOfMessages(numMessages);

Map<String, String> messageMap = new HashMap<>();
try {
    List<Message> messages = sqsClient.receiveMessage(receiveMessageRequest).getMessages();

    if (!messages.isEmpty()) {
        if (messages.size() == 1) {
            Message message = messages.get(0);
            String messageBody = message.getBody();
            String receiptHandle = message.getReceiptHandle();
         // snipped
        }
    }
 }

我希望能够“跳过”消息并仅找到要从该队列中删除的特定消息。我的领导确信这是可以做到的，但我有疑问。这些是我的想法：

• 如果我更改为标准队列，可以这样做吗？
• 我看到您必须收到一条消息才能receiptHandle获取DeleteMessageRequest.
• 但是如果我收到一条我想要处理的消息，而不是要删除的消息，我该如何将它放回队列中？
• 我是否可以扩展visibilityTimeout以让稍后接收消息？

标签： amazon-web-servicesamazon-sqs

Answer 1

1. 是的，正如您描述的那样：接收消息，提取回执句柄，提交删除消息请求
2. 是的
3. 通过简单地不做任何事情，消息将在其可见性超时到期后自动弹回队列中。请注意，即使是这样的基本接收也会增加接收计数器，并且可能会根据您的配置将消息推送到 dlq
4. 不，延长可见性超时只会进一步延迟进一步处理