使用Java SDK的Amazon SQS队列发送/接收意外行为-我做错了什么？

Question

我正在尝试将一些Java代码与我在AWS上制作的SQS队列进行接口。我已经开始编写一个测试，以获得我想要的行为（即编写和接收消息），它的行为似乎非常奇怪。下面是我的测试代码：

@Test
public void testMessagesAreSentToQueue() {
    sqs.sendMessage(queueUrl, "TEST MESSAGE1");
    sqs.sendMessage(queueUrl, "TEST MESSAGE2");
    sqs.sendMessage(queueUrl, "TEST MESSAGE3");

    ReceiveMessageRequest req = new ReceiveMessageRequest().withQueueUrl(queueUrl).withWaitTimeSeconds(20);
    List<Message> messagesInQueue = sqs.receiveMessage(req).getMessages();

    assertThat(messagesInQueue.size()).isEqualTo(3);
    assertThat(messagesInQueue.get(0).getBody()).isEqualTo("TEST MESSAGE1");
    assertThat(messagesInQueue.get(1).getBody()).isEqualTo("TEST MESSAGE2");
    assertThat(messagesInQueue.get(2).getBody()).isEqualTo("TEST MESSAGE3");
}

我是不是误解了SQS在这里的工作方式？我希望能够发送和接收回任何数量的消息我想要。

编辑--我正在使用maxNumberOfMessages并重复长轮询请求，直到队列耗尽为止（这里有更多内容--Amazon SQS长轮询不返回所有消息）

Answer 1

查看ReceiveMessageRequest的API文档，它似乎默认为每个调用最多检索1条消息。使用New ReceiveMessageRequest().WithMaxNumberOfMessages(3)增加该数字可能会解决您的问题，但仍可能无法如您所期望的那样工作，因为文档还说明：

如果队列中的消息数量很少（小于1000)，那么您获得的消息可能少于您在每次ReceiveMessage调用中请求的消息。如果队列中的消息数量极少,则可能无法在特定的ReceiveMessage响应中接收到任何消息；在这种情况下，您应该重复请求。