从SQS检索多条消息

Question

我在SQS中有多个消息。即使有数十个可见代码（不在运行中），以下代码也 始终 仅返回一个。
我认为setMaxNumberOfMessages允许一次使用多个..我误解了吗？

 CreateQueueRequest createQueueRequest = new CreateQueueRequest().withQueueName(queueName);
 String queueUrl = sqs.createQueue(createQueueRequest).getQueueUrl();
 ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest(queueUrl);
 receiveMessageRequest.setMaxNumberOfMessages(10);
 List<Message> messages = sqs.receiveMessage(receiveMessageRequest).getMessages();
 for (Message message : messages) {
      // i'm a message from SQS
 }

我也尝试使用withMaxNumberOfMessages，但没有任何运气：

 receiveMessageRequest.withMaxNumberOfMessages(10);

我怎么知道队列中有消息？大于1？

 Set<String> attrs = new HashSet<String>();
 attrs.add("ApproximateNumberOfMessages");
 CreateQueueRequest createQueueRequest = new CreateQueueRequest().withQueueName(queueName);
 GetQueueAttributesRequest a = new GetQueueAttributesRequest().withQueueUrl(sqs.createQueue(createQueueRequest).getQueueUrl()).withAttributeNames(attrs);
 Map<String,String> result = sqs.getQueueAttributes(a).getAttributes();
 int num = Integer.parseInt(result.get("ApproximateNumberOfMessages"));

上面的代码总是在运行之前给我int> 1

感谢您的输入

Answer 1

AWS API参考指南：Query /
QueryReceiveMessage

由于队列的分布式性质，将在ReceiveMessage调用中对一组加权随机计算机进行采样。这意味着仅返回被采样计算机上的消息。如果队列中的消息数量很少（少于1000条），则收到的消息可能会少于每个ReceiveMessage调用所请求的消息。如果队列中的消息数量非常少，则您在特定的ReceiveMessage响应中可能不会收到任何消息；在这种情况下，您应该重复请求。

和

MaxNumberOfMessages ：要返回的最大消息数。SQS永远不会返回比该值更多的消息，但 可能会返回更少的消息 。