Asp.net Core角色过期：如何在指定时长后移除用户角色？

看起来你遇到的空引用异常，大概率是因为没有等待异步方法完成，导致请求上下文被提前释放了。让我一步步帮你分析并解决这个问题：

问题根源 #

你调用sessionExpired(user)时没有加await，这会让这个异步方法在后台“火并忘记”（fire-and-forget）。当当前请求结束后，ASP.NET Core会自动释放请求相关的上下文（比如_userManager的依赖注入上下文、原user对象的状态）。等到Task.Delay结束后，再去操作这些已经被释放的对象，自然就会抛出空引用异常。

而且直接在请求线程里等待时长结束也不现实——这会让用户的请求一直挂着，体验极差。我们需要用后台任务来处理延迟执行的逻辑。

解决方案：使用后台任务队列 #

下面是一套不依赖第三方库的实现方案，用ASP.NET Core自带的后台服务来处理延迟移除角色的逻辑：

1. 创建后台任务队列 #

首先定义一个队列接口和实现，用来存放待执行的后台任务：

public interface IBackgroundTaskQueue
{
    void QueueBackgroundWorkItem(Func<CancellationToken, Task> workItem);
}

public class BackgroundTaskQueue : IBackgroundTaskQueue
{
    private readonly ConcurrentQueue<Func<CancellationToken, Task>> _workItems = new();
    private readonly SemaphoreSlim _signal = new(0);

    public void QueueBackgroundWorkItem(Func<CancellationToken, Task> workItem)
    {
        if (workItem == null) throw new ArgumentNullException(nameof(workItem));
        _workItems.Enqueue(workItem);
        _signal.Release();
    }

    public async Task<Func<CancellationToken, Task>> DequeueAsync(CancellationToken cancellationToken)
    {
        await _signal.WaitAsync(cancellationToken);
        _workItems.TryDequeue(out var workItem);
        return workItem;
    }
}

2. 实现后台服务处理队列 #

创建一个后台服务类，负责从队列中取出任务并执行：

public class QueuedHostedService : BackgroundService
{
    private readonly IBackgroundTaskQueue _taskQueue;
    private readonly ILogger<QueuedHostedService> _logger;

    public QueuedHostedService(IBackgroundTaskQueue taskQueue, ILogger<QueuedHostedService> logger)
    {
        _taskQueue = taskQueue;
        _logger = logger;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _logger.LogInformation("Queued Hosted Service is starting.");

        while (!stoppingToken.IsCancellationRequested)
        {
            var workItem = await _taskQueue.DequeueAsync(stoppingToken);

            try
            {
                await workItem(stoppingToken);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "Error occurred executing background task.");
            }
        }

        _logger.LogInformation("Queued Hosted Service is stopping.");
    }
}

3. 注册后台服务 #

在Program.cs中注册队列和后台服务：

builder.Services.AddSingleton<IBackgroundTaskQueue, BackgroundTaskQueue>();
builder.Services.AddHostedService<QueuedHostedService>();

4. 修改你的业务方法 #

在PurchaseSession方法中，将移除角色的逻辑加入后台队列，并且重新通过用户ID获取用户对象（避免依赖原请求中的user对象）：

private readonly IBackgroundTaskQueue _backgroundTaskQueue;
// 构造函数注入队列
public YourController(UserManager<IdentityUser> userManager, SignInManager<IdentityUser> signInManager, IBackgroundTaskQueue backgroundTaskQueue)
{
    _userManager = userManager;
    _signInManager = signInManager;
    _backgroundTaskQueue = backgroundTaskQueue;
}

public async Task<IActionResult> PurchaseSession(PurchaseSessionViewModel model) 
{ 
    var user = await _userManager.GetUserAsync(User); 
    await _userManager.AddToRoleAsync(user, "Active"); 
    await _signInManager.RefreshSignInAsync(user); 

    // 将延迟移除角色的任务加入后台队列
    _backgroundTaskQueue.QueueBackgroundWorkItem(async token =>
    {
        // 设置你需要的延迟时长，比如30分钟
        await Task.Delay(TimeSpan.FromMinutes(30), token);
        
        // 重新获取用户，避免原对象上下文被释放
        var targetUser = await _userManager.FindByIdAsync(user.Id);
        if (targetUser != null)
        {
            // 可选：先检查用户是否还在该角色中
            if (await _userManager.IsInRoleAsync(targetUser, "Active"))
            {
                await _userManager.RemoveFromRoleAsync(targetUser, "Active");
                // 如果需要让用户的登录状态立即失效，可以考虑刷新登录或使用缓存标记
                // 但客户端的Claims不会自动更新，可能需要前端配合检查
            }
        }
    });

    return RedirectToAction(nameof(Index)); 
}

额外注意事项 #

• 不要直接在请求线程中执行Task.Delay并等待，这会阻塞请求，影响用户体验。
• 后台任务中一定要重新获取用户对象，不要使用原请求中的user实例——因为请求结束后，该实例的上下文已经被释放。
• 如果你的应用是多实例部署，后台任务队列可能需要使用分布式队列（比如Redis），否则任务只会在当前实例执行。

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