zoukankan      html  css  js  c++  java
  • [Solution] Microsoft Windows 服务(3) 使用Quartz.net定时任务

      Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,Quartz.net 就是Quartz的移植版本。Quartz可以用来创建简单或为运行十个,百个,甚至是好几万个Jobs这样复杂的程序。

      官网教程:http://www.quartz-scheduler.net/documentation/index.html

      

      优点:

        1.全,启动时间,间隔,次数,结束时间都可以指定。

        2.方便。不需要考虑各种线程问题了。

    下载:

      Install-Package Quartz

      

      

    开发:

      1.job  2.trigger  3.scheduler

    job:一个任务项,定义要执行的事情

      实现IJob接口.只有一个方法。

      

    class SampleJob : IJob
        {
            public void Execute(IJobExecutionContext context)
            {
                File.AppendAllText("d:\1.txt", "good");
            }
        }

    trigger:触发器,定义何时执行多少次

      构造函数:public SimpleTriggerImpl(string name, string group, DateTimeOffset startTimeUtc, DateTimeOffset? endTimeUtc, int repeatCount, TimeSpan repeatInterval);

      

      通过上面的ctor可以new一个调用触发器

    scheduler:调度器,安排触发器和任务结合

      

    var factory = new StdSchedulerFactory();
    var sched = factory.GetScheduler();

    执行:

      a.把IJob包装成IJobDetail,通过public JobDetailImpl(string name, Type jobType);

      b.调用IScheduler接口的调度方法:DateTimeOffset ScheduleJob(IJobDetail jobDetail, ITrigger trigger);

      c.调用IScheduler接口开始方法:    void Start();或者void StartDelayed(TimeSpan delay);

      

    停止:

      调用IScheduler接口开始方法:    void Shutdown();

    代码下载:点击下载

    简单结合Quartz和TopShelf一起创建服务:

     1 class Program
     2     {
     3         static void Main(string[] args)
     4         {
     5             HostFactory.Run(x =>
     6             {
     7                 //要配置的服务
     8                 x.Service<RuntimeService>(c =>
     9                 {
    10                     c.ConstructUsing(name => new RuntimeService());
    11                     c.WhenStarted(s => s.Begin());
    12                     c.WhenStopped(s => s.Stop());
    13                 });
    14                 //服务的运行身份
    15                 x.RunAsLocalSystem();
    16 
    17                 x.SetDescription("服务描述");
    18                 x.SetDisplayName("显示名称");
    19                 x.SetServiceName("服务名称");
    20             });
    21         }
    22     }
    23 
    24     class RealJob : IJob
    25     {
    26         public void Execute(IJobExecutionContext context)
    27         {
    28             Console.WriteLine(DateTime.Now.ToLongTimeString());
    29         }
    30     }
    31 
    32     class RuntimeService
    33     {
    34         private IScheduler sched;
    35         public RuntimeService()
    36         {
    37             var factory = new StdSchedulerFactory();
    38             sched = factory.GetScheduler();
    39         }
    40         public void Begin()
    41         {
    42             sched.ScheduleJob(new JobDetailImpl("job", typeof(RealJob)),
    43                 new SimpleTriggerImpl("trig", "group", -1, new TimeSpan(0, 0, 1)));
    44             sched.Start();
    45         }
    46 
    47         public void Stop()
    48         {
    49             sched.Shutdown();
    50         }
    51     }
  • 相关阅读:
    Networking with standalone containers
    记filebeat内存泄漏问题分析及调优
    原创-The Salt Master has rejected this minion's public key!解决方法
    原创-某次建表失败-ERROR 1101 (42000): BLOB/TEXT column can’t have a default value
    action命令-判断判断码是否正确
    docker-docker中用户uid异常导致权限不足
    非原创-docker 6种减小镜像大小的方式
    非原创-docker update
    原创-k8s 存活探针,就绪探针与启动探针
    原创-阿里elasticsearch数据迁移
  • 原文地址:https://www.cnblogs.com/neverc/p/4616544.html
Copyright © 2011-2022 走看看