SQS ReceiveMessageRequest无法接收队列中全部消息（消息数少于10）

可能原因及解决办法 #

• 消息可见性超时影响：SQS消息被获取后会进入「不可见状态」，默认可见性超时为30秒。如果之前的请求已经拉取过部分消息且未删除，在超时时间内新请求无法再次获取这些消息。解决方式：处理完消息后调用deleteMessage()删除；或者在请求时通过withVisibilityTimeout()缩短超时时间（比如设为5秒），让消息更快重新变为可见。
• 参数过滤导致遗漏：检查是否设置了withAttributeNames()或withMessageAttributeNames()参数过滤消息。如果仅指定了部分属性，可能导致符合条件的消息不被返回。建议暂时移除这类过滤参数，测试能否获取全量消息。
• SDK版本bug：旧版AWS SQS SDK可能存在withMaxNumberOfMessages()参数不生效的问题。尝试升级到最新版本的SDK（以Java为例，更新aws-java-sdk-sqs依赖至最新版）。
• 消息异常：排查未被获取的消息是否存在异常，比如消息体大小超过SQS标准队列256KB的上限，这类消息可能被隐性处理。可以通过SQS控制台查看消息统计，确认目标消息是否正常存在。

测试用示例代码 #

可以添加重试逻辑并打印获取结果，辅助排查问题：

List<Message> allMessages = new ArrayList<>();
int maxRetries = 3;
int retryCount = 0;

while (retryCount < maxRetries) {
    ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest()
            .withQueueUrl(queueUrl)
            .withWaitTimeSeconds(10)
            .withMaxNumberOfMessages(10)
            .withVisibilityTimeout(5); // 缩短可见性超时，便于快速重试
    
    List<Message> messages = sqsConfig.getSQSClient().receiveMessage(receiveMessageRequest).getMessages();
    System.out.println("第" + (retryCount+1) + "次获取到" + messages.size() + "条消息");
    
    allMessages.addAll(messages);
    // 临时删除已获取消息，避免影响下一次拉取
    for (Message msg : messages) {
        sqsConfig.getSQSClient().deleteMessage(queueUrl, msg.getReceiptHandle());
    }
    
    if (allMessages.size() >= 3) {
        break;
    }
    retryCount++;
}

System.out.println("总共获取到" + allMessages.size() + "条消息");

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