通过在 Service Fabric 中的 Web API 控制器中做出的决定从 RunAsync() 强制返回

Question

当您看到抛出异常（例如FabricObjectClosedException）时，此线程与场景高度相关。

问题是针对特定场景，当您根据 http-request 使用 Web api 控制器中的 StateManager 提交入队时看到上述异常。

为了提供更多背景故事，当 Service Fabric 对象由于某种原因 (here) 当前处于关闭状态时，将引发 FabricObjectCloseException：

1. 正在删除 Service Fabric 对象。
2. 由于故障转移，无法访问 Service Fabric 对象。

如果上述异常是在RunAsync() while 循环中抛出的，推荐的做法是从RunAsync() 方法中返回，该方法基于link 调用服务的重启。

如果尝试在 Web API 控制器中使用可靠状态管理器时抛出异常怎么办？在这种情况下，有状态服务的RunAsync() 怎么能跳出while循环呢？

Answer 1

我不能 100% 确定我了解全部情况，但我可以想到以下情况：

你有：

1. 公开为 ServiceReplicaListener 以服务传入请求的 Web API 控制器
2. 在RunAsync 方法中完成的一些背景/继续工作

这里的第一件事是检查CancellationToken是否在FabricObjectCloseException被抛出时被设置为RunAsync。

据我了解，FabricObjectCloseException 在副本被关闭时抛出（here 我曾经描述过 Service Fabric 在服务关闭时执行的步骤），由集群管理器或其他原因引起。如果这个假设成立，那么应该设置CancellationToken。

如果未设置通过 CancellationToken - 那么我可以建议您：

1. 创建一个简单的服务来包装CancellationTokenSource
2. 在StatefulService 类的构造函数中创建CancellationTokenSource 的实例，并从#1 初始化服务。
3. 使用依赖注入，在 Web API 控制器中注入此服务，并在 FabricObjectCloseException 发生时取消信号。
4. 在RunAsync中，检查两者的取消状态：通过CancellationToken和自定义服务。

附：我不确定你在 RunAsync 方法中做了什么样的工作，但我只想提一下，当工作的后台部分完成时，从 return 到 return 是可以的 - 或者甚至不覆盖当没有后台工作时。