如何在Azure服务总线中使用PEEK方法知道队列是否已被完全读取

Question

我正在使用Azure服务总线REST API接收消息。要求具有从Azure服务总线队列读取消息并转发消息以进行处理的计划作业。如果处理成功，请从队列中删除它们，或将它们保留在队列中，以便在下一个计划作业中处理。我使用Peek-Lock消息（非破坏性读取）方法（https://docs.microsoft.com/en-us/rest/api/servicebus/peek-lock-message-non-destructive-read）。

我面临的问题是在我的循环中，如何知道我已经完全读取了队列，这样我就不会再次重新读取相同的队列。

Answer 1

你的要求有点问题。

如果处理成功，则将其从队列中删除或保留在队列中，以便在下一个计划作业中处理。

成功处理应始终导致消息完成。否则，你就是自找麻烦。在peek lock模式下处理消息时，消息将被锁定最多5分钟。如果处理成功，您有责任完成它。如果未完成，则表明处理未成功，应根据您的要求再次读取。不要将已成功处理的邮件留在队列中。

我面临的问题是在我的循环中，如何知道我已经完全读取了队列，这样我就不会再次重新读取相同的队列。

你不应该担心这个。阅读消息并进行处理。如果处理失败，消息将重新出现。否则，应删除一条消息。如果要处理幂等性，即，如果由于某种原因，消息未被多次处理，请确保在成功处理之后和完成之前，将消息ID（假定它是唯一的）存储在数据存储中，并根据该数据存储验证任何新消息。