如何在后台任务中获取 IHttpContextAccessor 实例（或等效实例）？

Question

在我的 ASP.Net Core 3.1 webapi 中，我将 IHttpContextAccessor 注册为单例并将其注入到我的所有控制器中。我有一个接口，它也被注入到我的所有控制器和我的服务中（它们又连接到数据库）。实现是：

public class PrincipalProvider : IPrincipalProvider
{
    private readonly UserPrincipal principal;

    public PrincipalProvider(IHttpContextAccessor accessor)
    {
        accessor.HttpContext.Items.TryGetValue("principal", out object principal);
        this.principal = principal as UserPrincipal;
    }

    public UserPrincipal GetPrincipal()
    {
        return principal;
    }
}

服务的 ctor 看起来像：

    public MyService(
        IPrincipalProvider provider,
        ILogger<MyService> logger, 
        IUnitOfWork unitOfWork) : base(provider, logger, unitOfWork) 
    { }

只要我在请求上下文中，上述所有工作都会按预期工作。

我有一个控制器操作，它使用带有后台队列的新 IHostedService 实现来启动后台任务，它的启动方式如下：

backgroundQueue.QueueBackgroundWorkItem(async (scope, hubContext, ct) =>
{
    await hubContext.Clients.Client(provider.GetPrincipal().ConnectionId).Notify();
    var myService = scope.Resolve<IMyService>();
}

其中scope 是ILifetimeScope 而hubConext 是IHubContext<MyHub, IMyHub>。 provider 变量是注入控制器 ctor 的 IPrincipalProvider。

问题是，当我尝试在任务中解析IMyService 时，它会创建一个IPrincipalProvider 的实例，而这又需要IHttpContextAccessor，它不再存在。

在这种情况下，解决方案是什么？我是否需要在服务上使用另一个 IPrincipalProvider 从其他地方获取上下文的第二个 ctor？如果是这样的话，从哪里来？

Answer 1

最好的解决方案是有两个IPrincipalProvider 的实现，一个使用httpContextAccessor，另一个使用其他东西。不幸的是，拥有其他实现并不总是那么容易。

当您创建子生命周期范围时，您可以向该子生命周期范围添加注册。您可以在此处注册StaticPrincipalProvider。

 private async Task BackgroundProcessing(...) {
    ... 
    try {
        using(ILifetimeScope queueScope = this._rootScope.BeginLifetimeScope(builder => {
            builder.RegisterInstance(new StaticPrincipalProvider(principal))
                   .As<IPrincipalProvider>();
        })){
            await workItem(queueScope, stoppingToken);
        }
    }
    ...
 }

你现在要做的就是想办法在你出队任务的时候获取对应的principal。为此，您可以将BackgroundTaskQueue 的实现更改为使用ConcurrentQueue<WorkItem> 而不是ConcurrentQueue<Func<ILifetimeScope, CancellationToken, Task>>，其中WorkItem 是

public class WorkItem {
    public Func<ILifetimeScope, CancellationToken, Task> Work { get; private set; }
    public IPrincipal Principal { get; private set; }
    // or
    public Action<ContainerBuilder> builderAccessor { get; private set; }
}

并且因为BackgroundTaskQueue 被实例化为请求范围，您将可以访问当前主体。