Longbow.Tasks 实战——任务持久化 - qidao123.com技术社区-IT企服评测·应用市场

复制代码

复制代码

1 //立即执行，仅执行一次
2 TaskServicesManager.GetOrAdd<TasksDemo>("任务唯一标识");
3
4 //周期性任务 (1 分钟后间隔 5 秒执行2次任务)
5 var trigger = TriggerBuilder.Default.WithInterval(TimeSpan.FromSeconds(5)).WithRepeatCount(2).WithStartTime(DateTimeOffset.Now.AddMinutes(1)).Build();
6
7 TaskServicesManager.GetOrAdd<TasksDemo>("任务唯一标识", trigger);
8
9 //支持cron表达式，间隔 5 秒循环执行任务
10 TaskServicesManager.GetOrAdd<TasksDemo>("任务唯一标识", TriggerBuilder.Build("*/5 * * * * *"));
11
12 //这里重点关注，可以让你的任务接收 serviceProvider 参数，这样就可以使用注入的服务了
13 TaskServicesManager.GetOrAdd("任务唯一标识", async (serviceProvider, token) =>
14 {
15 System.Console.WriteLine("任务唯一标识");
16 await Task.Delay(1000);
17 }, TriggerBuilder.Build("*/5 12 * * * *"));

复制代码

复制代码

1 public class TestHostedService : IHostedService
2 {
3 private readonly IServiceProvider _serviceProvider;
4
5 public TestHostedService(IServiceProvider serviceProvider)
6 {
7 _serviceProvider = serviceProvider;
8 }
9
10 /// <summary>
11 /// 假设这里是从数据库中读取的定时任务
12 /// </summary>
13 public Dictionary<string, string> Servers = new Dictionary<string, string>()
14 {
15 //key为服务名称，value为cron表达式
16 ["Task1"] = "*/5 12 * * * *",
17 ["Task2"] = "*/10 12 * * * *",
18 ["Task3"] = "*/15 12 * * * *",
19 };
20
21 public async Task StartAsync(CancellationToken cancellationToken)
22 {
23 await using var scope = _serviceProvider.CreateAsyncScope();
24 foreach (var server in Servers)
25 {
26 // 根据服务名称获取服务
27 var testServices = scope.ServiceProvider.GetKeyedServices<ITestService>(server.Key);
28 if (testServices.Any())
29 {
30 ///正常来说一个任务对应一个服务，这里只取第一个
31 var testService = testServices.First();
32 // 添加定时任务
33 TaskServicesManager.GetOrAdd(server.Key, async (serviceProvider, token) =>
34 {
35 await testService.Run(serviceProvider);
36 }, TriggerBuilder.Build(server.Value));
37 }
38 }
39 }
40
41 public Task StopAsync(CancellationToken cancellationToken)
42 {
43 Console.WriteLine("StopAsync");
44
45 return Task.CompletedTask;
46 }
47 }

复制代码