4

我在 SQS 中创建了一个队列，添加了两条消息（序列化的 PHP 数组：array('filename' => 0, ...)和array('filename' => 1, ...)）。我正在使用来自他们的 git repo 的最新版本的 amazon SDK for PHP。

问题是当我使用带有这些选项的 receive_message 函数时：

MaxNumberOfMessages = 10
VisibilityTimeout = 0 // other values doesn't change much

我只收到第一条消息，重复了 10 次：

<ReceiveMessageResponse>
−
<ReceiveMessageResult>
−
<Message>
<MessageId>82523332-75e0-444d-ae8f-55ccd5580beb</MessageId>
−
<ReceiptHandle>
v5iiyMGi3b6RunVNVvjOQOV+ZDqRV7sNLzj5pUAEj1brIAkucpYiGaM8UIdOEis9Kouh4s+cAkSAd7MhbJKPGM6SdKYE993x2Lf/DwEbhkfmzRxOevzUsyJCrrVdTSTSx0cNUqqV6Cgr/Asi72t/UOhbdXhTp3kaCaZfd2weymg=
</ReceiptHandle>
<MD5OfBody>ced185420292fbd06b32ea6e35da3d21</MD5OfBody>
−
<Body>
a:3:{s:8:"priority";i:2;s:8:"filename";i:0;s:11:"task_ticket";s:0:"";}
</Body>
</Message>
−
<Message>
<MessageId>82523332-75e0-444d-ae8f-55ccd5580beb</MessageId>
−
<ReceiptHandle>
v5iiyMGi3b6RunVNVvjOQOV+ZDqRV7sNLzj5pUAEj1brIAkucpYiGaM8UIdOEis9Kouh4s+cAkSAd7MhbJKPGM6SdKYE993x2Lf/DwEbhkfmzRxOevzUsyJCrrVdTSTSx0cNUqqV6Cgr/Asi72t/UOhbdXhTp3kaCaZfd2weymg=
</ReceiptHandle>
<MD5OfBody>ced185420292fbd06b32ea6e35da3d21</MD5OfBody>
−
<Body>
a:3:{s:8:"priority";i:2;s:8:"filename";i:0;s:11:"task_ticket";s:0:"";}
</Body>
</Message>
    ...and so on, always with "filename";i:0

我 100% 认为队列中只有 2 条消息（我删除它并重新创建以确保），但我只得到第一个，填充了很多次。这会不时发生变化，有时我会在列表中混合第二个。如果我保留VisibilityTimeout默认值 3（或其他非零值），第一个会消失一段时间（如预期的那样），然后我会得到第二个重复多次。

get_queue_size返回 2，这是真的。

我还尝试了 Amazon Scratchpad，只是进行了 API 调用，结果相同。那么，是 SQS 坏了还是我做错了什么？

4

1 回答 1

9

我相信这是预期的行为，因为您已经设置了VisibilityTimeout = 0. 通常，您会将超时值设置为处理消息的预期持续时间。您必须在可见性超时到期之前delete调用已读消息，否则该消息将自动重新排队。

在更复杂的系统中，如果初始超时时间不够长，则可以使用单独的线程来延长单个消息的超时时间。

听起来您才刚刚开始，因此编写消息处理代码以考虑多次读取同一消息非常重要。您的消息不仅可以自动重新排队，而且 SQS 有时会返回重复的消息。

于 2011-03-14T21:34:45.967 回答