如何让SignalR捕获ASP.NET Core MVC Web应用的自定义事件

你当前的思路存在本质错误：.NET后台的MessageEvent是服务器端进程内的事件，前端JavaScript运行在浏览器的独立环境中，两者完全隔离，前端根本无法直接捕获服务器端的.NET事件。必须通过SignalR的双向通信机制来实现服务器到客户端的消息传递。

以下提供两种可行解决方案：

方案一：后台直接通过SignalR向前端推送消息 #

这是最直接的实时通信方案，后台触发逻辑时，直接调用SignalR的客户端推送API，前端监听对应的事件即可。

1. 修改后台代码，注入Hub上下文并推送消息 #

在后台异步任务类中，通过IHubContext<ChatHub>直接推送消息（需要依赖注入）：

public class ExternClass
{
    private readonly IHubContext<ChatHub> _hubContext;

    // 通过构造函数注入Hub上下文
    public ExternClass(IHubContext<ChatHub> hubContext)
    {
        _hubContext = hubContext;
    }

    // 你的后台异步任务方法
    public async Task RunBackgroundTask()
    {
        string s = "whatever";
        int id = 1;
        // 推送给所有在线客户端，可自定义事件名和参数
        await _hubContext.Clients.All.SendAsync("ReceiveBackendMessage", "后台系统", s);
        // 如果需要传递ID和文本两个参数：
        // await _hubContext.Clients.All.SendAsync("ReceiveBackendMessage", id, s);
    }
}

2. 前端JS新增监听事件 #

在chat.js中添加对应监听，接收后台推送的消息：

// 新增监听后台推送的消息
connection.on("ReceiveBackendMessage", function (user, message) {
    var li = document.createElement("li");
    document.getElementById("messagesList").appendChild(li);
    li.textContent = `${user}（后台）：${message}`;
});

// 如果是传递ID和文本的版本：
// connection.on("ReceiveBackendMessage", function (id, text) {
//     var li = document.createElement("li");
//     document.getElementById("messagesList").appendChild(li);
//     li.textContent = `后台消息 [ID:${id}]：${text}`;
// });

方案二：后台直接调用Hub的业务方法 #

如果你希望复用ChatHub中SendMessageToAll的逻辑，需要将业务逻辑抽离为公共服务，再通过Hub上下文推送消息。

1. 抽离公共业务逻辑 #

新建一个服务类，封装队列读取等核心逻辑：

public class MessageService
{
    // 封装原Hub中的队列读取逻辑
    public string GetLatestQueueMessage()
    {
        return Program.ExternClass.ReceivingQueue.First().ToString();
    }
}

2. 修改ChatHub，注入公共服务 #

using Microsoft.AspNetCore.SignalR;

namespace HTTPChat_Application.Hubs;

public class ChatHub : Hub
{
    private readonly MessageService _messageService;

    public ChatHub(MessageService messageService)
    {
        _messageService = messageService;
    }

    public async Task SendMessageToAll(string user, string message) {
        string latestMessage = _messageService.GetLatestQueueMessage();
        Console.WriteLine(latestMessage);
        await Clients.All.SendAsync("ReceiveMessage", user, latestMessage);
    }
}

3. 后台类调用公共服务并推送消息 #

public class ExternClass
{
    private readonly IHubContext<ChatHub> _hubContext;
    private readonly MessageService _messageService;

    public ExternClass(IHubContext<ChatHub> hubContext, MessageService messageService)
    {
        _hubContext = hubContext;
        _messageService = messageService;
    }

    public async Task TriggerHubMethod()
    {
        string user = "后台系统";
        string latestMessage = _messageService.GetLatestQueueMessage();
        Console.WriteLine(latestMessage);
        // 直接调用客户端接收方法，和Hub中逻辑一致
        await _hubContext.Clients.All.SendAsync("ReceiveMessage", user, latestMessage);
    }
}

4. 注册服务（Program.cs） #

在启动类中注册公共服务：

builder.Services.AddSingleton<MessageService>();

补充：原代码无效的核心原因 #

• .NET事件是服务器进程内部事件，仅在.NET运行时环境中触发，无法跨进程传递到浏览器前端。
• 前端document.addEventListener("MessageEvent")监听的是浏览器DOM事件（如click、自定义前端事件），和服务器端.NET事件完全不是同一概念。

内容的提问来源于stack exchange，提问作者Roger Almirall Jou