使用 Topshelf 组件一步一步创建 Windows 服务 (2) 使用Quartz.net 调度

 1         /// <summary>
 2         /// 程序标识
 3         /// </summary>
 4         [ConfigurationProperty("AppKey", IsRequired = true)]
 5         public string AppKey
 6         {
 7             get { return base["AppKey"].ToString(); }
 8             internal set { base["AppKey"] = value; }
 9         }
10 
11         /// <summary>
12         /// 程序集信息
13         /// </summary>
14         [ConfigurationProperty("TypeInfo", IsRequired = true)]
15         public string TypeInfo
16         {
17             get { return base["TypeInfo"].ToString(); }
18             internal set { base["TypeInfo"] = value; }
19         }

 1 <?xml version="1.0" encoding="utf-8" ?>
 2 <configuration>
 3   <!--该节点一定要放在最上边-->
 4   <configSections>
 5     <section name="AppConfigHelper" type="Quartz.WinService.AppConfigHelper,Quartz.WinService"/>
 6   </configSections>
 7 
 8   <!--TopSelf服务配置文件 -->
 9   <AppConfigHelper
10     ServiceName="ProcessPrintLogService"
11     Desc="日志打印服务"
12     AppKey="ProcessPrintLogService"
13     TypeInfo="ProcessService.ProcessPrintLogService,ProcessService"
14   />
15 
16   <startup>
17     <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2" />
18   </startup>
19 </configuration>

 1 namespace ProcessService
 2 {
 3     /// <summary>
 4     /// 日志打印服务
 5     /// </summary>
 6     public class ProcessPrintLogService
 7     {
 8         private Logger log = LogManager.GetCurrentClassLogger();
 9         /// <summary>
10         /// 服务入口
11         /// </summary>
12         public void DoWork()
13         {
14             //log.Info("******************排行榜服务开始执行******************");
15             try
16             {
17                 PrintLogMethod();
18             }
19             catch (Exception ex)
20             {
21                 log.Error(string.Format("排行榜服务异常，原因：{0}", ex));
22             }
23             finally
24             {
25                 //log.Info("******************排行榜服务结束执行******************");
26             }
27         }
28 
29 
30         private void PrintLogMethod()
31         {
32             log.Trace(string.Format("我是日志:{0}号", Thread.CurrentThread.ManagedThreadId));
33         }
34     }
35 }

# You can configure your scheduler in either <quartz> configuration section
# or in quartz properties file
# Configuration section has precedence

quartz.scheduler.instanceName = ServiceQuartzScheduler

# configure thread pool info
quartz.threadPool.type = Quartz.Simpl.SimpleThreadPool, Quartz
quartz.threadPool.threadCount = 10
quartz.threadPool.threadPriority = Normal

# job initialization plugin handles our xml reading, without it defaults are used
quartz.plugin.xml.type = Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz
quartz.plugin.xml.fileNames = ~/quartz_jobs.xml

# 3.0以上用以下配置
# quartz.plugin.xml.type = Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz.Plugins
# quartz.plugin.xml.fileNames = ~/quartz_jobs.xml

# export this server to remoting context
# quartz.scheduler.exporter.type = Quartz.Simpl.RemotingSchedulerExporter, Quartz
# quartz.scheduler.exporter.port = 555
# quartz.scheduler.exporter.bindName = QuartzScheduler
# quartz.scheduler.exporter.channelType = tcp
# quartz.scheduler.exporter.channelName = httpQuartz

<?xml version="1.0" encoding="UTF-8"?>

<job-scheduling-data xmlns="http://quartznet.sourceforge.net/JobSchedulingData" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.0">

  <processing-directives>
    <overwrite-existing-data>true</overwrite-existing-data>
  </processing-directives>
  <schedule>
    <!--调度配置-->
    <job>
      <name>ProcessPrintLogService</name>
      <group>ProcessPrintLogServiceGroup</group>
      <description>日志打印服务<https://img.qb5200.com/download-x/description>
      <job-type>Quartz.WinService.QuartzWork,Quartz.WinService</job-type>
      <durable>true<https://img.qb5200.com/download-x/durable>
      <recover>false</recover>
    </job>
    <trigger>
      <cron>
        <name>ProcessPrintLogServiceTrigger</name>
        <group>ProcessPrintLogServiceTriggerGroup</group>
        <job-name>ProcessPrintLogService</job-name>
        <job-group>ProcessPrintLogServiceGroup</job-group>
        <misfire-instruction>SmartPolicy</misfire-instruction>
        <cron-expression>0/3 * * * * ? </cron-expression>
      </cron>
    </trigger>
  </schedule>
</job-scheduling-data>

namespace Quartz.WinService
{
    public class QuartzWork : IJob
    {
        private Logger log = LogManager.GetCurrentClassLogger();
        //ConcurrentDictionary是线程安全的字典集
        private readonly ConcurrentDictionary<string, Lazy<Delegate>> _dynamicCache = new ConcurrentDictionary<string, Lazy<Delegate>>();

        //记录当前工作接口是否已经工作
        private static readonly Dictionary<string, bool> WorkingNow = new Dictionary<string, bool>();

