使用 HttpContextBase 设置 HttpContext.Current

Question

我有一个在线程中运行的长时间运行的任务。我想在这个线程中设置HttpContext.Current，这样我的HttpContextFactory就可以得到当前的HttpContext。

这是我的 TaskRunner 类：

public class TaskRunner
{
    public TaskRunner(
        IQueueProcessorFactory queueProcessorFactory,
        IHttpContextFactory httpContextFactory)
    {
        _queueProcessorFactory = queueProcessorFactory;
        _httpContextFactory = httpContextFactory;
    }

    public void StartQueueProcessorThread()
    {
        var currentContext = _httpContextFactory.Create(); // Simply Gets new HttpContextWrapper(HttpContext.Current);
        queueProcessor = new Thread(
        () =>
        {
            HttpContext.Current = currentContext; // Cannot implicitly convert type 'System.Web.HttpContextBase' to 'System.Web.HttpContext'
            _queueProcessorFactory.Create().ProcessQueue(); // Log running task
        })
        { Name = "QueueProcessor" };
        queueProcessor.Start();
    }
}

有没有使用注入的 _httpContextFactory 设置 HttpContext.Current 的简单方法？

Answer 1

你想要的东西是不可能的，你也不应该尝试实现这样的事情。您的问题是由严重依赖HttpContext.Current 的代码引起的。这违反了依赖倒置原则。由于您的代码在后台线程上运行，因此它不是在 HTTP 请求的上下文中运行，因此不应使用请求信息。

解决方案是定义抽象HttpContext 的特定于应用程序的抽象。例如，当该代码需要有关当前用户的信息时，定义一个 IUserContext 抽象：

public interface IUserContext
{
    Guid UserId { get; }
}

这允许您在后台线程上运行时注入不同的IUserContext 实现。

您的网络请求的 IUserContext 实现可能如下所示：

public sealed class AspNetUserContext : IUserContext
{
    public Guid UserId => (Guid)HttpContext.Current.Session["UserId"];
}

另一方面，您在后台线程上使用的用户上下文可能实现如下：

public sealed class ThreadStaticUserContext : IUserContext
{
    [ThreadStatic]
    public static Guid UserIdField;

    public Guid UserId => this.UserIdField;
}

这个ThreadStaticUserContext 允许设置UserId。如果您想分离一个在与发起请求相同的用户 ID 中运行的后台线程，您必须将用户 ID 传递给后台线程，并在运行完整操作之前设置 FixedUserContext.UserId 值。这可能看起来像这样：

public AsynchronousWelcomeMessageSenderDecorator : IWelcomeMessageSender
{
    private readonly IUserContext userContext;
    private readonly Func<IWelcomeMessageSender> senderFactory;

    public AsynchronousWelcomeMessageSenderDecorator(
        IUserContext userContext, 
        Func<IWelcomeMessageSender> senderFactory) { ... }

    public void SendWelcomeMessage(WelcomeMessage message)
    {
        // Read the user ID while running on the request thread
        Guid userId = this.userContext.UserId;

        ThreadPool.QueueUserWorkItem(_ =>
        {
            // Set the user ID as the first thing to do on the background thread.
            ThreadStaticUserContext.UserIdField = userId;

            // Resolve the 'real' sender within the thread.
            IWelcomeMessageSender realSender = this.senderFactory();

            // Forward the call to the real sender.
            realSender.SendWelcomeMessage(message);
        });
    }
}

给你一个想法，在没有 DI 容器的情况下，对象图的这一部分可以构造如下：

IWelcomeMessageSender sender =
    new AsynchronousWelcomeMessageSenderDecorator(
        new AspNetUserContext(),
        () => new EmailMessageSender(new ThreadSpecificUserContext()));

换句话说，任何依赖于IWelcomeMessageSender 的组件都会注入AsynchronousWelcomeMessageSenderDecorator。当它的SendWelcomeMessage 被调用时，它会启动一个后台线程，该线程将通过senderFactory 请求一个IWelcomeMessageSender。 senderFactory 将创建一个新的EmailMessageSender 来发送实际邮件。这个EmailMessageSender 再次依赖于IUserContext，但在这种情况下，它被注入了ThreadSpecificUserContext。