美文网首页C#Asp.net开发.NET
Quartz.NET 作业调度(五):部署

Quartz.NET 作业调度(五):部署

作者: BeckJin | 来源:发表于2018-04-15 19:24 被阅读121次

    目前 Quartz.NET 最新版本已经 3.0.4 ,从 3.0 开始已经支持 .NET Core,所以在 .NET 版本 和 部署环境 上都有更多的选择。下面分别介绍基于.NET Framework 的 Windows 环境部署 和 基于.NET Core 的 Linux 环境部署。

    Windows

    在介绍 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
    
    安装

    服务启动后我们通过日志记录运行结果如下:


    执行结果

    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 在本地生成镜像。

    创建 Dockerfile:

    FROM microsoft/aspnetcore:2.0
    
    COPY bin/Release/PublishOutput  /app/
    
    WORKDIR /app
    
    ENTRYPOINT ["dotnet", "/app/App_NetCore.dll"]
    
    1. 通过 FROM 指定了需要的基础镜像 aspnetcore2.0 环境;
    2. 将发布好的代码 COPY 到镜像内的 /app/ 目录下( bin/Release/PublishOutput 是程序默认发布的地址);
    3. 指定 /app/ 为工作目录;
    4. 通过 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 作业调度(五):部署

      本文链接:https://www.haomeiwen.com/subject/axpaaxtx.html