‫مدیریت ایونت‌ها در MediatR

مقدمه

مفهوم ایونت‌ها در MediatR

ویژگی‌های ایونت در MediatR:

1. Broadcasting: هر ایونت می‌تواند چندین هندلر داشته باشد.
2. عدم ترتیب پیش‌فرض: هندلرها به ترتیب خاصی اجرا نمی‌شوند، مگر اینکه ترتیب آن‌ها را مشخص کنید.
3. غیرهمزمانی: ایونت‌ها می‌توانند به صورت همزمان و غیرهمزمان هندل شوند.

مراحل استفاده از ایونت‌ها در MediatR

۱. نصب وابستگی‌های موردنیاز

dotnet add package MediatR
dotnet add package MediatR.Extensions.Microsoft.DependencyInjection

۲. تعریف ایونت

using MediatR;

public class OrderCreatedEvent : INotification
{
    public int OrderId { get; set; }
    public DateTime CreatedAt { get; set; }

    public OrderCreatedEvent(int orderId, DateTime createdAt)
    {
        OrderId = orderId;
        CreatedAt = createdAt;
    }
}

۳. تعریف چند هندلر برای ایونت

using MediatR;

public class LogOrderHandler : INotificationHandler<OrderCreatedEvent>
{
    public Task Handle(OrderCreatedEvent notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"[1] Logging Order Created: {notification.OrderId}");
        return Task.CompletedTask;
    }
}

public class SendEmailHandler : INotificationHandler<OrderCreatedEvent>
{
    public Task Handle(OrderCreatedEvent notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"[2] Sending Email for Order: {notification.OrderId}");
        return Task.CompletedTask;
    }
}

public class UpdateInventoryHandler : INotificationHandler<OrderCreatedEvent>
{
    public Task Handle(OrderCreatedEvent notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"[3] Updating Inventory for Order: {notification.OrderId}");
        return Task.CompletedTask;
    }
}

ترتیب اجرای هندلرها (Custom Execution Order)

۴. پیاده‌سازی Decorator برای ترتیب هندلرها

using MediatR;

public class OrderedNotificationHandler<TNotification> : INotificationHandler<TNotification>
    where TNotification : INotification
{
    private readonly IEnumerable<INotificationHandler<TNotification>> _handlers;

    public OrderedNotificationHandler(IEnumerable<INotificationHandler<TNotification>> handlers)
    {
        _handlers = handlers;
    }

    public async Task Handle(TNotification notification, CancellationToken cancellationToken)
    {
        foreach (var handler in _handlers.OrderBy(h => GetPriority(h)))
        {
            await handler.Handle(notification, cancellationToken);
        }
    }

    private int GetPriority(INotificationHandler<TNotification> handler)
    {
        var priorityAttribute = handler.GetType()
            .GetCustomAttributes(typeof(HandlerPriorityAttribute), true)
            .FirstOrDefault() as HandlerPriorityAttribute;

        return priorityAttribute?.Priority ?? int.MaxValue; 
    }
}

[AttributeUsage(AttributeTargets.Class)]
public class HandlerPriorityAttribute : Attribute
{
    public int Priority { get; }
    public HandlerPriorityAttribute(int priority) => Priority = priority;
}

۵. افزودن اولویت به هندلرها

[HandlerPriority(1)]
public class LogOrderHandler : INotificationHandler<OrderCreatedEvent>
{
    public Task Handle(OrderCreatedEvent notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"[1] Logging Order Created: {notification.OrderId}");
        return Task.CompletedTask;
    }
}

[HandlerPriority(2)]
public class SendEmailHandler : INotificationHandler<OrderCreatedEvent>
{
    public Task Handle(OrderCreatedEvent notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"[2] Sending Email for Order: {notification.OrderId}");
        return Task.CompletedTask;
    }
}

[HandlerPriority(3)]
public class UpdateInventoryHandler : INotificationHandler<OrderCreatedEvent>
{
    public Task Handle(OrderCreatedEvent notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"[3] Updating Inventory for Order: {notification.OrderId}");
        return Task.CompletedTask;
    }
}

۶. ثبت Decorator در DI

using MediatR;

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddMediatR(typeof(Program));

builder.Services.Decorate(typeof(INotificationHandler<>), typeof(OrderedNotificationHandler<>));

var app = builder.Build();
app.Run();

۷. انتشار ایونت

using MediatR;

public class OrderService
{
    private readonly IMediator _mediator;

    public OrderService(IMediator mediator)
    {
        _mediator = mediator;
    }

    public async Task CreateOrder(int orderId)
    {
        Console.WriteLine("Creating Order...");

        var orderCreatedEvent = new OrderCreatedEvent(orderId, DateTime.UtcNow);
        await _mediator.Publish(orderCreatedEvent);
    }
}

Creating Order...
[1] Logging Order Created: 123
[2] Sending Email for Order: 123
[3] Updating Inventory for Order: 123