目前 Quartz.NET 最新版本已经 3.0.4 , 从 3.0 开始已经支持 .NET Core, 所以在 .NET 版本 和 部署环境 上都有更多的选择. 下面分别介绍基于. NET Framework 的 Windows 环境部署 和 基于. NET Core 的 Linux 环境部署.
Windows
在介绍 Windows 环境部署之前需要先阅读一下 Topshelf 秒建 Windows 服务 http://beckjin.com/2018/04/08/topshelf/ . 通过 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
服务启动后我们通过日志记录运行结果如下:
Linux
测试代码基于. 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 https://www.docker.com/docker-windows 在本地生成镜像.
创建 Dockerfile:
- FROM microsoft/aspnetcore:2.0
- COPY bin/Release/PublishOutput /app/
- WORKDIR /app
- ENTRYPOINT ["dotnet", "/app/App_NetCore.dll"]
通过 FROM 指定了需要的运行环境;
将发布好的代码 COPY 到镜像内的 /app/ 目录下 ( bin/Release/PublishOutput 是程序默认发布的地址);
指定 /app/ 为工作目录;
通过 ENTRYPOINT 指定程序启动运行的命令.
接下来分别执行以下几条命令:
- // 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 来执行. 结果如下:
参考链接:
Quartz.NET Documentation https://www.quartz-scheduler.net/
Topshelf 秒建 Windows 服务 http://beckjin.com/2018/04/08/topshelf/
案例 Demo-QuartzNetDeploy https://github.com/beckjin/QuartzNetSamples/tree/master/QuartzNetDeploy
来源: https://juejin.im/entry/5ad33a5a6fb9a028cf32ebe3