Java操作AWS标准SQS：接收与删除消息异常问题排查

向AWS标准SQS发送2条消息后，执行接收和删除操作时出现以下异常：

1. 首次调用receiveMessage仅返回1条消息（预期2条）
2. 调用删除方法后，再次调用receiveMessage仍返回1条消息（预期0条）

问题1：首次接收仅拿到1条消息的原因 #

• 标准SQS分布式特性：标准SQS的消息分散存储在多个节点中，默认的短轮询（waitTimeSeconds=0）只会随机查询部分节点，因此无法保证一次拉取到所有消息，即便maxNumberOfMessages设置为5。
• 未启用长轮询：短轮询不会等待新消息，直接返回当前查询到的内容；而长轮询会等待直到拿到最多maxNumberOfMessages条消息或超时，能大幅提升消息拉取的完整性。

问题2：删除后仍能拿到消息的核心原因 #

• 方法名笔误：代码中定义的删除方法是deleteMessagesInIntegrationQueue，但实际调用的是deleteMessagesInQueue——这一错误导致删除逻辑根本未执行，消息在可见性超时后会重新回到队列，所以再次接收仍能拿到。
• 可见性窗口机制：即使删除逻辑正确，如果在消息的可见性超时时间（默认30秒）内未完成删除，消息会重新变为可接收状态，也会出现重复拉取的情况。

修复方案 #

1. 修正方法名错误 #

将调用的deleteMessagesInQueue(results)改为deleteMessagesInIntegrationQueue(results)，确保删除逻辑被执行：

// 原错误调用
// deleteMessagesInQueue(results);
// 修正后
deleteMessagesInIntegrationQueue(results);

2. 配置长轮询提升消息拉取完整性 #

修改getReceiveMessageRequest方法，添加长轮询配置（最长可设20秒）：

private ReceiveMessageRequest getReceiveMessageRequest() {
    return new ReceiveMessageRequest(QUEUE_URL)
        .withMaxNumberOfMessages(5)
        .withWaitTimeSeconds(20); // 启用长轮询
}

3. 循环拉取确保获取所有预期消息 #

如果需要保证拿到所有消息，可通过循环调用receiveMessage直到达到预期数量或返回空列表：

List<Message> allMessages = new ArrayList<>();
int expectedCount = 2;
while (allMessages.size() < expectedCount) {
    List<Message> batch = testSQS.receiveMessage(getReceiveMessageRequest()).getMessages();
    if (batch.isEmpty()) {
        break; // 无更多消息，退出循环
    }
    allMessages.addAll(batch);
}
SOPL(allMessages);

4. 批量删除优化性能 #

替代循环单个删除，使用deleteMessageBatch批量删除消息，减少API调用次数：

private void deleteMessagesInIntegrationQueue(List<Message> messages) {
    if (messages.isEmpty()) {
        return;
    }
    List<DeleteMessageBatchRequestEntry> entries = new ArrayList<>();
    for (int i = 0; i < messages.size(); i++) {
        Message message = messages.get(i);
        entries.add(new DeleteMessageBatchRequestEntry(
            "entry-" + i, // 唯一条目ID
            message.getReceiptHandle()
        ));
    }
    testSQS.deleteMessageBatch(new DeleteMessageBatchRequest(QUEUE_URL, entries));
}

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