定时器停止更新页面的 Blazor Server 问题

Question

我编写了一个使用 Blazor 服务器应用定期更新页面的程序。

该程序执行时，每秒获取当前时间和数据库表中的值并显示在页面上，但该定时器中的处理在一定时间后停止。

虽然没有准确测量，但计时器中的处理会在大约 10 到 30 分钟后停止。

但是，当我查看浏览器的调试工具时，没有错误，在visual studio上也没有错误。

我搜索了一个这样的例子，但找不到它，也无法确定是什么原因造成的。

我希望此计时器中的处理工作，直到我明确指定它停止。

这可能是什么原因？ 我有麻烦，因为我不知道原因。 请给我一些建议。 谢谢。

    private string Time { get; set; }

    protected override void OnInitialized()
    {
        var timer = new System.Threading.Timer((_) =>
        {
            Time = DateTime.Now.ToString();
            InvokeAsync(() =>
            {   
                // Get the value from the database
                databaseValue = TimerProcessGetValue();                
                StateHasChanged();
            });
        }, null, 0, 1000);
        base.OnInitialized();
    }

定时器中调用的进程

public async Task<int?> TimerProcessGetValue()
{
    int? timerProcessValue;
    using(DbContext = DbFactory.CreateDbContext())
    {
        timerProcessValue = dbContext.TestTable.Single(x => x.Id == 1).TestValue;
    }
    return timerProcessValue;
}

后记

目标组件的全文。

PageRefleshTest.cs

@page "/refresh-ui-manually"
@using System.Threading;
@using TestBlazorServer.Models;
@using Microsoft.EntityFrameworkCore;
@inject IDbContextFactory<SQLbeginnerContext> DbFactory

<h1>@Time</h1> 
<h1>TestValue:@databaseValue</h1>

private string Time { get; set; }
private int? databaseValue { get; set; }

protected override void OnInitialized()
{
    var timer = new System.Threading.Timer((_) =>
    {
        Time = DateTime.Now.ToString();
        InvokeAsync(() =>
        {
            // Get the value from the database
            databaseValue = TimerProcessGetValue().Result;
            StateHasChanged();
        });
    }, null, 0, 1000);
    base.OnInitialized();
}


public async Task<int?> TimerProcessGetValue()
{
    int? timerProcessValue;
    using (var dbContext = DbFactory.CreateDbContext())
    {
        timerProcessValue = dbContext.TestTable.Single(x => x.Id == 1).TestValue;
    }
    return timerProcessValue;
}

使用 System.Timers.Timer 实现

@page "/Refresh2"
@inject IDbContextFactory<SQLbeginnerContext> DbFactory
@using TestBlazorServer.Models
@using Microsoft.EntityFrameworkCore
@using System.Timers
@implements IDisposable

<h3>PageRefresh2</h3>
<h1>@Time</h1>
<h1>@currentCount</h1>
<h1>TestValue:@databaseValue/h1>

@code {

private int currentCount = 0;
private Timer timer2 = new(1000);
private string Time { get; set; }
private int? databaseValue { get; set; }

protected override void OnInitialized()
{
    timer2.Elapsed += (sender, eventArgs) => OnTimerCallback();
    timer2.Start();
}

private void OnTimerCallback()
{
    _ = InvokeAsync(() =>
    {
        currentCount++;
        Time = DateTime.Now.ToString();
        databaseValue = TimerProcessGetValue().Result;
        StateHasChanged();
    });
}


public void Dispose() => timer2.Dispose();


public async Task<int?> TimerProcessGetValue()
{
    int? timerProcessValue;
    await using (var dbContext = DbFactory.CreateDbContext())
    {
        timerProcessValue = dbContext.TestTable.Single(x => x.Id == 1).TestValue;
    }
    return timerProcessValue;
}

}

Answer 1

这当然可能是由于 SignalR 连接失败。不过，这应该会重新连接。

这里的主要嫌疑人是.Result。您应该始终避免在异步代码中使用 .Wait() 和 .Result。另外，您的数据库方法并不是真正的异步，这也可能起作用。

但是那个“半小时”也可能来自垃圾收集器抛出 Timer 对象。请参阅this page 上的紫色说明。当你有一个 Timer 时，你应该将它锚定在一个字段中并 Dispose() 它。

下一步是使事件处理程序成为async void，这是需要的极少数情况之一。然后只调用 StatehasChanged 调用。

@implements IDisposable

...
@code {
  System.Threading.Timer _timer;  // use a private field
  protected override void OnInitialized()
  {
    _timer = new System.Threading.Timer(async (_) =>
    {
        Time = DateTime.Now.ToString();
        databaseValue = await TimerProcessGetValue();
        await InvokeAsync(StateHasChanged);    
    }, null, 0, 1000);
    // base.OnInitialized();  -- not needed
  }

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

并使 Db 操作实际上是异步的：

public async Task<int?> TimerProcessGetValue()
{
    int? timerProcessValue;
    using (var dbContext = DbFactory.CreateDbContext())
    {
        timerProcessValue = 
          (await dbContext.TestTable.SingleAsync(x => x.Id == 1))
          .TestValue;
    }
    return timerProcessValue;
}

只有您可以现场测试，如果它有效，请告诉我们。