上篇博客中,我们用实际的业务场景和代码示例了Azure Messaging-ServiceBus Messaging对复杂对象消息的支持和消息的持久化:

Azure Messaging-ServiceBus Messaging消息队列技术系列4-复杂对象消息是否需要支持序列化和消息持久化

本文中我们主要研究并介绍Azure Messaging对重复消息的支持。

MessageReceiver 对象创建时可以指定消息接收模式: ReceiveAndDelete 和 PeekLock (默认),其中:

1. 使用 ReceiveAndDelete 模式时,接收是单步操作,即当 Service Bus 收到请求时,它将消息标记为“正在使用”,然后将其返回给应用程序。ReceiveAndDelete 模式是最简

单的模型,并且最适合在出现故障时应用程序能够容许不处理消息的场景。理解此模式时,可考虑这种情况:使用者发出了接收请求,但在处理消息之前发生崩溃。由于 Service B

us已将消息标记为“正在使用”,因此当应用程序重新启动并重新开始使用消息时,它就会错过在崩溃前已使用的消息。

2. 在 PeekLock 模式下,接收变成两阶段操作,因此可以支持不能容许错过消息的应用程序。当 Service Bus 收到请求时,它会找到下一条要使用的消息,将其锁定以防止其他使

用者接收它,然后将其返回给应用程序。应用程序完成消息处理(或将消息可靠地存储以便将来处理)后,会对收到的消息调用 Complete 以完成接收过程的第二阶段。当Service

Bus 看到 Complete 时,会将该消息标记为“正在使用”。另外两个结果也是可能的。第一个结果,如果由于某种原因应用程序无法处理该消息,它可以对收到的消息Abandon(而

不是 Complete)。这将导致 Service Bus 解锁该消息,并使该消息可以重新被同一使用者或其他竞争的使用者接收。第二个结果,即存在与锁定关联的超时,如果应用程序在锁

定超时到期前无法处理改消息(例如,应用程序崩溃)则 Service