怎么使用SignalR進(jìn)行任務(wù)調(diào)度

SignalR 是一個實時通信庫，通常用于在 Web 應(yīng)用程序中實現(xiàn)實時通信功能。雖然 SignalR 本身并不是用于任務(wù)調(diào)度的工具，但是可以借助 SignalR 實現(xiàn)簡單的任務(wù)調(diào)度功能。下面是一個基本的示例來演示如何使用 SignalR 進(jìn)行任務(wù)調(diào)度：

1. 在你的項目中安裝 SignalR 包：

dotnet add package Microsoft.AspNetCore.SignalR

2. 創(chuàng)建一個繼承自 Hub 的 SignalR Hub 類，用于處理客戶端與服務(wù)端之間的通信：

using Microsoft.AspNetCore.SignalR;

public class TaskSchedulerHub : Hub
{
    public async Task ScheduleTask(string taskName, int delay)
    {
        await Task.Delay(delay);
        await Clients.All.SendAsync("TaskCompleted", taskName);
    }
}

3. 在 Startup.cs 中配置 SignalR 服務(wù)，并添加路由映射：

public void ConfigureServices(IServiceCollection services)
{
    services.AddSignalR();
}

public void Configure(IApplicationBuilder app, IHostingEnvironment env)
{
    app.UseSignalR(routes =>
    {
        routes.MapHub<TaskSchedulerHub>("/taskScheduler");
    });
}

4. 在客戶端代碼中連接到 SignalR Hub，并調(diào)度任務(wù)：

const connection = new signalR.HubConnectionBuilder()
    .withUrl("/taskScheduler")
    .build();

connection.on("TaskCompleted", taskName => {
    console.log(`Task ${taskName} completed`);
});

connection.start()
    .then(() => {
        connection.invoke("ScheduleTask", "Task1", 5000);
        connection.invoke("ScheduleTask", "Task2", 10000);
    })
    .catch(err => console.error(err));

通過以上步驟，你就可以使用 SignalR 實現(xiàn)簡單的任務(wù)調(diào)度功能了。當(dāng)客戶端調(diào)用 ScheduleTask 方法時，服務(wù)端會延遲一定時間后發(fā)送任務(wù)完成通知給所有客戶端。你也可以根據(jù)實際需求擴(kuò)展和優(yōu)化這個示例。