当前位置：首页 > java >正文

【C#】Quartz.NET怎么动态调用方法，并且根据指定时间周期执行，动态配置类何方法以及Cron表达式，有请DeepSeek

java 2025/7/13 14:40:56

🌹欢迎来到《小5讲堂》🌹
🌹这是《C#》系列文章，每篇文章将以博主理解的角度展开讲解。🌹
🌹温馨提示：博主能力有限，理解水平有限，若有不对之处望指正！🌹

在这里插入图片描述

前言

任务调度一直都有在用，但是自己确实没有从零开始搭建何尝试创建，
最近有伙伴咨询任务调度怎么使用，因此自己也尝试了一边搭建，好在现在有AI工具，简单问一句就能出来我想要的效果，一起来看看吧。

效果

设置每隔10秒执行一次
在这里插入图片描述

Quartz.NET插件

要在类库中启动Quartz.NET动态调度功能，你需要创建一个可被主程序调用的入口点。以下是完整的实现方案：

1. 创建调度服务类

在你的类库中创建一个调度服务类，封装所有调度逻辑：

using Quartz;
using Quartz.Impl;
using System;
using System.Collections.Specialized;
using System.Threading.Tasks;public class DynamicSchedulerService
{private IScheduler _scheduler;public async Task StartAsync(){// 1. 创建调度器var factory = new StdSchedulerFactory(GetSchedulerProperties());_scheduler = await factory.GetScheduler();// 2. 启动调度器await _scheduler.Start();}public async Task StopAsync(){if (_scheduler != null){await _scheduler.Shutdown();}}public async Task ScheduleMethodAsync(string methodName,string className,string cronExpression,string jobName = null,string groupName = "default"){if (_scheduler == null){throw new InvalidOperationException("调度器未启动，请先调用StartAsync()");}jobName ??= $"job_{methodName}_{Guid.NewGuid().ToString("N")}";// 创建作业var job = JobBuilder.Create<DynamicMethodJob>().WithIdentity(jobName, groupName).UsingJobData("MethodName", methodName).UsingJobData("ClassName", className).Build();// 创建触发器var trigger = TriggerBuilder.Create().WithIdentity($"trigger_{jobName}", groupName).WithCronSchedule(cronExpression).Build();// 安排作业await _scheduler.ScheduleJob(job, trigger);}private NameValueCollection GetSchedulerProperties(){// 可以在这里配置线程池、作业存储等设置return new NameValueCollection{// 示例配置，根据需求调整["quartz.threadPool.threadCount"] = "10",["quartz.scheduler.instanceName"] = "DynamicScheduler"};}
}

2. 实现动态方法作业

在类库中创建动态方法作业类：

using Quartz;
using System;
using System.Reflection;
using System.Threading.Tasks;public class DynamicMethodJob : IJob
{public Task Execute(IJobExecutionContext context){try{var dataMap = context.JobDetail.JobDataMap;var typeName = dataMap.GetString("ClassName");var methodName = dataMap.GetString("MethodName");if (string.IsNullOrEmpty(typeName) || string.IsNullOrEmpty(methodName)){throw new ArgumentException("ClassName和MethodName不能为空");}var type = Type.GetType(typeName);if (type == null){throw new TypeLoadException($"无法加载类型: {typeName}");}var method = type.GetMethod(methodName, BindingFlags.Public | BindingFlags.Static | BindingFlags.Instance);if (method == null){throw new MissingMethodException($"在类型{typeName}中找不到方法{methodName}");}object instance = null;if (!method.IsStatic){instance = Activator.CreateInstance(type);}// 调用方法method.Invoke(instance, null);return Task.CompletedTask;}catch (Exception ex){// 记录日志或处理异常Console.WriteLine($"作业执行失败: {ex}");throw new JobExecutionException(ex);}}
}

3. 在类库中暴露启动接口

创建一个公共接口供外部调用：

public interface IDynamicScheduler
{Task StartSchedulerAsync();Task StopSchedulerAsync();Task ScheduleMethodAsync(string methodName, string className, string cronExpression, string jobName = null, string groupName = "default");
}public class DynamicScheduler : IDynamicScheduler
{private readonly DynamicSchedulerService _schedulerService = new DynamicSchedulerService();public Task StartSchedulerAsync() => _schedulerService.StartAsync();public Task StopSchedulerAsync() => _schedulerService.StopAsync();public Task ScheduleMethodAsync(string methodName, string className, string cronExpression, string jobName = null, string groupName = "default"){return _schedulerService.ScheduleMethodAsync(methodName, className, cronExpression, jobName, groupName);}
}

4. 使用示例

在类库中定义要调用的方法

public class SampleTasks
{public static void SendDailyReport(){Console.WriteLine($"{DateTime.Now}: 正在发送每日报告...");// 实际发送报告的逻辑}public void ProcessData(){Console.WriteLine($"{DateTime.Now}: 正在处理数据...");// 实际处理数据的逻辑}
}

在主程序中调用类库

using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using TaskV2.Base;namespace TaskV2
{public class Program{static async Task Main(string[] args){// 创建调度器实例IDynamicScheduler scheduler = new DynamicScheduler();try{// 启动调度器await scheduler.StartSchedulerAsync();Console.WriteLine("调度器已启动");/*// 调度静态方法 - 每天上午9点执行await scheduler.ScheduleMethodAsync("SendDailyReport","YourNamespace.SampleTasks", // 完整类名(包括命名空间)"0 0 9 * * ?"); // 每天9点*//*// 调度实例方法 - 每30分钟执行一次await scheduler.ScheduleMethodAsync("ProcessData","YourNamespace.SampleTasks","0 0/30 * * * ?");*/// 查询表 - 执行List<JobModel> list = new List<JobModel>();list.Add(new JobModel(){methodName = "TestData",className = "TaskV2.Work.AccessTokenShop",cronExpression = "0/10 * * * * ?",});// 调度实例方法foreach (JobModel obj in list){await scheduler.ScheduleMethodAsync(obj.methodName,obj.className,obj.cronExpression);}Console.WriteLine("按任意键停止...");Console.ReadKey();}finally{// 停止调度器await scheduler.StopSchedulerAsync();Console.WriteLine("调度器已停止");}}}
}

5.目标任务类

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;namespace TaskV2.Work
{public class AccessTokenShop{public int Id = 1;public void TestData(){Console.WriteLine($"TestData{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");}}
}

6. 高级配置选项

如果你需要更复杂的配置，可以扩展DynamicSchedulerService：

// 在DynamicSchedulerService类中添加
public async Task ScheduleMethodWithParametersAsync(string methodName,string className,string cronExpression,object[] parameters,string jobName = null,string groupName = "default")
{jobName ??= $"job_{methodName}_{Guid.NewGuid().ToString("N")}";var job = JobBuilder.Create<DynamicMethodJob>().WithIdentity(jobName, groupName).UsingJobData("MethodName", methodName).UsingJobData("ClassName", className).UsingJobData("Parameters", parameters) // 传递参数.Build();var trigger = TriggerBuilder.Create().WithIdentity($"trigger_{jobName}", groupName).WithCronSchedule(cronExpression).Build();await _scheduler.ScheduleJob(job, trigger);
}

然后在DynamicMethodJob中处理参数：

// 修改DynamicMethodJob的Execute方法
var parameters = context.JobDetail.JobDataMap.Get("Parameters") as object[];
method.Invoke(instance, parameters);

注意事项

类型解析：确保Type.GetType()能找到你的类，可能需要使用程序集限定名称
依赖注入：如果需要使用DI容器创建实例，可以修改作业工厂
异常处理：确保作业中的异常被适当处理
生命周期：长时间运行的应用需要注意调度器的生命周期管理
日志记录：建议添加日志记录以便调试

这样实现后，你的类库就提供了一个完整的、可动态调度方法的Quartz.NET解决方案，可以在任何.NET应用程序中使用。