逐个处理服务总线队列消息

Question

我对Azure服务总线队列还比较陌生，正在构建一个项目，该项目需要按照消息到达的顺序（FIFO）处理队列中的消息。

使用微软的文档，我能够理解这一部分。据我所知，我需要为队列打开会话？

我所面临的困难是确定对队列执行以下一组有序任务的最佳方法/服务堆栈。

首先，让我们假设我们有一个基于先进先出的服务总线队列，它有n个消息。我怎么可能：

1. 从队列中拾取第一条消息。
2. 使用Azure函数处理消息。
3. 将有效载荷发送到IoT中心，该中心将交付给外部设备（C2D）。
4. 这是我想不通的部分...等待完成指标从IoT中心返回，或者等待传出的IoT中心消息的TTL过期。
5. 现在完成队列中的项目。
6. 从1点开始。

我可以想象，也许一个逻辑应用程序可以帮助我实现我正在尝试做的事情。一切似乎都是直截了当的，直到#4。我不知道如何拥有逻辑应用1。等到IoT中心确认云到设备消息已发送或过期以及2.在收到IoT中心确认并将当前队列消息标记为完成之前，不要处理队列中的下一条消息。

请注意：我对此如此具体的原因是，接收传出物联网中心C2D消息的设备关心订单。如果他们收到的消息不按顺序排列，则进程将被关闭。

任何建议都非常感谢。

Answer 1

具有会话的Azure服务总线队列可用于实现消息的有序处理。

从这个问题中，我可以理解，只有在从物联网集线器接收到确认后，才应该删除来自服务总线队列的消息。

我能感觉到这个流程可能会出现问题。

首先，您需要了解服务总线队列中的锁定持续时间属性。根据为此属性设置的值，消息将被锁定x分钟或秒。无论何时从队列接收到消息，都会对该消息应用锁。使消息在x分钟或x秒内不可用于任何其他接收器<代码>完成操作应在锁过期之前进行。一旦锁过期，该消息将可供其他接收者处理。在您的情况下，同一Azure函数有可能再次接收消息（导致重复）

可以为“锁定持续时间”属性设置的最大值为5分钟。

因此，如果您确定IOT Hub在5分钟内响应，则可以继续此实施。但是，仍然没有选项让函数知道何时处理下一条消息。