Azure服务结构:IReliableQueue

Question

我正在使用天蓝色服务面料进行新服务.

对于面向客户端的网关,我有一个使用Web API端点的无状态服务获取请求,实际工作是使用可靠的无状态actor完成的.

正如Sean McKenna - MSFT在这个问题中所建议的,我将传入的请求放在ReliableQueue中并将结果存储在ReliableDictionary中.

我不明白如何实现这个,我在哪里定义ReliableQueue？很明显(？)将一个作业排入Web API控制器,但是我在哪里出列一个对象以及什么时候出现？没有事件触发告诉我添加了一个对象？

如你所见,我会在这方面得到一些帮助

谢谢

Answer 1

在您提到的问题中，我描述了WordCount 示例中显示的模式。

在这种情况下，应用程序由无状态网关服务和有状态处理服务组成。客户端输入被发送到无状态网关，然后中继到有状态服务，最初保存在ReliableQueue. 同时，该RunAsync方法内部运行一个无限 while 循环，将项目从队列中拉出并进行处理，结果存储在ReliableDictionary. 当您想要快速向客户端确认收到（并安全地保留！）其输入并且能够异步执行实际处理时，此模式非常有用。

请注意，如果您打算将状态存储在ReliableQueue/中ReliableDictionary，则使用无状态参与者进行处理可能没有太大价值。您最好将该逻辑移动到有状态服务中的一种类型中，并在那里进行处理，因为您可能会节省来回的网络跳跃。