使用接收句柄删除SQS消息

Question

我目前正在使用亚马逊的SQS，在尝试删除当前“正在运行”的队列消息时遇到问题。

下面是一些示例代码：

ReceiveMessageRequest queueRequest = new ReceiveMessageRequest();
        queueRequest.WithMaxNumberOfMessages(1);
        queueRequest.WithQueueUrl(config.QueueURL);
        queueRequest.WithAttributeName("All");

        ReceiveMessageResponse response = sqs.ReceiveMessage(queueRequest);

        if (response.IsSetReceiveMessageResult())
        {
            ReceiveMessageResult result = response.ReceiveMessageResult;

            if (result.IsSetMessage())
            {
                if (result.Message.First() != null)
                {
                    return new Tuple<string, string, bool>(result.Message.First().ReceiptHandle, result.Message.First().Body ?? null, false);
                }
            }
        }

现在，在接收到句柄和消息体之后，我将接收句柄字符串存储到云存储中（例如DynamoDB）。随后，我从存储服务中加载该句柄，并使用类似于以下内容的方式调用delete：

sqs.DeleteMessage(new DeleteMessageRequest() { QueueUrl = "urL", ReceiptHandle = handle });

但是，当运行该行时，我收到一条“输入收据句柄无效”的错误消息。

注意，我知道这条消息没有被重新接收，所以记录的接收句柄应该是最新的。还要注意的是，我现在可以在同一个应用程序中删除消息，只需在收到消息后Hibernate，然后像上面那样尝试删除它！

有什么想法吗？

Answer 1

ReceiptHandle包含一些特殊字符，这些字符对网址很敏感。所以你需要首先对网址进行编码。我也是这么做的，它起作用了。

Answer 2

您必须等到消息的VisibilityTimeout过期后才能再次对其执行操作。这使得处理该消息的机器有时间做它需要做的任何事情。

Answer 3

在执行这两个操作（ReceiveMessage和DeleteMessage）时，请确保使用的URL与引用队列的URL完全相同。