Fast jede Anwendung braucht sie, Dienste die gewisse Hintergrundaufgaben durchführen. Diese Dienste müssen selbstständig, zyklisch und von der Hauptfunktionalität der Anwendung losgelöst arbeiten. Einen gängigen Lösungsansatz bieten Cron-Jobs, die aus UNIX oder unixoiden Betriebssystemen bekannt sind. Die Jobs werden zentral von einem Scheduler aufgerufen.
Quartz.NET ist ein bewährtes, quelloffenes und gut dokumentiertes Job-Scheduling Framework für .NET, das in verschiedensten Anwendungen eingesetzt werden kann.
Dieser Blogbeitrag zeigt dir, wie du Quartz.NET (kurz Quartz) in deine ASP.NET Core WebApi integrieren kannst. In einem Anwendungsbeispiel (Proof of Concept) erprobst du die Interaktion von Quartz mit einem relationalen Datenbanksystem (hier Postgres) sowie mit Microsofts Objekt-Datenbank-Mapper Entity Framework Core (kurz EF Core).
Vorteile
Durch die Verwendung von Quartz bieten sich dir die folgenden Vorteile:
- Quartz kann in deine bestehende Anwendungen integriert oder als eigenständiges Programm ausgeführt werden.
- Ein ausführbarer Job ist eine Klasse, die ein Job Interface von Quartz implementiert.
- Der Quartz Scheduler führt einen Job aus, wenn der zugehörige Trigger erfolgt.
- Ein Trigger unterstützt eine Vielzahl von Optionen und ist über eine Cron-Expression sekundengenau einstellbar.
- Über die Implementierung eines Listeners können Scheduling-Ergebnisse überwacht werden.
Quartz installieren
Das Shell-Skript dotnet_add_quartz.sh zeigt dir, wie du Quartz in deiner Projektumgebung installierst.
#!/bin/sh # File: dotnet_add_quartz.sh dotnet add package Quartz dotnet add package Quartz.Extensions.DependencyInjection dotnet add package Quartz.Extensions.Hosting
In der Datei Directory.Build.targets findest du alle notwendigen Pakete, die du für die hier gezeigte Anwendung installieren musst.
Quartz konfigurieren
Bevor die WebApi mit integriertem Quartz gestartet werden kann, müssen die Quartz Services konfiguriert werden. Du findest die Konfiguration in der Methode AddCronJobScheduling(), welche in der Datei Program.cs als Erweiterung von IServiceCollection aufgerufen wird.
// File: ServiceCollectionExtensions.cs (Auszug)
namespace CronJobScheduling.Extensions;
public static IServiceCollection AddCronJobScheduling(this IServiceCollection services)
{
services.AddQuartz(options =>
{
options.SchedulerId = "Scheduler.Core";
options.SchedulerName = "Quartz.AspNetCore.Scheduler";
options.UseMicrosoftDependencyInjectionJobFactory();
options.MaxBatchSize = 5;
options.InterruptJobsOnShutdown = true;
options.InterruptJobsOnShutdownWithWait = true;
});
services.AddQuartzHostedService(options =>
{
options.StartDelay = TimeSpan.FromMilliseconds(1_000);
options.AwaitApplicationStarted = true;
options.WaitForJobsToComplete = true;
});
return services;
}
Folgende Konfigurationen im Detail:
UseMicrosoftDependencyInjectionJobFactory(): Integriert die Instanziierung von Jobs unter Verwendung des Microsoft Dependency Injection Systems.MaxBatchSize: Die maximale Anzahl von Triggern, die ein Scheduler auf einmal erfassen (und starten) darf. Der Standardwert ist 1.
Die übrigen Einstellungen sind selbsterklärend und können in der Quartz Dokumentation nachgelesen werden.
Interface ICronJob erstellen
Die im Blog implementierten Jobs sollen als Cron-Job mittels Cron-Expression ausgeführt werden. Dafür wird das Interface ICronJob erstellt, welches das Quartz Standard-Interface IJob erweitert.
// File: ICronJob.cs
namespace CronJobScheduling.Abstractions;
public interface ICronJob : IJob
{
string Name { get; }
string Group { get; }
string CronExpression { get; }
string Description { get; }
}
Neben der CronExpression erfordert die Implementierung von ICronJob einen Name, eine Group und eine optionale Description. Sämtliche Properties werden später beim Scheduling des Cron-Jobs benötigt.
Beispiele für gültige Cron-Expressions findest du in der Klasse CronExpressionDefaults oder in der Quartz Dokumentation. Außerdem findest du auf der Homepage freeformater.com einen Cron Expression Generator und Explainer für Quartz.
Abstrakte Basis-Klasse CronJobBase erstellen
Um eine direkte Abhängigkeit der Cron-Jobs auf ICronJob und IJob bzw. auf Quartz selbst zu vermeiden, erstellst du die abstrakte Basis-Klasse CronJobBase.
// File: CronJobBase.cs
namespace CronJobScheduling.Abstractions;
public abstract class CronJobBase<T> : ICronJob
where T : class
{
public virtual string Name => typeof(T).FullName ?? nameof(T);
public virtual string Description => string.Empty;
public abstract string Group { get; }
public abstract string CronExpression { get; }
public async Task Execute(IJobExecutionContext context)
{
await InvokeAsync(context.CancellationToken);
}
protected abstract Task InvokeAsync(CancellationToken cancellationToken);
}
Die Basis-Klasse implementiert die von IJob geforderte Methode Execute(). Innerhalb von Execute() wird die Methode InvokeAsync() aufgerufen, welche von der ableitenden Kind-Klasse implementiert werden muss. In InvokeAsync() wird dann die eigentliche Funktionalität des Cron-Jobs eingebettet.
Im folgenden Abschnitt implementierst du Cron-Jobs als Kind-Klassen von CronJobBase.
Cron-Jobs implementieren
Für das Anwendungsbeispiel implementierst du im Folgenden zwei Cron-Jobs, welche über den DbContext von EF Core Datensätze in einer Datenbank erzeugen und löschen.
Der erste Cron-Job CreateNoteJob erstellt mit jedem Aufruf einen neuen Datensatz Note und speichert diesen in der Datenbank.
// File: CreateNoteJob.cs
namespace CronJobScheduling.Jobs.DataStore;
public class CreateNoteJob : CronJobBase<CreateNoteJob>
{
public override string Description => "Creates one note each time it is executed.";
public override string Group => CronGroupDefaults.User;
public override string CronExpression => CronExpressionDefaults.Every5ThSecondFrom0Through59;
private readonly INoteRepository _noteRepository;
public CreateNoteJob(INoteRepository noteRepository)
{
_noteRepository = noteRepository;
}
protected override async Task InvokeAsync(CancellationToken cancellationToken)
{
var note = Note.Create($"Created by '{Name}' at '{DateTime.UtcNow}'.");
await _noteRepository.AddNoteAsync(note, cancellationToken);
}
}
Der Cron-Job CreateNoteJob soll alle fünf Sekunden ausgeführt werden, siehe Every5ThSecondFrom0Through59.
Zum Erzeugen und Speichern eines Datensatzes Note verwendet CreateNoteJob eine Implementierung von INoteRepository, welche über die Standard Constructor-Injection zugänglich wird.
Die Implementierungen von NoteRepository und ApplicationDbContext werden in der Methode AddCronJobSchedulingDataStore() im Service Container des WebHosts registriert.
Der zweite Cron-Job DeleteNotesJob löscht mit jedem Aufruf alle Datensätze Note mit Ausnahme der beiden letzten Note Datensätze.
// File: DeleteNotesJob.cs
namespace CronJobScheduling.Jobs.DataStore;
public class DeleteNotesJob : CronJobBase<DeleteNotesJob>
{
public override string Description => "Deletes all notes except the two latest notes.";
public override string Group => CronGroupDefaults.User;
public override string CronExpression => CronExpressionDefaults.EveryMinuteAtSecond0;
private readonly INoteRepository _noteRepository;
public DeleteNotesJob(INoteRepository noteRepository)
{
_noteRepository = noteRepository;
}
protected override async Task InvokeAsync(CancellationToken cancellationToken)
{
var notes = await _noteRepository.GetNotesDescendingAsync(skip: 2, cancellationToken);
await _noteRepository.RemoveNotesAsync(notes, cancellationToken);
}
}
Der Cron-Job DeleteNotesJob soll zu jeder vollen Minute ausgeführt werden, siehe EveryMinuteAtSecond0.
Zwei weitere Cron-Job Implementierungen kannst du dir in den Klassen LoggingJob und SchedulerAliveJob anschauen.
Cron-Jobs im Service Container registrieren
Bevor die Cron-Jobs dem Scheduler hinzugefügt werden registrierst du diese im Service Container des WebHosts. Das erfolgt automatisch über die Methode AddCronJobs().
// File: ServiceCollectionExtensions.cs (Auszug)
namespace CronJobScheduling.Extensions;
public static IServiceCollection AddCronJobs(
this IServiceCollection services,
Assembly assembly)
{
var abstraction = typeof(ICronJob);
var baseType = typeof(CronJobBase<>);
var implementations = assembly.GetTypes()
.Where(t =>
(t.IsAssignableTo(abstraction)
|| t.BaseType == baseType)
&& t.IsClass
&& t.IsAbstract == false)
.ToList();
foreach (var implementation in implementations)
{
services.AddTransient(abstraction, implementation);
}
return services;
}
Die Methode registriert mittels Reflection alle Cron-Jobs des gegebenen Assembly.
Cron-Job Scheduling starten
Im letzten Schritt wird der Quartz Scheduler mit den implementierten Cron-Jobs bestückt und gestartet. Dies erfolgt automatisch über die Methode StartSchedulingAsync().
// File: CronJobSchedulingStarter.cs (Auszug)
public static async Task StartSchedulingAsync(
IApplicationBuilder builder,
CancellationToken cancellationToken = default)
{
//
// Create service scope to resolve injected application services.
//
using var scope = builder.ApplicationServices.CreateScope();
//
// Get cron jobs from service container.
//
var cronJobs = scope.ServiceProvider
.GetServices<ICronJob>()
.ToList();
if (cronJobs.Count < 1)
{
return;
}
EnsureValidCronJobs(cronJobs);
//
// Get Quartz scheduler factory from service container and build scheduler.
//
var scheduler = await scope.ServiceProvider
.GetRequiredService<ISchedulerFactory>()
.GetScheduler(cancellationToken);
//
// Create dictionary with jobs and their triggers for scheduler.
//
var jobsAndTriggers = new Dictionary<IJobDetail, IReadOnlyCollection<ITrigger>>();
foreach (var cronJob in cronJobs)
{
var jobDetail = JobBuilder.Create(cronJob.GetType())
.WithIdentity(cronJob.Name, cronJob.Group)
.WithDescription(cronJob.Description)
.Build();
var trigger = TriggerBuilder.Create()
.WithIdentity($"trigger.{cronJob.Name}", "standard")
.WithCronSchedule(cronJob.CronExpression)
.Build();
jobsAndTriggers.Add(jobDetail, new[] { trigger });
}
//
// Finish scheduling.
//
await DeleteExistingJobFromScheduler(scheduler, jobsAndTriggers.Keys, cancellationToken);
await scheduler.ScheduleJobs(jobsAndTriggers, replace: false, cancellationToken);
await scheduler.Start(cancellationToken);
}
Die Cron-Jobs und die Quartz Scheduler-Factory werden aus dem Service Container bezogen. Die Scheduler-Factory erstellt den Scheduler, der anschließend mit einem Dictionary aus Paaren von Jobs und Triggern bestückt wird. Die Trigger werden mit der zugehörigen CronExpressions konfiguriert. Zuletzt wird der Scheduler gestartet.
Nachdem der Quartz Scheduler gestartet wurde, kann auch die WebApi gestartet werden. Die letzten beiden Zeilen der Datei Program.cs starten Scheduler und WebApi.
// File: Program.cs (Auszug) app.RunCronJobScheduling(); app.Run();
Anwendungsbeispiel ausführen (Proof of Concept)
Sofern du Docker auf deinem Rechner installiert hast, kannst du den in der Anwendung verwendenten Postgres Datenbankserver innerhalb eines Docker Containers ausführen. Starte dafür einfach den Docker Engine und führe anschließend das Shell-Skript run_npgsql_server.sh aus.
Über den folgenden Connection String kannst du die Anwendungen dann mit der Datenbank verbinden:
Server=localhost; Port=4200; Username=root; Password=pasSworD; Database=cronjob_db;
Wenn du auf deinem Rechner einen Postgres Datenbankserver installiert hast, dann kannst du auch diesen verwenden. Stelle in diesem Fall eine entsprechende Konfiguration sicher.
Starte anschließend die WebApi, indem du das Shell-Skript run_webapi.sh ausführst. Wenn du für das Anwendungsbeispiel das Shell-Skript run_npgsql_server.sh verwendest, dann kannst du in deinem Browser den Datenbank Adminer über die folgende URL http://localhost:4300 öffnen.
Ein Blick in die Datenbank Tabelle Notes zeigt, dass alle fünf Sekunden ein neuer Datensatz Note erzeugt und gespeichert wird. Zu jeder vollen Minute werden dann alle Datensätze Note mit Ausnahme der beiden letzten Note Datensätze gelöscht. Weiterhin zeigt ein Blick ins Terminal der WebApi, dass alle vier Cron-Job Implementierungen ausgeführt werden.
Fazit
Dieser Blogbeitrag zeigt dir die vollständige Integration des Quartz.NET Frameworks in deine ASP.NET Core WebApi. Die Implementierung eines Cron-Jobs ist einfach möglich. Dafür hast du eine abstrakte Basis-Klasse erstellt. Die Konfiguration der Quartz Services, sowie das Starten des Schedulers ist vollständig automatisiert. Dazu hast du entsprechende Erweiterungsmethoden geschrieben.
In einem weiteren Schritt könntest du die Scheduling-Ergebnisse überwachen. Dafür bietet sich die Implementierung entsprechender Quartz Listener an. Ebenfalls könntest du die Ausführung der einzelnen Cron-Jobs in einer zugehörigen Datenbanktabelle persistieren. Hierfür könntest du die Cron-Job Basis-Klasse anpassen. Beide Erweiterungen würden die Qualität deines Job-Scheduling Systems nochmal deutlich verbessern.
Den Code zum Blog findest du auch auf GitHub.
Happy Coding!
