monksoul / sundial Goto Github PK

  services.AddSchedule(options =>
  {
      options.AddExecutor<JobExecutor>();
      options.AddMonitor<JobMonitor>();
      options.AddJob(JobBuilder.Create<MyJob>().SetIncludeAnnotations(true)); 
  });

  public class JobExecutor : IJobExecutor
  {
      private readonly ILogger<JobExecutor> _logger;
      public JobExecutor(ILogger<JobExecutor> logger)
      {
          _logger = logger;
      }

      public async Task ExecuteAsync(JobExecutingContext context, IJob jobHandler, CancellationToken stoppingToken)
      {
          // 实现失败重试策略
          await Retry.InvokeAsync(async () =>
          {
              await jobHandler.ExecuteAsync(context, stoppingToken);
          }, context.Trigger.NumRetries, context.Trigger.RetryTimeout
          // 每次重试输出日志 
          , retryAction: (total, times) =>
          {
              _logger.LogWarning($"Retrying {times}/{total} times for 触发器{context.Trigger.TriggerId} 第{context.Trigger.NumberOfRuns}次执行的Job【{context.JobId}】");
          });
      }
  }

    public class JobMonitor : IJobMonitor
    {
        private readonly ILogger<JobMonitor> _logger;
        private readonly ISchedulerFactory _schedulerFactory;
        public JobMonitor(ILogger<JobMonitor> logger, ISchedulerFactory schedulerFactory)
        {
            _logger = logger;
            _schedulerFactory = schedulerFactory;
        }

        public async Task OnExecutingAsync(JobExecutingContext context, CancellationToken stoppingToken)
        {
            _logger.LogInformation($"Job【{context.JobId}】第{context.Trigger.NumberOfRuns}次执行开始");
            await Task.CompletedTask;
        }

        public async Task OnExecutedAsync(JobExecutedContext context, CancellationToken stoppingToken)
        {
            if (context.Exception != null)
            {
                _logger.LogError(context.Exception,$"Job【{context.JobId}】for 触发器{context.Trigger.TriggerId} 第{context.Trigger.NumberOfRuns}次执行过程中出错啦，具体Job信息: {context.ConvertToJSON()},具体错误信息：{context.Exception}");
            }

            //context.Trigger.ElapsedTime不起作用?
            _logger.LogInformation($"Job【{context.JobId}】for 触发器{context.Trigger.TriggerId} 第{context.Trigger.NumberOfRuns}次执行结束,执行总耗时为{context.Trigger.ElapsedTime / 1000}秒");

            await Task.CompletedTask;
        }
    }

  [JobDetail("MyJob", Concurrent = false, Description = "这是一段MyJob描述", GroupName = "MyService")]
  [PeriodSeconds(3, NumRetries = 3, RetryTimeout = 1000, TriggerId = "MyJobTrigger")]
  public class MyJob : IJob
  {
      private readonly ILogger<MyJob> _logger;
      public MyJob(ILogger<MyJob> logger)
      {
          _logger = logger;
      }

      public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
      {
          // 模拟运行第三次出异常
          if (context.Trigger.NumberOfRuns == 3)
          {
              throw new Exception("假装出错");
          }

          await Task.CompletedTask;
      }
  }