热门搜索:
您现在的位置是：首页 > 文章详情

这个 .NET 分布式定时任务有点强，Sundial v2.5.0 发布

日期：2022-12-06点击：386

痛并快乐

自上一次 Sundial 发布已过 12 天，借助 Furion 框架的人气，Sundial 在 Nuget 平台下载量达到了 1900+ 次，随着越来越多的开发者使用，也暴露出了之前架构设计一些不灵活的问题，收集到了不少建议和问题反馈。

这一次不再是独自一人，为了尽快优化架构和功能改进，拉了4个小伙伴一起对所有代码、注释、文档进行了完整性审查工作，历尽5天的时间，终于解决了现有的所有问题还添加了不少新特性。

这十多天被各种问题搞得焦头烂额，但痛并快乐着~

项目概况

亮点展现

此版本在解决不少问题的同时，也增加了不少亮点。

1. 简化作业执行上下文默认字符串输出行为

 public class MyJob : IJob { private readonly ILogger<MyJob> _logger; public MyJob(ILogger<MyJob> logger) { _logger = logger; } public Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken) { _logger.LogInformation($"{context}"); return Task.CompletedTask; } }
 services.AddSchedule(options => { // 注册作业，并配置作业触发器 options.AddJob<MyJob>(Triggers.Secondly()); // 表示每秒执行 });
 info: 2022-12-02 16:51:33.5032989 +08:00 星期五 L System.Logging.ScheduleService[0] #1 Schedule hosted service is running. info: 2022-12-02 16:51:33.5180669 +08:00 星期五 L System.Logging.ScheduleService[0] #1 Schedule hosted service is preloading... info: 2022-12-02 16:51:34.1452041 +08:00 星期五 L System.Logging.ScheduleService[0] #1 The <job1_trigger1> trigger for scheduler of <job1> successfully appended to the schedule. info: 2022-12-02 16:51:34.1541701 +08:00 星期五 L System.Logging.ScheduleService[0] #1 The scheduler of <job1> successfully appended to the schedule. warn: 2022-12-02 16:51:34.1748401 +08:00 星期五 L System.Logging.ScheduleService[0] #1 Schedule hosted service preload completed, and a total of <1> schedulers are appended. info: 2022-12-02 16:51:35.0712571 +08:00 星期五 L MyJob[0] #4 <job1> [C] <job1 job1_trigger1> * * * * * * 1ts 2022-12-02 16:51:35.000 -> 2022-12-02 16:51:36.000 info: 2022-12-02 16:51:36.0317375 +08:00 星期五 L MyJob[0] #14 <job1> [C] <job1 job1_trigger1> * * * * * * 2ts 2022-12-02 16:51:36.000 -> 2022-12-02 16:51:37.000 info: 2022-12-02 16:51:37.0125007 +08:00 星期五 L MyJob[0] #9 <job1> [C] <job1 job1_trigger1> * * * * * * 3ts 2022-12-02 16:51:37.000 -> 2022-12-02 16:51:38.000 info: 2022-12-02 16:51:38.0179920 +08:00 星期五 L MyJob[0] #8 <job1> [C] <job1 job1_trigger1> * * * * * * 4ts 2022-12-02 16:51:38.000 -> 2022-12-02 16:51:39.000

JobExecutionContext 重写了 ToString() 方法并提供以下几种格式：

 # 持续运行格式 <作业Id> 作业描述 [并行C/串行S] <作业Id 触发器Id> 触发器字符串 触发器描述 触发次数ts 触发时间 -> 下一次触发时间 # 触发停止格式 <作业Id> 作业描述 [并行C/串行S] <作业Id 触发器Id> 触发器字符串 触发器描述 触发次数ts 触发时间 [触发器终止状态]

2. 添加动态委托作业功能

 service.AddSchedule(options => { options.AddJob((serviceProvider, context, stoppingToken) => { serviceProvider.GetLogger().LogInformation($"{context}"); return Task.CompletedTask; }, Triggers.PeriodSeconds(5)); });

3. 支持动态编译作业处理程序代码

 // 初始化 NatashaInitializer.Preheating(); // 创建程序集（可自定义编写程序集名称） var oop = new AssemblyCSharpBuilder("JobAssembly") { Domain = DomainManagement.Random() }; // 添加代码 oop.Add(@" using Furion.Schedule; using Microsoft.Extensions.Logging; using System; using System.Threading; using System.Threading.Tasks; namespace YourProject; public class MyJob : IJob { private readonly ILogger<MyJob> _logger; public MyJob(ILogger<MyJob> logger) { _logger = logger; } public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken) { _logger.LogInformation($""我是 Roslyn 方式创建的：{context}""); await Task.CompletedTask; } } "); // 生成运行时 MyJob 类型 var jobType = oop.GetTypeFromShortName("MyJob");

4. 提供更多内置作业触发器方法和特性

 // 间隔 Period 方式 // 创建毫秒周期（间隔）作业触发器构建器 var triggerBuilder = Triggers.Period(5000); // 创建秒周期（间隔）作业触发器构建器 var triggerBuilder = Triggers.PeriodSeconds(5); // 创建分钟周期（间隔）作业触发器构建器 var triggerBuilder = Triggers.PeriodMinutes(5); // 创建小时周期（间隔）作业触发器构建器 var triggerBuilder = Triggers.PeriodHours(5); // Cron 表达式方式 // 创建 Cron 表达式作业触发器构建器 var triggerBuilder = Triggers.Cron("* * * * *", CronStringFormat.Default); // 创建每秒开始作业触发器构建器 var triggerBuilder = Triggers.Secondly(); // 创建每分钟开始作业触发器构建器 var triggerBuilder = Triggers.Minutely(); // 创建每小时开始作业触发器构建器 var triggerBuilder = Triggers.Hourly(); // 创建每天（午夜）开始作业触发器构建器 var triggerBuilder = Triggers.Daily(); // 创建每月1号（午夜）开始作业触发器构建器 var triggerBuilder = Triggers.Monthly(); // 创建每周日（午夜）开始作业触发器构建器 var triggerBuilder = Triggers.Weekly(); // 创建每年1月1号（午夜）开始作业触发器构建器 var triggerBuilder = Triggers.Yearly(); // 创建每周一至周五（午夜）开始作业触发器构建器 var triggerBuilder = Triggers.Workday(); // Cron 表达式 Macro At 方式 // 每第 3 秒 var triggerBuilder = Triggers.SecondlyAt(3); // 每第 3，5，6 秒 var triggerBuilder = Triggers.SecondlyAt(3, 5, 6); // 每分钟第 3 秒 var triggerBuilder = Triggers.MinutelyAt(3); // 每分钟第 3，5，6 秒 var triggerBuilder = Triggers.MinutelyAt(3, 5, 6); // 每小时第 3 分钟 var triggerBuilder = Triggers.HourlyAt(3); // 每小时第 3，5，6 分钟 var triggerBuilder = Triggers.HourlyAt(3, 5, 6); // 每天第 3 小时正（点） var triggerBuilder = Triggers.DailyAt(3); // 每天第 3，5，6 小时正（点） var triggerBuilder = Triggers.DailyAt(3, 5, 6); // 每月第 3 天零点正 var triggerBuilder = Triggers.MonthlyAt(3); // 每月第 3，5，6 天零点正 var triggerBuilder = Triggers.MonthlyAt(3, 5, 6); // 每周星期 3 零点正 var triggerBuilder = Triggers.WeeklyAt(3); var triggerBuilder = Triggers.WeeklyAt("WED"); // SUN（星期天），MON，TUE，WED，THU，FRI，SAT // 每周星期 3，5，6 零点正 var triggerBuilder = Triggers.WeeklyAt(3, 5, 6); var triggerBuilder = Triggers.WeeklyAt("WED", "FRI", "SAT"); // 还支持混合 var triggerBuilder = Triggers.WeeklyAt(3, "FRI", 6); // 每年第 3 月 1 日零点正 var triggerBuilder = Triggers.YearlyAt(3); var triggerBuilder = Triggers.YearlyAt("MAR"); // JAN（一月），FEB，MAR，APR，MAY，JUN，JUL，AUG，SEP，OCT，NOV，DEC // 每年第 3，5，6 月 1 日零点正 var triggerBuilder = Triggers.YearlyAt(3); var triggerBuilder = Triggers.YearlyAt(3, 5, 6); var triggerBuilder = Triggers.YearlyAt("MAR", "MAY", "JUN"); // 还支持混合 var triggerBuilder = Triggers.YearlyAt(3, "MAY", 6);

5. 改进作业持久化设计

 public class DbJobPersistence : IJobPersistence { public IEnumerable<SchedulerBuilder> Preload() { // 作业调度服务启动时运行时初始化，可通过数据库加载，或者其他方式 return Array.Empty<SchedulerBuilder>(); } public SchedulerBuilder OnLoading(SchedulerBuilder builder) { // 如果是更新操作，则 return builder.Updated(); 将生成 UPDATE 语句 // 如果是新增操作，则 return builder.Appended(); 将生成 INSERT 语句 // 如果是删除操作，则 return builder.Removed(); 将生成 DELETE 语句 // 如果无需标记操作，返回 builder 默认值即可 return builder; } public void OnChanged(PersistenceContext context) { var sql = context.ConvertToSQL("job_detail"); // 这里执行 sql 即可 💖 } public void OnTriggerChanged(PersistenceTriggerContext context) { var sql = context.ConvertToSQL("job_trigger"); // 这里执行 sql 即可 💖 } }

还有更多更多功能改进可查阅文档：https://furion.baiqian.ltd/docs/job

本期更新 

  • 新特性

    • [新增] 定时任务间隔分钟作业触发器 Triggers.PeriodMinutes(5) 和 [PeriodMinutes(5)] 特性 4.8.2.8 ⏱️2022.12.01 8e1f06f
    • [新增] 定时任务工作日作业触发器 Triggers.Workday() 和 [Workday] 特性 4.8.2.6 ⏱️2022.11.30 28b2d20
    • [新增] 定时任务作业校对功能，可对误差进行校正 4.8.2.6 ⏱️2022.11.30 f725a25
    • [新增] 定时任务 Triggers 所有带 At 的 Cron 表达式触发器构建器及特性 4.8.2.5 ⏱️2022.11.29 #I63PLR
    • [新增] 定时任务批量添加 SchedulerBuilder 作业功能 4.8.2.4 ⏱️2022.11.29 5faa67b
    • [新增] 定时任务 BuildSqlType 配置，可设置生成不同数据库类型的 SQL 语句 4.8.2.3 ⏱️2022.11.29 293f9bc !675
    • [新增] JobDetail 和 Trigger 自定义 ConvertToSQL 输出 SQL 配置 4.8.2 ⏱️2022.11.27 0bb9d8f
    • [新增] 作业触发器 ResetOnlyOnce 属性，支持只运行一次的作业重新启动服务重复执行 4.8.1.5 ⏱️2022.11.25 a8be728
    • [新增] 动态作业处理程序委托支持 4.8.1.8 ⏱️2022.11.27 e02266c

  • 突破性变化

    • [调整] 定时任务底层所有代码，日志，注释，文档 4.8.1.10 ⏱️2022.12.05

  • 问题修复

    • [修复] 作业触发器不符合下一次执行规律但 NextRunTime 不为 null 情况 4.8.1.5 ⏱️2022.11.25 a8be728
    • [修复] 运行时启动/暂停作业无效问题 4.8.1.6 ⏱️2022.11.25 #I6368M
    • [修复] 定时任务生成的 SQL 语句不支持 MySQL 问题 4.8.1.7 ⏱️2022.11.26 #I638ZC

  • 其他更改

    • [调整] 定时任务调度器时间精度，控制持续执行一年误差在 100ms 以内 4.8.2.9 ⏱️2022.12.01 334d089
    • [调整] 定时任务作业计划工厂 GetNextRunJobs() 方法逻辑 4.8.2.7 ⏱️2022.11.30 #I63VS2

  • 文档

    • [新增] 作业触发器 ResetOnlyOnce 文档 4.8.1.5 ⏱️2022.11.25 a8be728
    • [新增] 通过 Roslyn 动态编译代码创建 IJob 类型文档 4.8.1.5 ⏱️2022.11.25 2c5e5be
    • [新增] 自定义 JobDetail 和 Trigger 输出 SQL 文档 4.8.2 ⏱️2022.11.27 0bb9d8f
原文链接：https://www.oschina.net/news/220745/sundial-2-5-0-released
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有，本站原创内容转载请注明来源。

相关文章

    文章评论

    共有0条评论来说两句吧...

    文章二维码

    扫描即可查看该文章

    点击排行

    推荐阅读

    最新文章