我以一种非常简单的方式使用Amazon SQS队列。通常，消息被写入并立即可见和读取。有时，会写入一条消息，并在队列中保持飞行中（不可见）几分钟。我可以从控制台看到它。接收消息等待时间为0，默认可见性为5秒。它将保持这种状态几分钟，或者直到写入新消息以某种方式释放它为止。几秒钟的延迟是可以的，但超过60秒是不可以的。
这里有8个读取器线程，它们总是长时间轮询，因此它们不是某个东西在试图读取它。
编辑：明确地说，所有使用者读取都没有返回任何消息，并且无论控制台是否打开，它都会发生。在这种情况下，只涉及一条消息，它只是位于对消费者不可见的队列中。
有没有其他人看到过这种行为，以及我可以做些什么来改善它？
这是我正在使用的Java的SDK：
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk</artifactId>
<version>1.5.2</version>
</dependency>
这是执行读取的代码（max = 10，maxwait = 0启动配置）：
void read(MessageConsumer consumer) {
List<Message> messages = read(max, maxWait);
for (Message message : messages) {
if (tryConsume(consumer, message)) {
delete(message.getReceiptHandle());
}
}
}
private List<Message> read(int max, int maxWait) {
AmazonSQS sqs = getClient();
ReceiveMessageRequest rq = new ReceiveMessageRequest(queueUrl);
rq.setMaxNumberOfMessages(max);
rq.setWaitTimeSeconds(maxWait);
List<Message> messages = sqs.receiveMessage(rq).getMessages();
if (messages.size() > 0) {
LOG.info("read {} messages from SQS queue",messages.size());
}
return messages;
}
发生这种情况时，永远不会出现“ read ..”的日志行，这是导致我进入控制台并查看消息是否存在的原因。
听起来您好像误解了所看到的。
“运行中”的消息没有等待发送，它们是已经发送但尚未由消费者采取进一步行动的消息。
如果消息已发送到客户端，但尚未删除或尚未到达其可见性窗口的末尾，则视为正在运行。
— http://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/sqs-metricscollected.html
当使用者收到一条消息时，它必须-在某个时候删除该消息，或发送请求以增加该消息的超时；否则，超时后该消息将再次变为可见。如果消费者未执行这些操作之一，则该消息将自动再次变为可见。可见性超时是消费者必须完成这些操作之一之前的时间。
在没有收到消息的情况下，消息不应处于“运行中”状态-但“内容”可以包括控制台本身，正如您将注意到的那样，在弹出菜单中选择“查看/删除消息”时会看到弹出窗口。控制台（除非您已经选中“不再显示”复选框）：
控制台停止轮询消息之前，控制台中显示的消息将对其他应用程序不可用。
控制台从“查看/删除消息”屏幕观察队列时，控制台中显示的消息“正在运行”。
如果您的默认可见性超时仅为5秒，并且代码中没有任何内容会增加该超时，则没有明显意义的部分是消息正在“运行几分钟”，但是...可以用以下方法完美地解释这一点：您的消费者没有正确处理该消息，导致该消息超时并立即重新传递，给人的印象是该消息的单个实例仍在运行中，而实际上，该消息只是短暂地过渡回可见状态，只是为了几乎立即被另一位消费者要求赔偿，然后又重新回到了机上。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句