        /// <summary>
        /// 任务调度执行入口
        /// 实现IJob的Execute方法,在Execute方法里编写要处理的业务逻辑，系统就会按照Quartz的配置，定时处理
        /// 当Job的trigger触发的时候, Execute(..) 方法就会在scheduler的工作线程中执行
        /// </summary>
        /// <param name="context"></param>
        public void Execute(IJobExecutionContext context)
        {
            try
            {
                Task.Factory.StartNew(() =>
                {
                    var service = AppConfigHelper.Initity();
                    WorkNow(service);
                });
            }
            catch (Exception ex)
            {
                log.Fatal($"执行Quartz调度异常，信息：{ex.Message}");
            }
            //return Task.FromResult(true);  //返回一个bool类型的Task, Quartz 3.0版本以上需要用到
        }

        private void WorkNow(AppConfigHelper service)
        {
            string key = service.AppKey;  //key值
            lock (this)
            {
                if (!WorkingNow.ContainsKey(key))
                {
                    WorkingNow.Add(key, false);
                }
                //如果执行则跳出
                if (WorkingNow[key])
                {
                    log.Trace($"服务key:{key} 正在运行,此次服务忽略");
                    return;
                }
                //并且设置为执行状态
                WorkingNow[key] = true;
            }
            try
            {
                var type = Type.GetType(service.TypeInfo);  //这里通过App.config文件设置
                if (type != null)
                {
                    //创建指定类型的实例,相当于通过反射new了一个对象实例
                    var provider = Activator.CreateInstance(type);
                    Dynamic(provider, "DoWork", key);
                }
                else
                {
                    log.Error($"任务:{key} 实例化失败");
                }
            }
            catch (Exception ex)
            {
                log.Fatal($"任务:{key} 实例化异常：{ex.Message}");
            }
            finally
            {
                WorkingNow[key] = false;
            }
        }

        //Delegate.CreateDelegate 官方定义:用来动态创建指定类型的委托，该委托可以对指定的类实例调用的指定的方法。
        //简单来说:就是可以调用指定类里边指定的方法,前提是,使用时需要实例化该类
        //GetOrAdd函数会根据指定key判断是否存在对应内容,存在则返回
        //DynamicInvoke 动态调用委托方法
        //obj参数就是指定类的实例化对象,methodName指定类中的方法名
        private void Dynamic(object obj, string methodName, string key)
        {
            var dmc = _dynamicCache.GetOrAdd(key, t => new Lazy<Delegate>(() => Delegate.CreateDelegate(typeof(Action), obj, methodName)));
            dmc.Value.DynamicInvoke();   //动态调用委托方法
        }

    }
}

namespace Quartz.WinService
{
    public class RegistService
    {
        /// <summary>
        /// 注册入口
        /// </summary>
        /// <param name="config">配置文件</param>
        /// <param name="isreg">是否注册</param>
        public static void Regist(AppConfigHelper config, bool isreg = false)
        {
            //这里也可以使用HostFactory.Run()代替HostFactory.New()
            var host = HostFactory.New(x =>
            {
                x.Service<QuartzHost>(s =>
                {
                    //通过 new QuartzHost() 构建一个服务实例 
                    s.ConstructUsing(name => new QuartzHost());
                    //当服务启动后执行什么
                    s.WhenStarted(tc => tc.Start());
                    //当服务停止后执行什么
                    s.WhenStopped(tc => tc.Stop());
                    //当服务暂停后执行什么
                    s.WhenPaused(w => w.Stop());
                    //当服务继续后执行什么
                    s.WhenContinued(w => w.Start());
                });

                if (!isreg) return; //false表示不注册

                //服务用本地系统账号来运行
                x.RunAsLocalSystem();

                //启用自动重启服务
                x.EnableServiceRecovery(v =>
                {
                    v.RestartService(2);  //2分钟后重启
                });

                //服务的描述信息
                x.SetDescription(config.Description);
                //服务的显示名称
                x.SetDisplayName(config.ServiceName);
                //服务的名称（最好不要包含空格或者有空格属性的字符）Windows 服务名称不能重复。
                x.SetServiceName(config.ServiceName);
            }).Run();   //启动服务  如果使用HostFactory.Run()则不需要该方法
        }
    }
}

namespace Quartz.WinService
{
    public class QuartzHost
    {
        private Logger log = LogManager.GetCurrentClassLogger();
        private readonly IScheduler scheduler;
        public QuartzHost()
        {
            //初始化调度服务
            //scheduler = StdSchedulerFactory.GetDefaultScheduler().Result;  //3.0以上写法
            scheduler = StdSchedulerFactory.GetDefaultScheduler();
        }

        /// <summary>
        /// 调度开始
        /// </summary>
        public void Start()
        {
            try
            {
                scheduler.Start();
                log.Info("Quartz调度服务开始工作");
            }
            catch (Exception ex)
            {
                log.Fatal(string.Format("Quartz调度服务开始异常！错误信息：{0}", ex));
                throw;
            }
        }

        /// <summary>
        /// 调度停止
        /// </summary>
        public void Stop()
        {
            try
            {
                if (scheduler != null)
                {
                    scheduler.Shutdown(true);
                }
                log.Info("Quartz调度服务结束工作");
            }
            catch (Exception ex)
            {
                log.Fatal(string.Format("Quartz调度服务停止异常！错误信息：{0}", ex));
                throw;
            }
        }
    }
}