Blazor Server集成Azure SignalR遇协商错误，寻求实时更新方案

一、Azure SignalR 协商错误排查 #

你遇到的Invalid negotiation response received以及JsonReaderException: '<' is an invalid start of a value错误，本质是SignalR协商请求返回了HTML内容（而非预期的JSON），常见原因及排查步骤如下：

1. 路由配置不匹配 #

• 确认服务端Hub路由与客户端连接路径完全一致：
  • 服务端配置示例：

    // Program.cs 或 Startup.cs
    app.UseEndpoints(endpoints =>
    {
        endpoints.MapHub<PatientUpdateHub>("/patient-update-hub"); // 明确路由路径
        endpoints.MapBlazorHub();
        // 其他路由配置
    });
    

  • 客户端连接时必须使用相同路径：

    var hubConnection = new HubConnectionBuilder()
        .WithUrl(NavigationManager.ToAbsoluteUri("/patient-update-hub"))
        .Build();
    

  • 若路径拼写错误，协商请求会返回404 HTML页面，触发JSON解析失败。

2. 认证拦截导致重定向 #

由于你的应用基于Azure AD认证，SignalR协商请求可能被拦截并重定向到登录页面（返回HTML），需确保客户端连接时携带认证凭据：

var hubConnection = new HubConnectionBuilder()
    .WithUrl(NavigationManager.ToAbsoluteUri("/patient-update-hub"), options =>
    {
        options.UseDefaultCredentials = true;
        // 若使用Azure AD令牌认证，添加令牌获取逻辑
        options.AccessTokenProvider = async () =>
        {
            var tokenResult = await HttpContext.Request.HttpContext.GetTokenAsync("access_token");
            return tokenResult;
        };
    })
    .Build();

同时，若Hub仅允许已认证用户访问，需在Hub类上添加[Authorize]特性，避免匿名访问被拦截。

3. Azure SignalR连接字符串验证 #

确认appsettings.json中的连接字符串格式正确，需从Azure Portal的SignalR资源中复制完整字符串，格式应为：

{
  "Azure": {
    "SignalR": {
      "ConnectionString": "Endpoint=https://<your-signalr-resource>.service.signalr.net;AccessKey=<your-access-key>;Version=1.0;"
    }
  }
}

若连接字符串缺失关键部分，服务端无法正确路由到Azure SignalR服务，可能返回错误页面。

4. 中间件顺序错误 #

确保路由相关中间件顺序正确：

// 正确顺序
app.UseRouting();
app.UseAuthentication();
app.UseAuthorization();

app.UseEndpoints(endpoints =>
{
    endpoints.MapHub<PatientUpdateHub>("/patient-update-hub");
    endpoints.MapBlazorHub();
});

若UseEndpoints在UseRouting之前配置，会导致Hub路由无法被正确解析。

二、实时更新功能实现逻辑 #

当上述配置问题解决后，可按以下步骤实现患者信息实时同步：

1. 定义SignalR Hub：

public class PatientUpdateHub : Hub
{
    // 发送患者更新通知给所有客户端
    public async Task SendPatientUpdate(int patientId)
    {
        await Clients.All.SendAsync("ReceivePatientUpdate", patientId);
    }
}

2. EF更新后触发通知：
   在患者信息更新的业务逻辑中，注入IHubContext<PatientUpdateHub>并发送通知：

public class PatientService
{
    private readonly IHubContext<PatientUpdateHub> _hubContext;
    private readonly AppDbContext _dbContext;

    public PatientService(IHubContext<PatientUpdateHub> hubContext, AppDbContext dbContext)
    {
        _hubContext = hubContext;
        _dbContext = dbContext;
    }

    public async Task UpdatePatient(Patient patient)
    {
        _dbContext.Patients.Update(patient);
        await _dbContext.SaveChangesAsync();
        // 通知所有客户端更新
        await _hubContext.Clients.All.SendAsync("ReceivePatientUpdate", patient.Id);
    }
}

3. 客户端监听更新并刷新UI：
   在Blazor组件中监听Hub消息，收到通知后更新患者数据：

@inject NavigationManager NavigationManager
@implements IAsyncDisposable

@code {
    private HubConnection _hubConnection;
    private List<Patient> _patients;

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

        _hubConnection.On<int>("ReceivePatientUpdate", async (patientId) =>
        {
            // 更新单个患者数据或重新获取列表
            var updatedPatient = await PatientService.GetPatientById(patientId);
            var index = _patients.FindIndex(p => p.Id == patientId);
            if (index != -1)
            {
                _patients[index] = updatedPatient;
                StateHasChanged();
            }
        });

        await _hubConnection.StartAsync();
        // 初始化加载患者数据
        _patients = await PatientService.GetAllPatients();
    }

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

三、替代实时更新方案 #

若Azure SignalR配置仍有问题，可考虑以下替代方案：

1. 原生SignalR（无需Azure托管） #

本地测试时可先切换到Blazor Server自带的SignalR，去掉AddAzureSignalR()配置，仅保留services.AddSignalR();，确认功能正常后再迁移到Azure SignalR，排除云服务端的配置问题。

2. 优化定时器方案 #

若使用定时器，可通过以下方式避免干扰用户输入：

• 增量查询：记录上次查询时间，仅拉取该时间后更新的患者数据，减少数据传输量。
• 输入时暂停：监听表格输入控件的onfocus和onblur事件，聚焦时暂停定时器，失焦后恢复：

private System.Timers.Timer _updateTimer;
private bool _isUserEditing;
private DateTime _lastUpdateTime = DateTime.Now;

protected override void OnInitialized()
{
    _updateTimer = new System.Timers.Timer(5000); // 5秒间隔
    _updateTimer.Elapsed += async (sender, e) => await UpdatePatientData();
    _updateTimer.Start();
}

private async Task UpdatePatientData()
{
    if (!_isUserEditing)
    {
        // 增量查询更新数据
        var newPatients = await PatientService.GetUpdatedPatients(_lastUpdateTime);
        _patients.AddRange(newPatients);
        _lastUpdateTime = DateTime.Now;
        InvokeAsync(StateHasChanged);
    }
}

// 输入控件事件处理
private void OnEditStart() => _isUserEditing = true;
private void OnEditEnd() => _isUserEditing = false;

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