Blazor Web App中客户端与服务器的关联及主动消息推送方案咨询

一、默认场景下的服务器行为 #

你描述的这种常规服务调用（基于HTTP请求-响应模式），服务器不会主动记录客户端连接信息，也无法主动向客户端发送消息。因为每次请求处理完成后，HTTP连接就会断开，服务器不会保留客户端的持久连接状态。

二、可行方案：使用SignalR实现主动消息推送 #

Blazor官方推荐的最简实时双向通信方案是SignalR，它专门用于处理服务器与客户端之间的实时消息交互，支持服务器主动向特定或所有客户端发消息。以下是具体实现步骤：

1. 服务器端配置 #

（1）添加SignalR包

在服务器项目中安装Microsoft.AspNetCore.SignalR NuGet包。

（2）创建SignalR Hub类

Hub是SignalR的核心组件，负责处理客户端连接和消息路由：

using Microsoft.AspNetCore.SignalR;
using System.Collections.Concurrent;

public class TestHub : Hub
{
    // 用线程安全字典存储用户ID与连接ID的映射（生产环境可替换为分布式缓存）
    private static readonly ConcurrentDictionary<string, string> UserConnectionMap = new();

    // 客户端连接时记录映射关系
    public override async Task OnConnectedAsync()
    {
        var userId = Context.User?.Identity?.Name;
        if (!string.IsNullOrEmpty(userId))
        {
            UserConnectionMap[userId] = Context.ConnectionId;
        }
        await base.OnConnectedAsync();
    }

    // 客户端断开时移除映射
    public override async Task OnDisconnectedAsync(Exception? exception)
    {
        var userId = Context.User?.Identity?.Name;
        if (!string.IsNullOrEmpty(userId))
        {
            UserConnectionMap.TryRemove(userId, out _);
        }
        await base.OnDisconnectedAsync(exception);
    }

    // 向所有客户端发送消息
    public async Task SendToAll(string message)
    {
        await Clients.All.SendAsync("ReceiveMessage", message);
    }

    // 向特定用户发送消息
    public async Task SendToUser(string userId, string message)
    {
        if (UserConnectionMap.TryGetValue(userId, out var connectionId))
        {
            await Clients.Client(connectionId).SendAsync("ReceiveMessage", message);
        }
    }
}

（3）注册SignalR服务并映射Hub

在Program.cs中添加SignalR相关配置：

var builder = WebApplication.CreateBuilder(args);

// 注册SignalR服务
builder.Services.AddSignalR();
// 注册你的TestService
builder.Services.AddScoped<TestService>();

var app = builder.Build();

app.UseHttpsRedirection();
app.UseStaticFiles();
app.UseRouting();

// 映射SignalR Hub的访问路径
app.MapHub<TestHub>("/testhub");

app.MapBlazorHub();
app.MapFallbackToPage("/_Host");

app.Run();

2. 客户端配置（以Blazor Server为例） #

（1）注入HubConnection

Blazor Server会自动注入HubConnection，直接在Razor页面中使用即可：

@page "/"
@inject HubConnection HubConnection
@inject TestService TestService

<button class="btn btn-primary" @onclick="OnTest">Test</button>
<div>收到服务器消息：@ReceivedMessage</div>

@code {
    private string ReceivedMessage { get; set; } = string.Empty;

    protected override async Task OnInitializedAsync()
    {
        // 监听服务器发送的消息
        HubConnection.On<string>("ReceiveMessage", (message) =>
        {
            ReceivedMessage = message;
            StateHasChanged();
        });

        // 连接到SignalR Hub
        await HubConnection.StartAsync();
    }

    private async Task OnTest()
    {
        bool result = await TestService.TestMethod();
        // 业务逻辑处理
    }

    // 页面销毁时断开连接
    public async ValueTask DisposeAsync()
    {
        if (HubConnection is not null)
        {
            await HubConnection.DisposeAsync();
        }
    }
}

3. 服务器主动发消息的方式 #

如果需要在其他服务（比如你的TestService）中主动发消息，可以注入IHubContext<TestHub>：

public class TestService
{
    private readonly IHubContext<TestHub> _hubContext;

    public TestService(IHubContext<TestHub> hubContext)
    {
        _hubContext = hubContext;
    }

    public async Task<bool> TestMethod()
    {
        // 执行你的业务逻辑
        bool result = true;

        // 主动向所有客户端发送消息
        await _hubContext.Clients.All.SendAsync("ReceiveMessage", "TestMethod执行完成");

        // 主动向特定用户发送消息（示例：假设用户ID为"user123"）
        await _hubContext.Clients.Client(UserConnectionMap["user123"]).SendAsync("ReceiveMessage", "你的专属消息");

        return result;
    }
}

三、Blazor WASM的特殊说明 #

如果是Blazor WASM项目，客户端需要手动创建HubConnection：

using Microsoft.AspNetCore.SignalR.Client;
using Microsoft.AspNetCore.Components;

public class SignalRService
{
    public HubConnection HubConnection { get; }

    public SignalRService(NavigationManager navigationManager)
    {
        HubConnection = new HubConnectionBuilder()
            .WithUrl(navigationManager.ToAbsoluteUri("/testhub"))
            .Build();
    }
}

然后在Program.cs中注册为单例：

builder.Services.AddSingleton<SignalRService>();

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