sannlynnhtun-coding/DotNet8WebApi.HangfireApp

C# .NET 8 ASP.NET Core Web API using Hangfire

DotNet8WebApi.HangfireApp

Reference - https://docs.hangfire.io/en/latest/getting-started/aspnet-core-applications.html

Fire-and-Forget Jobs Fire-and-forget jobs are executed only once and almost immediately after creation.

var jobId = BackgroundJob.Enqueue(
    () => Console.WriteLine("Fire-and-forget!"));

Delayed Jobs Delayed jobs are executed only once too, but not immediately, after a certain time interval.

var jobId = BackgroundJob.Schedule(
    () => Console.WriteLine("Delayed!"),
    TimeSpan.FromDays(7));

Recurring Jobs Recurring jobs fire many times on the specified CRON schedule.

RecurringJob.AddOrUpdate(
    "myrecurringjob",
    () => Console.WriteLine("Recurring!"),
    Cron.Daily);

Example Code :

using DotNet8WebApi.HangfireApp.Services;
using Hangfire;
using Microsoft.EntityFrameworkCore;

var builder = WebApplication.CreateBuilder(args);

// Add services to the container.

builder.Services.AddControllers();
// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen();

builder.Services.AddHangfire(configuration => configuration
       .SetDataCompatibilityLevel(CompatibilityLevel.Version_180)
       .UseSimpleAssemblyNameTypeSerializer()
       .UseRecommendedSerializerSettings()
       .UseSqlServerStorage(builder.Configuration.GetConnectionString("DbConnection"))); // Add this line

builder.Services.AddHangfireServer(); // Add this line

builder.Services.AddDbContext<AppDbContext>(opt =>
{
    opt.UseSqlServer(builder.Configuration.GetConnectionString("DbConnection"));
});

var app = builder.Build();

var backgroundJobs = app.Services.GetRequiredService<IBackgroundJobClient>(); // Add this line
var jobId = backgroundJobs.Enqueue(() => Console.WriteLine("Hello from Hangfire!")); // Add this line

backgroundJobs.Schedule(
   () => Console.WriteLine("Delayed!"),
   TimeSpan.FromSeconds(5)); // Add this line

RecurringJob.AddOrUpdate(
    "myrecurringjob",
    () => Console.WriteLine("Recurring!"),
    Cron.Minutely); // Add this line

RecurringJob.RemoveIfExists("myrecurringjob"); // Add this line

backgroundJobs.ContinueJobWith(
    jobId,
    () => Console.WriteLine("Continuation!")); // Add this line


// Configure the HTTP request pipeline.
if (app.Environment.IsDevelopment())
{
    app.UseSwagger();
    app.UseSwaggerUI();
}
app.UseHangfireDashboard("/cron"); // Add this line

app.UseHttpsRedirection();

app.UseAuthorization();

app.MapControllers();

app.Run();