目前 Quartz.NET 最新版本已经 3.0.4 ,从 3.0 开始已经支持 .NET Core,所以在 .NET 版本 和 部署环境 上都有更多的选择。下面分别介绍基于.NET Framework 的 Windows 环境部署 和 基于.NET Core 的 Linux 环境部署。
在介绍 Windows 环境部署之前需要先阅读一下 Topshelf 秒建 Windows 服务 。通过 Topshelf 我们非常快速部署一个 Windows 服务。
定义 TestSchedule 如下,代码功能和之前的 Demo 没什么区别,只是将里 Start 和 Shutdown 定义在了方法中。
public class TestSchedule { readonly IScheduler scheduler = null; public TestSchedule() { // 创建作业调度器 scheduler = new StdSchedulerFactory().GetScheduler().Result; var jobDataMap = new JobDataMap(); jobDataMap.Add("times", "1"); // 创建一个作业 IJobDetail job = JobBuilder.Create<TestJob>() .WithIdentity("job1", "jobGroup1") .UsingJobData(jobDataMap) .Build(); // 创建一个触发器 ITrigger trigger = TriggerBuilder.Create() .WithIdentity("trigger1", "triggerGroup1") .StartNow() .WithSimpleSchedule(x => x .WithIntervalInSeconds(1) .WithRepeatCount(10)) .Build(); scheduler.ScheduleJob(job, trigger).Wait(); } public void Start() { scheduler.Start().Wait(); } public void Stop() { scheduler.Shutdown().Wait(); } }
Main 方法中添加如下设置:
static void Main(string[] args) { // 配置和运行宿主服务 HostFactory.Run(x => { // 指定服务类型。这里设置为 TestSchedule x.Service<TestSchedule>(s => { // 通过 new TestSchedule() 构建一个服务实例 s.ConstructUsing(name => new TestSchedule()); // 当服务启动后执行什么 s.WhenStarted(tc => tc.Start()); // 当服务停止后执行什么 s.WhenStopped(tc => tc.Stop()); }); // 服务用本地系统账号来运行 x.RunAsLocalSystem(); // 服务描述信息 x.SetDescription("TestSchedule"); // 服务显示名称 x.SetDisplayName("TestScheduleService"); // 服务名称 x.SetServiceName("TestScheduleService"); }); }
开发环境下直接通过 F5 运行调试。如果希望部署成服务,只需要在 bin 目录下执行:
xxx.exe install
服务启动后我们通过日志记录运行结果如下:
测试代码基于.Net Core 2.0 ,最终通过 Docker 来部署到 Linux 上。和 Windows 方式类似,创建一个控制台应用程序,Program.cs 主要代码如下:
class Program { private static readonly ManualResetEvent manualResetEvent = new ManualResetEvent(false); private static TestSchedule testSchedule; static void Main(string[] args) { testSchedule = new TestSchedule(); // 开启新线程执行 Schedule Task.Run(Start); Console.CancelKeyPress += (sender, e) => { Task.Run(StopSilo); }; AppDomain.CurrentDomain.ProcessExit += (s, e) => { Task.Run(StopSilo); }; // 进入阻塞状态,开始等待唤醒信号。(防止程序直接退出) manualResetEvent.WaitOne(); } private static async Task Start() { await testSchedule.Start(); Console.WriteLine("started"); } private static async Task StopSilo() { await testSchedule.Stop(); Console.WriteLine("stopped"); // 取消阻塞状态,发出唤醒信号 manualResetEvent.Set(); } }
这里需要注意 ManualResetEvent 的使用,它主要用于多线程协同和进程操作,这里可以理解为 Quartz 的执行提供守护进程。
如果是Windows用户,可以把程序 Build 后打包到 Linux 上生成镜像,也可以通过 Docker for Windows 在本地生成镜像。
创建 Dockerfile:
FROM microsoft/aspnetcore:2.0 COPY bin/Release/PublishOutput /app/ WORKDIR /app ENTRYPOINT ["dotnet", "/app/App_NetCore.dll"]
接下来分别执行以下几条命令:
// docker build 默认会根据当前目录下的 Dockerfile 文件生成镜像,这里指定镜像名为 beckjin/test-quartznet-local docker build -t beckjin/test-quartznet-local . // 通过 docker tag 给 beckjin/test-quartznet-local 最新 build 的版本打上一个标签 beckjin/test-quartznet:0.0.1(可以理解为版本) docker tag beckjin/test-quartznet-local:latest beckjin/test-quartznet:0.0.1 // 登录 docker hub 账号 docker login -u xxx -p xxx // 将镜像推到 docker hub 上 docker push beckjin/test-quartznet:0.0.1 // 执行 beckjin/test-quartznet:0.0.1 镜像 docker run beckjin/test-quartznet:0.0.1
因为这个例子比较简单,这里直接使用 docker run 来执行。结果如下: