我一直在尝试使用AWS SDK for

Java从SQS队列中检索所有消息的几种方法无济于事.我已经了解了AWS SQS的分布式特性,并且消息存储在不同的服务器上.但我不明白为什么这个架构不会被最终用户隐藏.我需要在Java代码中应用哪些技巧来检索所有消息,并且100％确定没有人错过？

我试着用“长轮询”：

ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest(myQueueUrl);

List messages = sqs.receiveMessage(receiveMessageRequest).getMessages();

for (Message message : messages) {

System.out.println(" Message");

System.out.println(" MessageId: " + message.getMessageId());

System.out.println(" ReceiptHandle: " + message.getReceiptHandle());

System.out.println(" MD5OfBody: " + message.getMD5OfBody());

System.out.println(" Body: " + message.getBody());

for (Entry entry : message.getAttributes().entrySet()) {

System.out.println(" Attribute");

System.out.println(" Name: " + entry.getKey());

System.out.println(" Value: " + entry.getValue());

}

}

System.out.println();

这与请求批处理/客户端缓​​冲：

// Create the basic Amazon SQS async client

AmazonSQSAsync sqsAsync = new AmazonSQSAsyncClient();

// Create the buffered client

AmazonSQSAsync bufferedSqs = new AmazonSQSBufferedAsyncClient(sqsAsync);

CreateQueueRequest createRequest = new CreateQueueRequest().withQueueName("MyTestQueue");

CreateQueueResult res = bufferedSqs.createQueue(createRequest);

SendMessageRequest request = new SendMessageRequest();

String body = "test message_" + System.currentTimeMillis();

request.setMessageBody( body );

request.setQueueUrl(res.getQueueUrl());

SendMessageResult sendResult = bufferedSqs.sendMessage(request);

ReceiveMessageRequest receiveRq = new ReceiveMessageRequest()

.withMaxNumberOfMessages(10)

.withQueueUrl(queueUrl);

ReceiveMessageResult rx = bufferedSqs.receiveMessage(receiveRq);

List messages = rx.getMessages();

for (Message message : messages) {

System.out.println(" Message");

System.out.println(" MessageId: " + message.getMessageId());

System.out.println(" ReceiptHandle: " + message.getReceiptHandle());

System.out.println(" MD5OfBody: " + message.getMD5OfBody());

System.out.println(" Body: " + message.getBody());

for (Entry entry : message.getAttributes().entrySet()) {

System.out.println(" Attribute");

System.out.println(" Name: " + entry.getKey());

System.out.println(" Value: " + entry.getValue());

}

}

但我仍然无法检索所有消息.

任何的想法？

AWS论坛对我的帖子保持沉默.