在背景服務中託管 ASP.NET Core SignalR

作者：Dave Pringle 和 Brady Gaster

本文提供下列項目的指導：

• 使用裝載 ASP.NET Core 的背景背景工作處理序，裝載 SignalR 中樞。
• 從 .NET BackgroundService內將訊息傳送至連線的用戶端。

檢視或下載範例程式碼 \(英文\) (如何下載)

在應用程式啟動時啟用 SignalR

在背景背景工作處理序的內容中裝載 ASP.NET Core SignalR 中樞，與在 ASP.NET Core Web 應用程式中裝載的方式相同。 在 Program.cs 中，呼叫 builder.Services.AddSignalR 會將必要的服務新增至 ASP.NET Core 相依性插入 (DI) 層，以支援 SignalR。 在 MapHubWebApplication 上呼叫了 app 方法，以連線 ASP.NET Core 要求管線中的中樞端點。

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddSignalR();
builder.Services.AddHostedService<Worker>();

var app = builder.Build();

app.MapHub<ClockHub>("/hubs/clock");

app.Run();

在上述範例中，類別 ClockHub 會實作 Hub<T> 類別來建立強型別中樞。 已在 ClockHub 中設定 Program.cs，以回應端點 /hubs/clock 的要求。

如需強型別中樞的詳細資訊，請參閱在適用於 SignalR 的 ASP.NET Core 中使用中樞。

Note

這項功能不限於中樞<T> 類別。 繼承自中樞的任何類別 (例如 DynamicHub) 均適用。

public class ClockHub : Hub<IClock>
{
    public async Task SendMyLocalTimeToOtherClients(DateTime dateTime)
    {
        await Clients.All.ShowTime(dateTime);
    }
}

強型別 ClockHub 所使用的介面是 IClock 介面。

public interface IClock
{
    Task ShowTime(DateTime currentTime);
}

從背景服務呼叫 SignalR 中樞

在啟動期間，將使用 Worker 啟用 BackgroundService 類別 AddHostedService。

builder.Services.AddHostedService<Worker>();

由於在啟動階段也會啟用 SignalR，因此每個中樞都會附加至 ASP.NET Core HTTP 要求管線中的個別端點，因此每個中樞都會在伺服器上以 IHubContext<T> 來表示。 使用 ASP.NET Core 的 DI 功能，裝載層所具現化的其他類別 (例如 BackgroundService 類別、MVC 控制器類別或 Razor 頁面模型) 可以透過在建構期間接受 IHubContext<ClockHub, IClock> 執行個體來取得伺服器端中樞的參考。

public class Worker : BackgroundService
{
    private readonly ILogger<Worker> _logger;
    private readonly IHubContext<ClockHub, IClock> _clockHub;

    public Worker(ILogger<Worker> logger, IHubContext<ClockHub, IClock> clockHub)
    {
        _logger = logger;
        _clockHub = clockHub;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            _logger.LogInformation("Worker running at: {Time}", DateTime.Now);
            await _clockHub.Clients.All.ShowTime(DateTime.Now);
            await Task.Delay(1000, stoppingToken);
        }
    }
}

當背景服務中反覆呼叫 ExecuteAsync 方法時，伺服器目前的日期和時間會使用 ClockHub傳送至連線的用戶端。

使用背景服務回應 SignalR 事件

如同使用 SignalR 之 JavaScript 用戶端的單頁應用程式，或使用 ASP.NET Core SignalR .NET 用戶端的 .NET 傳統型應用程式一樣，BackgroundService 或 IHostedService 實作也可用於連線至 SignalR 中樞並回應事件。

ClockHubClient 類別會同時實作 IClock 介面和 IHostedService 介面。 如此一來，就可以在啟始期間啟用，以持續執行，並從伺服器回應中樞事件。

public partial class ClockHubClient : IClock, IHostedService
{
}

初始化期間，ClockHubClient 會建立 HubConnection 的執行個體，並啟用 IClock.ShowTime 方法作為中樞 ShowTime 事件的處理常式。

private readonly ILogger<ClockHubClient> _logger;
private HubConnection _connection;

public ClockHubClient(ILogger<ClockHubClient> logger)
{
    _logger = logger;
    
    _connection = new HubConnectionBuilder()
        .WithUrl(Strings.HubUrl)
        .Build();

    _connection.On<DateTime>(Strings.Events.TimeSent, ShowTime);
}

public Task ShowTime(DateTime currentTime)
{
    _logger.LogInformation("{CurrentTime}", currentTime.ToShortTimeString());

    return Task.CompletedTask;
}

在 IHostedService.StartAsync 實作中，會以非同步方式啟動 HubConnection。

public async Task StartAsync(CancellationToken cancellationToken)
{
    // Loop is here to wait until the server is running
    while (true)
    {
        try
        {
            await _connection.StartAsync(cancellationToken);

            break;
        }
        catch
        {
            await Task.Delay(1000, cancellationToken);
        }
    }
}

在 IHostedService.StopAsync 方法期間，HubConnection 會以非同步方式處置。

public async Task StopAsync(CancellationToken cancellationToken)
{
    await _connection.DisposeAsync();
}

其他資源

• 開始使用
• Hubs
• 發佈至 Azure
• 強型別中樞