1

我正在寻找一种用于ServiceClient.GetFeedbackReceiver()接收来自带有 Azure IoT SDK 的设备的确认的良好做法。

我有两个IEventProcessor处理来自 IoT HUB 的消息的实例——一个用于冷路径，另一个用于热路径。如果需要更多数据，每个 EventProcessor 都可以向设备发送消息。

我需要处理来自我发送消息的设备的 ACK。所以我有一个像这样的“存根代码”：

        var sc = ServiceClient.CreateFromConnectionString(connectionString);
        var fr = sc.GetFeedbackReceiver();

        while (true)
        {
            var feedbackBatch = await fr.ReceiveAsync();
            if (feedbackBatch == null) continue;

            var myName = GetType().Name;
            Console.WriteLine(myName +": ack list: {0}", string.Join(", ", feedbackBatch.Records.Select(f => f.StatusCode + " for " + f.OriginalMessageId + ";")));

            await fr.CompleteAsync(feedbackBatch);
        }

问题是：

  • 当我在两个事件处理器（热和冷）中运行此代码时，我得到反馈响应（ack）是完全随机的！
  • 两个 EventProcessor 是分开的，所以我不能只将收到的 ACK 从一个传递到另一个；

我需要的：

  • 我需要 ACK 来返回消息来源的 EventProcessor
  • 或解决问题的其他常见的、良好的做法、规范的解决方案；
4

1 回答 1

2

没有人发布更好的答案，所以我将分享我的解决方案。

免责声明：我仍然不知道这是否是最佳解决方案。

我创建了第三个（新的、独立的）事件处理器（IEventProcessor），始终作为一个实例运行，它处理来自所有设备的所有 ACK 反馈。

所以整体解决方案是基于三个事件处理器（两个接收冷热路径的正常消息，第三个接收ACK）。所有这些（除了特定的逻辑）都将接收到的消息转换为域事件并放入事件中心。我系统中的其他组件监视此集线器并处理域逻辑。

评论：

  • 为一个 IoT 中心仅运行一个反馈接收器 ( ServiceClient.GetFeedbackReceiver()+ )实例非常重要。ReceiveAsync这保证了所有 ACK 将以确定性的方式接收。
于 2016-03-01T09:50:13.957 回答