Blazor Server中SignalR工作原理及数据未实时同步问题咨询

核心原因 #

Blazor Server里的SignalR是负责组件与服务器端代码之间的双向通信，它本身不会自动监听数据库的外部变更（比如SSMS直接修改数据）。具体来说：

• EF Core的DbContext没有内置数据库变更监听能力：你通过EF Core查询数据时，只是在查询瞬间拉取当前数据快照，之后数据库的外部修改，DbContext不会主动感知，服务器端也不会收到任何通知。
• SignalR需要触发源才能推送更新：只有当服务器端代码感知到数据变化（比如应用内的更新操作），才会通过SignalR把新数据推给客户端；而SSMS的操作属于外部修改，没有触发服务器端的任何事件，所以SignalR没有推送的依据。

解决办法 #

根据场景不同，有几种常用的实现方式：

1. 定时刷新（简单场景首选）

通过定时任务重新查询数据库，然后手动触发组件刷新。适合对实时性要求不高的场景：

@implements IDisposable
@inject ApplicationDbContext _dbContext

<h3>员工列表</h3>
<ul>
    @foreach (var emp in Employees)
    {
        <li>@emp.Name - @emp.Position</li>
    }
</ul>

@code {
    private List<Employee> Employees { get; set; } = new();
    private System.Timers.Timer? _refreshTimer;

    protected override async Task OnInitializedAsync()
    {
        await LoadEmployees();
        // 每5秒刷新一次，可根据需求调整间隔
        _refreshTimer = new System.Timers.Timer(5000);
        _refreshTimer.Elapsed += async (_, __) => await LoadEmployees();
        _refreshTimer.Start();
    }

    private async Task LoadEmployees()
    {
        // 每次查询都获取最新数据
        Employees = await _dbContext.Employees.AsNoTracking().ToListAsync();
        // 跨线程调用组件刷新方法
        await InvokeAsync(StateHasChanged);
    }

    public void Dispose()
    {
        _refreshTimer?.Dispose();
    }
}

2. 监听数据库变更通知（实时性要求高的场景）

利用SQL Server的SqlDependency功能，监听特定查询的数据库变更，当数据变化时通过SignalR推送给客户端：

• 首先确保SQL Server启用了Service Broker（可通过SSMS执行ALTER DATABASE YourDbName SET ENABLE_BROKER;）
• 然后在服务器端配置监听：

public class EmployeeService
{
    private readonly ApplicationDbContext _dbContext;
    private readonly IHubContext<EmployeeHub> _hubContext;

    public EmployeeService(ApplicationDbContext dbContext, IHubContext<EmployeeHub> hubContext)
    {
        _dbContext = dbContext;
        _hubContext = hubContext;
        SetupSqlDependency();
    }

    private void SetupSqlDependency()
    {
        SqlDependency.Start(_dbContext.Database.GetConnectionString());
        using var connection = new SqlConnection(_dbContext.Database.GetConnectionString());
        connection.Open();
        using var command = new SqlCommand("SELECT Id, Name, Position FROM dbo.Employees", connection);
        var dependency = new SqlDependency(command);
        dependency.OnChange += async (_, e) =>
        {
            if (e.Info != SqlNotificationInfo.Invalid)
            {
                // 通知所有客户端刷新数据
                await _hubContext.Clients.All.SendAsync("EmployeesUpdated");
                // 重新注册监听
                SetupSqlDependency();
            }
        };
        command.ExecuteReader();
    }
}

• 在Blazor组件中订阅SignalR事件：

@inject IHubConnectionBuilder _hubConnectionBuilder
@implements IDisposable

@code {
    private HubConnection? _hubConnection;

    protected override async Task OnInitializedAsync()
    {
        _hubConnection = _hubConnectionBuilder.WithUrl(NavigationManager.ToAbsoluteUri("/employeeHub")).Build();
        _hubConnection.On("EmployeesUpdated", async () =>
        {
            await LoadEmployees();
            await InvokeAsync(StateHasChanged);
        });
        await _hubConnection.StartAsync();
        await LoadEmployees();
    }

    private async Task LoadEmployees()
    {
        // 加载最新数据逻辑
    }

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

3. 应用内操作主动推送（如果是应用自身修改数据）

如果数据变更是通过你的应用（比如后台管理页面）触发的，那在修改完成后直接通过SignalR通知所有客户端：

• 首先定义SignalR Hub：

public class EmployeeHub : Hub { }

• 在Program.cs中注册Hub：

app.MapHub<EmployeeHub>("/employeeHub");

• 在数据更新方法中添加推送逻辑：

public async Task UpdateEmployee(Employee updatedEmp)
{
    _dbContext.Employees.Update(updatedEmp);
    await _dbContext.SaveChangesAsync();
    // 通知所有客户端刷新
    await _hubContext.Clients.All.SendAsync("EmployeesUpdated");
}

• 组件端的订阅逻辑和方案2一致。

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