Blazor Server（.NET 8）能否复用BlazorHub实现实时通知？

核心结论 #

不建议复用Blazor框架内置的BlazorHub，最佳实践是单独创建自定义SignalR Hub来实现你的实时通知、功能动态开关需求。

为什么不能复用BlazorHub？ #

• BlazorHub是Blazor Server框架内部用于组件状态同步、双向通信的核心组件，遵循框架专属的通信协议与生命周期逻辑。
• 强行在BlazorHub中添加自定义业务逻辑，可能干扰框架正常运行（比如组件渲染异常、状态同步失败），且.NET版本更新时，框架对BlazorHub的内部实现可能调整，导致自定义代码出现兼容性问题。

.NET 8 Blazor Server中自定义Hub的实现步骤 #

1. 创建自定义SignalR Hub类

using Microsoft.AspNetCore.SignalR;

public class AppHub : Hub
{
    // 推送功能开关更新给所有客户端
    public async Task BroadcastFeatureToggle(string featureName, bool isEnabled)
    {
        await Clients.All.SendAsync("ReceiveFeatureToggleUpdate", featureName, isEnabled);
    }

    // 推送冲突操作通知给指定用户
    public async Task SendConflictNotification(string userId, string message)
    {
        await Clients.User(userId).SendAsync("ReceiveConflictAlert", message);
    }
}

2. 在Program.cs中注册自定义Hub
   在BlazorHub注册之后添加自定义Hub的端点（两者完全独立，互不干扰）：

var builder = WebApplication.CreateBuilder(args);

// 添加Blazor服务
builder.Services.AddRazorComponents()
    .AddInteractiveServerComponents();

// 显式添加SignalR服务（Blazor Server已隐含依赖，显式声明更清晰）
builder.Services.AddSignalR();

var app = builder.Build();

// 中间件配置...

// 映射Blazor框架内置Hub（默认端点/_blazor）
app.MapBlazorHub();
// 映射自定义Hub，指定独立端点
app.MapHub<AppHub>("/app-hub");

app.MapRazorComponents<App>()
    .AddInteractiveServerRenderMode();

app.Run();

3. 在Blazor组件中使用自定义Hub
   注入HubConnection并连接，接收实时消息：

@page "/"
@using Microsoft.AspNetCore.SignalR.Client
@inject NavigationManager NavManager
@implements IAsyncDisposable

<h3>系统状态</h3>
<p>功能X状态: @isFeatureXEnabled</p>

@code {
    private HubConnection? _hubConnection;
    private bool isFeatureXEnabled;

    protected override async Task OnInitializedAsync()
    {
        _hubConnection = new HubConnectionBuilder()
            .WithUrl(NavManager.ToAbsoluteUri("/app-hub"))
            .Build();

        // 监听功能开关更新
        _hubConnection.On<string, bool>("ReceiveFeatureToggleUpdate", (featureName, enabled) =>
        {
            if (featureName == "FeatureX")
            {
                isFeatureXEnabled = enabled;
                StateHasChanged();
            }
        });

        // 监听冲突通知
        _hubConnection.On<string>("ReceiveConflictAlert", (message) =>
        {
            // 这里可弹出通知或更新UI
            Console.WriteLine($"冲突警告: {message}");
        });

        await _hubConnection.StartAsync();
    }

    public async ValueTask DisposeAsync()
    {
        if (_hubConnection != null)
        {
            await _hubConnection.DisposeAsync();
        }
    }
}

4. 结合ConcurrentDictionary的业务逻辑推送消息
   当修改全局功能开关或检测到冲突操作时，通过自定义Hub推送消息：

// 全局状态管理类示例
public class GlobalAppState
{
    private readonly ConcurrentDictionary<string, bool> _featureToggles = new();
    private readonly IHubContext<AppHub> _hubContext;

    public GlobalAppState(IHubContext<AppHub> hubContext)
    {
        _hubContext = hubContext;
    }

    public async Task UpdateFeatureToggle(string featureName, bool isEnabled)
    {
        _featureToggles.AddOrUpdate(featureName, isEnabled, (_, _) => isEnabled);
        // 推送给所有客户端
        await _hubContext.Clients.All.SendAsync("ReceiveFeatureToggleUpdate", featureName, isEnabled);
    }

    public async Task NotifyConflict(string userId, string taskName)
    {
        var message = $"用户{userId}正在执行{taskName}，请稍后再试";
        // 推送给指定用户
        await _hubContext.Clients.User(userId).SendAsync("ReceiveConflictAlert", message);
    }
}

额外说明 #

如果需要更细粒度的客户端分组（比如按公司、部门分组），自定义Hub可灵活使用Groups相关API实现，完全适配业务需求。

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