ASP.NET MVC .NET6中SignalR单向通信问题：客户端收不到消息

核心问题点 #

1. IHubContext实例化错误 #

直接通过new IHubContext<SignalUpdateHub>()创建上下文无效，SignalR的IHubContext必须通过依赖注入获取，否则无法关联到实际运行的Hub实例。

2. 推送方法名不匹配 #

服务器端推送时调用的是SendAsync("SendAsync","newMessge")，但客户端监听的是sendNewSignal，两者名称不一致，导致消息无法被接收。

3. 客户端JavaScript语法错误 #

connection.on("sendNewSignal", function(message)=> { ... }) 混合了function声明和箭头函数语法，会导致回调无法正确注册。

4. .NET6启动配置潜在问题 #

.NET6默认使用顶级语句，原Startup写法需调整以适配新的Program.cs结构。

修正后的代码示例 #

服务器端：正确获取IHubContext并推送 #

在控制器/服务中注入IHubContext

public class MessageController : Controller
{
    private readonly IHubContext<SignalUpdateHub> _hubContext;

    // 通过构造函数注入IHubContext
    public MessageController(IHubContext<SignalUpdateHub> hubContext)
    {
        _hubContext = hubContext;
    }

    // 触发推送的示例方法
    public async Task<IActionResult> PushMessage()
    {
        // 调用客户端监听的"sendNewSignal"方法
        await _hubContext.Clients.All.SendAsync("sendNewSignal", "newMessage");
        return Ok();
    }
}

Hub类（单向推送场景可简化为空类）

public class SignalUpdateHub : Hub
{
    // 若无需客户端主动调用服务器方法，该类可留空
}

.NET6 Program.cs启动配置

var builder = WebApplication.CreateBuilder(args);

// 配置CORS策略，添加AllowCredentials支持跨域SignalR连接
builder.Services.AddCors(p => p.AddPolicy("corsapp", builder =>
{
    builder.WithOrigins("*").AllowAnyMethod().AllowAnyHeader().AllowCredentials();
}));

// 注册SignalR服务
builder.Services.AddSignalR(o => o.EnableDetailedErrors = true);

var app = builder.Build();

// 中间件顺序：先启用CORS，再配置端点
app.UseCors("corsapp");

app.UseRouting();

app.UseEndpoints(endpoints =>
{
    endpoints.MapHub<SignalUpdateHub>("/signalUpdate");
});

app.Run();

客户端修正后的JavaScript代码 #

document.addEventListener('DOMContentLoaded', function() {
    var connection = new signalR.HubConnectionBuilder()
        .withUrl("https://localhost:2041/signalUpdate")
        .withAutomaticReconnect()
        .configureLogging(signalR.LogLevel.Debug)
        .build();

    // 修正箭头函数语法，确保回调正确注册
    connection.on("sendNewSignal", (message) => {
        console.log("收到服务器推送消息：", message);
    });

    async function start() {
        try {
            await connection.start(); // 用await确保连接成功后再打印日志
            console.log("SignalR Connected.");
        } catch (err) {
            console.log(err);
            setTimeout(start, 5000);
        }
    };

    connection.onclose(async () => {
        await start();
    });

    start();
});

验证要点 #

1. 确保服务器推送的方法名与客户端connection.on监听的方法名大小写完全一致
2. 严禁手动实例化IHubContext，必须通过依赖注入获取
3. CORS策略需添加AllowCredentials()，否则跨域SignalR连接会存在隐性权限问题
4. 客户端connection.start()需用await等待连接建立完成，避免提前打印"已连接"的误导日志

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