日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網站首頁 編程語言 正文

實現.Net7下數據庫定時檢查的方法詳解_實用技巧

作者：Newbe36524 ? 更新時間： 2023-01-20 編程語言

在軟件開發過程中，有時候我們需要定時地檢查數據庫中的數據，并在發現新增數據時觸發一個動作。為了實現這個需求，我們在 .Net 7 下進行一次簡單的演示。

PeriodicTimer

.Net 6 中新增了 PeriodicTimer 這個類，它可以用來創建一個定時器，以固定間隔的時間調用回調函數。使用方法如下：

using?var?timer?=?new?PeriodicTimer(TimeSpan.FromSeconds(10));
while?(await?timer.WaitForNextTickAsync())
{
????//Business?logic
}

這樣就可以每隔 10 秒執行一次操作。

PeriodicTimer 相比于傳統 Timer 的優勢在于：

  • PeriodicTimer 將使我們能夠異步地等待指定的時間間隔。
  • 在回調的執行過程中，我們可以阻止下一次回調的執行，直到我們完成了當前的操作。

BackgroundService

AspNetCore 中的 BackgroundService 類，它是一個抽象類，實現了 IHostService 接口，可以被用來創建后臺服務。使用方法如下：

using?System;
using?System.Threading;
using?System.Threading.Tasks;
using?Microsoft.Extensions.Hosting;

namespace?ConsoleApp1
{
????public?class?DatabaseCheckService?:?BackgroundService
????{
????????protected?override?async?Task?ExecuteAsync(CancellationToken?stoppingToken)
????????{
????????????while?(!stoppingToken.IsCancellationRequested)
????????????{
????????????????Console.WriteLine("Checking?database...");
????????????????//?檢查數據庫代碼
????????????????await?Task.Delay(TimeSpan.FromSeconds(5),?stoppingToken);
????????????}
????????}
????}

????class?Program
????{
????????static?void?Main(string[]?args)
????????{
????????????var?host?=?new?HostBuilder()
????????????????.ConfigureServices((hostContext,?services)?=>
????????????????{
????????????????????services.AddHostedService<DatabaseCheckService>();
????????????????})
????????????????.Build();

????????????host.Run();
????????}
????}
}

在這個例子中，我們繼承了 BackgroundService 類并重寫了 ExecuteAsync 方法。ExecuteAsync 方法會在后臺服務啟動時被調用，并在參數 stoppingToken 被取消時退出。我們在 while 循環中使用 Task.Delay 方法來等待 5 秒，并在每次循環中調用檢查數據庫的代碼。

結合使用

我們可以將 PeriodicTimer 和 BackgroundService 結合起來，實現一個定時檢查數據庫的后臺服務。代碼如下：

using?System;
using?System.Threading;
using?System.Threading.Tasks;
using?Microsoft.Extensions.Hosting;
using?Microsoft.Extensions.Logging;

namespace?ConsoleApp1
{
????public?class?DatabaseCheckService?:?BackgroundService
????{
????????protected?override?async?Task?ExecuteAsync(CancellationToken?stoppingToken)
????????{
????????????using?var?timer?=?new?PeriodicTimer(TimeSpan.FromSeconds(10));
????????????while?(!stoppingToken.IsCancellationRequested)
????????????{
????????????????if?(await?timer.WaitForNextTickAsync(stoppingToken))
????????????????{
????????????????????Console.WriteLine("Checking?database...");
????????????????????//?檢查數據庫代碼
????????????????}
????????????}
????????}
????}

????class?Program
????{
????????static?void?Main(string[]?args)
????????{
????????????var?host?=?new?HostBuilder()
????????????????.ConfigureServices((hostContext,?services)?=>
????????????????{
????????????????????services.AddHostedService<DatabaseCheckService>();
????????????????})
????????????????.Build();

????????????host.Run();
????????}
????}
}

總結

在這篇文章中，我們介紹了如何使用 .Net 7 中的 PeriodicTimer 類和 BackgroundService 類來實現一個定時檢查數據庫的后臺服務。實際使用中會遇到更多復雜的場景，這篇文章只是一個簡單的示例。

原文鏈接：https://www.cnblogs.com/newbe36524/p/16989678.html

欄目分類
最近更新