如何将 SignalR 集线器上下文传递给 ASP .NET Core 2.1 上的 Hangfire 作业？答案

【问题标题】：How can I pass a SignalR hub context to a Hangfire job on ASP .NET Core 2.1?如何将 SignalR 集线器上下文传递给 ASP .NET Core 2.1 上的 Hangfire 作业？
【发布时间】：2026-02-15 14:10:02
【问题描述】：

如何将 SignalR 集线器上下文传递给 ASP .NET Core 2.1 上的 Hangfire 作业？

似乎由于向 Hangfire 传递参数是通过序列化/反序列化完成的，Hangfire 似乎很难重建 SignalR 集线器上下文。

我使用 :

安排作业（在我的控制器中）

BackgroundJob.Schedule(() => _hubContext.Clients.All.SendAsync(
        "MyMessage",
        "MyMessageContent", 
        System.Threading.CancellationToken.None), 
    TimeSpan.FromMinutes(2));

然后 2 分钟后，当作业尝试执行时，我有错误：

Newtonsoft.Json.JsonSerializationException：无法创建 Microsoft.AspNetCore.SignalR.IClientProxy 类型的实例。类型是一个接口或抽象类，不能实例化。

有什么想法吗？

更新 1

我最终使用了 Startup.cs 中定义的静态上下文，并从 Configure() 分配

hbctx = app.ApplicationServices.GetRequiredService<IHubContext<MySignalRHub>>();

所以现在 Hangfire 安排了一个使用静态上下文的集线器助手：

BackgroundJob.Schedule(() => new MyHubHelper().Send(), TimeSpan.FromMinutes(2));

集线器助手通过Startup.hbctx获取上下文

虽然可以，但是有点臭

更新 2

我也尝试使用Access SignalR Hub without Constructor Injection中的方法：

我的后台作业调度变成了：

BackgroundJob.Schedule(() => Startup.GetService().SendOutAlert(2), TimeSpan.FromMinutes(2));

但是这一次，当我到达上面的行时，我有一个异常：

执行请求时发生未处理的异常 System.ObjectDisposedException：无法访问已处置的对象。对象名称：“IServiceProvider”。

更新 3

谢谢大家。解决方案是创建一个 helper，通过其构造函数通过 DI 获取 hubcontext，然后使用 hangfire 调度 helper 方法 Send 作为后台作业。

public interface IMyHubHelper
{
    void SendOutAlert(String userId);
}

public class MyHubHelper : IMyHubHelper
{
    private readonly IHubContext<MySignalRHub> _hubContext;

    public MyHubHelper(IHubContext<MySignalRHub> hubContext)
    {
        _hubContext = hubContext;
    }

    public void SendOutAlert(String userId)
    {
        _hubContext.Clients.All.SendAsync("ReceiveMessage", userId, "msg");
    }
}

然后从任何地方启动后台作业：

BackgroundJob.Schedule<MyHubHelper>( x => x.SendOutAlert(userId), TimeSpan.FromMinutes(2));

【问题讨论】：

使用 DI 方法并在需要时解析集线器上下文
@Yahia 查看我给here 的以下答案。尽管它主要针对的是重复性工作，但原则仍然是让工作解决必要的依赖关系以执行其功能。

标签： c# asp.net-core signalr hangfire asp.net-core-signalr

【解决方案1】：

使用Schedule<T> 泛型，您应该能够利用框架的依赖注入功能。

BackgroundJob.Schedule<IHubContext<MySignalRHub>>(hubContext => 
    hubContext.Clients.All.SendAsync(
        "MyMessage",
        "MyMessageContent", 
        System.Threading.CancellationToken.None), 
    TimeSpan.FromMinutes(2));

【讨论】：

通过使用 hangfire 容器，您无需将集线器上下文注入控制器。 Hangfire 将解决依赖关系，这将在表达式中使用。
您的回答为我指明了道路。解决方案是使用BackgroundJob.Schedule，而不是IHubContext<MySignalRHub>，而是MyHubHelper，其构造函数通过DI注入IHubContext<MySignalRHub>。作业的调度变为：BackgroundJob.Schedule<MyHubHelper>( x => x.SendOutAlert(userId), TimeSpan.FromMinutes(2));

【解决方案2】：

Nkosi 建议使用Schedule<T> generics 的回答指出了我使用的最终解决方案：

首先，我的 MySignalRHub 只是一个继承自 Hub 的空类。

public class MySignalRHub 
{
}

然后，我创建了一个集线器助手，它在我的 MySignalRHub 上维护一个集线器上下文。 hubcontext 通过 ASP.Net Core 内置的 DI 机制注入到 helper 类中（如here 解释）。

助手类：

public class MyHubHelper : IMyHubHelper
{
    private readonly IHubContext<MySignalRHub> _hubContext;

    public MyHubHelper(IHubContext<MySignalRHub> hubContext)
    {
        _hubContext = hubContext;
    }

    public void SendData(String data)
    {
        _hubContext.Clients.All.SendAsync("ReceiveMessage", data);
    }
}

帮助界面：

public interface IMyHubHelper
{
    void SendData(String data);
}

最后，我可以使用 hangfire 从代码中的任何位置调度集线器助手的方法 SendData() 作为后台作业：

BackgroundJob.Schedule<MyHubHelper>(h => h.SendData(myData), TimeSpan.FromMinutes(2));

【讨论】：