Blazor中Scoped Service事件处理问题：跨租户页面同步更新失败

问题根源 #

1. Scoped服务的隔离性：Scoped服务在每个用户会话中会生成独立实例，你调用OnPageStateChanged.Invoke时，仅会触发当前用户服务实例的事件，其他租户用户的服务实例完全接收不到触发信号，自然无法通知对应组件更新。
2. 组件订阅时机错误：你的组件在OnAfterRender(bool firstRender)的firstRender为true时就取消了事件订阅，这意味着组件首次渲染完成后，再也无法接收任何事件通知——哪怕是当前用户自身的后续操作也不会触发更新。

修复步骤与解决方案 #

第一步：修正组件的订阅/取消订阅逻辑 #

将取消订阅的代码移至组件的IDisposable实现中，确保组件销毁时才解绑事件，避免提前丢失订阅：

public partial class YourComponent : IDisposable
{
    private Action<string, int, int>? pageStateChangedHandler;

    protected override async Task OnInitializedAsync()
    {
        pageStateChangedHandler = HandlePageStateChanged;
        mainService.OnPageStateChanged += pageStateChangedHandler;
        // 省略其他初始化代码
    }

    private async void HandlePageStateChanged(string detailId, int minusChange, int plusChange)
    {
        var changedPage = PageDetails?.FirstOrDefault(x => x.ID == detailId);
        if (changedPage != null)
        {
            changedPage.Incremental += plusChange;
            changedPage.Decremental -= minusChange;
            await InvokeAsync(() => StateHasChanged());
        }
    }

    // 实现IDisposable接口，组件销毁时取消订阅
    public void Dispose()
    {
        if (pageStateChangedHandler != null)
        {
            mainService.OnPageStateChanged -= pageStateChangedHandler;
        }
    }
}

第二步：实现跨用户的事件通知（二选一） #

方案A：使用SignalR（推荐，原生支持跨客户端通信）

SignalR是Blazor官方推荐的跨客户端实时通信方案，可直接向指定租户的所有用户推送通知：

1. 创建SignalR Hub：

public class TenantUpdateHub : Hub
{
    // 客户端调用此方法加入租户组
    public async Task JoinTenantGroup(string tenantId)
    {
        await Groups.AddToGroupAsync(Context.ConnectionId, tenantId);
    }

    // 服务端调用此方法向租户组推送更新
    public async Task SendTenantUpdate(string tenantId, string detailId, int minusChange, int plusChange)
    {
        await Clients.Group(tenantId).SendAsync("ReceiveTenantUpdate", detailId, minusChange, plusChange);
    }
}

2. 在Program.cs注册Hub：

builder.Services.AddSignalR();
// ...
app.MapHub<TenantUpdateHub>("/tenantUpdateHub");

3. 修改mainService，注入HubContext并在SubmitChange时推送通知：

private readonly IHubContext<TenantUpdateHub> _hubContext;
private readonly string _currentTenantId; // 从当前上下文获取租户ID，比如通过认证信息

public mainService(IDbContextFactory<ApplicationDbContext> factory, IHubContext<TenantUpdateHub> hubContext, IHttpContextAccessor httpContextAccessor)
{
    _factory = factory;
    _hubContext = hubContext;
    // 示例：从HttpContext的用户声明中获取租户ID，根据实际实现调整
    _currentTenantId = httpContextAccessor.HttpContext?.User.FindFirst("TenantId")?.Value ?? string.Empty;
}

public async Task<bool> SubmitChange(List<Changes> MainChanges)
{
    // 省略业务逻辑代码
    // 向当前租户的所有用户推送更新
    await _hubContext.Clients.Group(_currentTenantId).SendAsync("ReceiveTenantUpdate", Details.ID, 1, 1);
    return true;
}

4. 组件中订阅SignalR通知：

private HubConnection? _hubConnection;
private string _currentTenantId; // 获取当前租户ID

protected override async Task OnInitializedAsync()
{
    // 初始化Hub连接
    _hubConnection = new HubConnectionBuilder()
        .WithUrl(NavigationManager.ToAbsoluteUri("/tenantUpdateHub"))
        .Build();

    // 订阅更新事件
    _hubConnection.On<string, int, int>("ReceiveTenantUpdate", HandlePageStateChanged);

    await _hubConnection.StartAsync();
    // 加入当前租户组
    await _hubConnection.SendAsync("JoinTenantGroup", _currentTenantId);

    // 其他初始化代码
}

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

方案B：使用Singleton事件总线中转

如果暂时不想引入SignalR，可以创建一个Singleton的事件总线，作为Scoped服务之间的通信桥梁：

1. 创建Singleton事件总线：

public interface ITenantEventBus
{
    event EventHandler<TenantUpdateEventArgs>? TenantUpdated;
    void PublishTenantUpdate(string tenantId, string detailId, int minusChange, int plusChange);
}

public class TenantEventBus : ITenantEventBus
{
    public event EventHandler<TenantUpdateEventArgs>? TenantUpdated;

    public void PublishTenantUpdate(string tenantId, string detailId, int minusChange, int plusChange)
    {
        TenantUpdated?.Invoke(this, new TenantUpdateEventArgs(tenantId, detailId, minusChange, plusChange));
    }
}

public class TenantUpdateEventArgs : EventArgs
{
    public string TenantId { get; }
    public string DetailId { get; }
    public int MinusChange { get; }
    public int PlusChange { get; }

    public TenantUpdateEventArgs(string tenantId, string detailId, int minusChange, int plusChange)
    {
        TenantId = tenantId;
        DetailId = detailId;
        MinusChange = minusChange;
        PlusChange = plusChange;
    }
}

2. 在Program.cs注册为Singleton：

builder.Services.AddSingleton<ITenantEventBus, TenantEventBus>();

3. 修改mainService，注入事件总线并发布事件：

private readonly ITenantEventBus _eventBus;
private readonly string _currentTenantId;

public mainService(IDbContextFactory<ApplicationDbContext> factory, ITenantEventBus eventBus, IHttpContextAccessor httpContextAccessor)
{
    _factory = factory;
    _eventBus = eventBus;
    _currentTenantId = httpContextAccessor.HttpContext?.User.FindFirst("TenantId")?.Value ?? string.Empty;
}

public async Task<bool> SubmitChange(List<Changes> MainChanges)
{
    // 省略业务逻辑代码
    _eventBus.PublishTenantUpdate(_currentTenantId, Details.ID, 1, 1);
    return true;
}

4. 组件中订阅事件总线的通知：

private ITenantEventBus _eventBus;
private string _currentTenantId;
private EventHandler<TenantUpdateEventArgs>? _updateHandler;

protected override void OnInitialized()
{
    _updateHandler = (sender, args) =>
    {
        // 只处理当前租户的更新
        if (args.TenantId == _currentTenantId)
        {
            HandlePageStateChanged(args.DetailId, args.MinusChange, args.PlusChange);
        }
    };
    _eventBus.TenantUpdated += _updateHandler;
}

public void Dispose()
{
    if (_updateHandler != null)
    {
        _eventBus.TenantUpdated -= _updateHandler;
    }
}

关键注意事项 #

• 获取租户ID的逻辑需根据系统实际实现调整，确保能正确识别当前用户所属租户。
• Blazor WASM与Server获取租户ID的方式不同，WASM需从认证令牌或客户端存储中获取。
• 使用事件总线时，必须在组件销毁时取消订阅，避免内存泄漏。

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