StatefulService资源清理正确方式及Dispose未调用问题

在共享进程模型中，Service Fabric不会主动调用服务实例的Dispose()方法——因为进程会被多个服务实例复用，服务实例停用后不会触发对象销毁逻辑。以下是可行的资源清理方案：

1. 重写OnCloseAsync方法处理优雅关闭 #

这是服务实例正常终止时的标准回调，适合执行需要完整完成的异步清理逻辑：

protected override async Task OnCloseAsync(CancellationToken cancellationToken)
{
    // 执行资源清理，比如关闭数据库连接、释放可靠状态管理器关联资源等
    await CleanupManagedResourcesAsync(cancellationToken);
    // 务必调用基类方法完成框架级清理
    await base.OnCloseAsync(cancellationToken);
}

2. 重写OnAbort方法处理强制终止 #

当服务因节点故障、资源耗尽等原因被强制终止时，会触发此方法，需快速执行同步清理操作，避免阻塞：

protected override void OnAbort()
{
    // 紧急清理非托管资源、终止正在执行的关键操作
    ReleaseUnmanagedResources();
    base.OnAbort();
}

3. 结合IAsyncDisposable实现异步清理（.NET Core 3.0+） #

若清理逻辑以异步操作为主，可实现IAsyncDisposable接口，并在OnCloseAsync中主动调用：

public class MyStatefulService : StatefulService, IAsyncDisposable
{
    public MyStatefulService(StatefulServiceContext serviceContext, IReliableStateManagerReplica2 reliableStateManagerReplica)
        : base(serviceContext, reliableStateManagerReplica)
    {
        // 构造逻辑
    }

    public async ValueTask DisposeAsync()
    {
        // 异步清理代码，比如释放异步资源池、关闭WebSocket连接等
        await CleanupAsyncResources();
    }

    protected override async Task OnCloseAsync(CancellationToken cancellationToken)
    {
        await DisposeAsync();
        await base.OnCloseAsync(cancellationToken);
    }
}

注意事项 #

• 共享进程模型下，进程会被多个服务实例复用，需确保每个实例的资源独立隔离，避免跨实例资源污染。
• OnAbort方法必须快速执行，不能包含耗时操作，否则进程可能被Service Fabric强制杀死，导致清理不彻底。

内容的提问来源于stack exchange，提问作者Slobo80