.Net Core控制台应用程序使用定时器

缺乏、安全感 2023-10-17 18:12 49阅读 0赞

引用两个库：

McApp.QuartzCore

Pomelo.AspNetCore.TimedJob

using Newtonsoft.Json;
    using Quartz;
    using Quartz.Impl;
    using System;
    using System.Collections.Specialized;
    using System.Threading.Tasks;
    
    namespace TestDockerConsole
    {
        public class HelloJob:IJob{
            public Task Execute(IJobExecutionContext context) {
               return Console.Out.WriteLineAsync("Greetings from HelloJob!");
            }
        }
    class Program
        {
            static void Main(string[] args)
            {
                Console.WriteLine("Time Job Start");
                RunProgram().GetAwaiter().GetResult();
                Console.WriteLine("Hello World!");
                Console.Read();
            }
    
            private static async Task RunProgram()
            {
                try
                {
                    // Grab the Scheduler instance from the Factory  
                    NameValueCollection props = new NameValueCollection
                    {
                        { "quartz.serializer.type", "binary" }
                    };
                    StdSchedulerFactory factory = new StdSchedulerFactory(props);
                    IScheduler scheduler = await factory.GetScheduler();
    
    
                    // 启动任务调度器  
                    await scheduler.Start();
    
    
                    // 定义一个 Job  
                    IJobDetail job = JobBuilder.Create<HelloJob>()
                        .WithIdentity("job1", "group1")
                        .Build();
                    ISimpleTrigger trigger = (ISimpleTrigger)TriggerBuilder.Create()
                        .WithIdentity("trigger1") // 给任务一个名字  
                        .StartAt(DateTime.Now) // 设置任务开始时间  
                        .ForJob("job1", "group1") //给任务指定一个分组  
                        .WithSimpleSchedule(x => x
                        .WithIntervalInSeconds(1)  //循环的时间 1秒1次 
                        .RepeatForever())
                        .Build();
    
    
                    // 等待执行任务  
                    await scheduler.ScheduleJob(job, trigger);
    
    
                    // some sleep to show what's happening  
                    //await Task.Delay(TimeSpan.FromMilliseconds(2000));  
                }
                catch (SchedulerException se)
                {
                    await Console.Error.WriteLineAsync(se.ToString());
                }
            }
        }
    }

运行结果：

![SouthEast][]

[SouthEast]: https://img-blog.csdn.net/20180207093053328?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvenp6aWxp/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast