Azure 服务总线条件消息锁定

Question

是否可以使用 Azure 服务总线实现以下伪场景？

我有一个可以扩展到 50 个实例的函数，它使用服务总线触发器。我想保证仅当当前未处理现有相关消息时才会处理相关消息。

假设我有一条消息(消息 A)正在由与 UserID 1234 关联的函数实例处理。另一条消息(消息 B)出现在也与 UserID 1234 关联的队列中，服务总线应该“忽略”这是因为相关消息已在处理中。另一条用户 ID 为 9876 的消息(消息 C)出现在队列中，该消息会立即得到处理，因为没有用户 ID 为 9876 的正在运行的消息。

消息 A 已完成处理，消息 B 现已被拾取。

<小时/>

目前，我有一个路由函数，它消耗初始服务总线触发器，然后将其路由到 10 个函数之一，每个函数负责 UserID 最后一位数字为 0-9 的消息。

这意味着，如果函数“4”正忙于处理某个请求，它将无法处理任何其他 UserID 以 4 结尾的请求，从而保证系统无法同时处理相关消息。它完成了它的工作，但无法扩展。

Answer 1

没有条件锁定。从描述来看，听起来您想一次处理一个与同一用户 ID 关联的消息。为此，Azure 服务总线有一个名为 Message Sessions 的功能。 .