MediatR: Publish Notification

Trong MediatR, Publish Method chính là công cụ mà chúng ta sử dụng để gửi notification đến các handler đã đăng ký. Các handler này sẽ được thực thi theo thứ tự được đăng ký.

Mô hình Publish Method trong MediatR được xây dựng theo design pattern Observer.

Design pattern Observer (hay còn gọi là Subscriber) định nghĩa một mối quan hệ một-nhiều trong đó một đối tượng publisher duy trì một danh sách các đối tượng subscriber và gửi notification cho tất cả các subscriber khi có thay đổi xảy ra. 

Ưu điểm của design pattern này là giảm sự phụ thuộc trực tiếp của các class. Việc thêm hoặc gỡ bỏ các subscriber (handler) đơn giản chỉ cần thực hiện thao tác đăng ký hoặc hủy đăng ký với mediator.

Setup Notification

MediatR cung cấp interface INotification làm lớp trung gian để thực hiện việc đăng ký subcriber

//
// Summary:
//     Marker interface to represent a notification
public interface INotification
{
}

Tạo 1 class cụ thể cho Notification

public class AddAuthorEvent: INotification
{
    public int AuthorId { get; set; }
}

Tạo 2 handler Email và Log để đăng ký xử lý Notification

using CqrsSample.Services.Repositories;
using MediatR;

namespace CqrsSample.Application.Notifications.Handlers;

public class AddAuthorEventEmailHandler: INotificationHandler<AddAuthorEvent>
{
    private readonly IAuthorRepository _authorRepository;

    public AddAuthorEventEmailHandler(IAuthorRepository authorRepository)
    {
        _authorRepository = authorRepository;
    }

    public async Task Handle(AddAuthorEvent notification, CancellationToken cancellationToken)
    {
        var author = await _authorRepository.Get(notification.AuthorId);
        if(author == null) { return; }
        var message = $"Send email: Author {author.FirstName} {author.LastName} was created";
        Console.WriteLine(message);
    }
}

public class AddAuthorEventLogHandler : INotificationHandler<AddAuthorEvent>
{
    private readonly IAuthorRepository _authorRepository;

    public AddAuthorEventLogHandler(IAuthorRepository authorRepository)
    {
        _authorRepository = authorRepository;
    }

    public async Task Handle(AddAuthorEvent notification, CancellationToken cancellationToken)
    {
        var author = await _authorRepository.Get(notification.AuthorId);
        if(author == null) { return; }
        var message = $"Log: Author {author.FirstName} {author.LastName} was created";
        Console.WriteLine(message);
    }
}

Thêm hàm trả về Author Info

public Task<AuthorModel> Get(int id)
{
    var author = _dbContext.Authors.FirstOrDefault
        (x => x.Id == id);
    if (author == null) { return null; }
    return Task.FromResult(new AuthorModel
    {
        FirstName = author.FirstName,
        LastName = author.LastName,
        Id = id
    });
}

Từ controller, chúng ta sẽ publish notification sau khi Author được tạo

[HttpPost]
public async Task<int> Create(AddAuthorModel author)
{
    var newAuthorCommand = new AddAuthorCommand
    {
        FirstName = author.FirstName,
        LastName = author.LastName
    };
    var result = await _mediator.Send(newAuthorCommand);
    await _mediator.Publish(new AddAuthorEvent { AuthorId = result });
    return result;
}

Sau khi thực hiện gọi API, bạn sẽ thấy kết quả từ console log:

info: CqrsSample.Behaviors.LoggingBehavior[0]
      Handled Int32
Send email: Author string string was created
Log: Author string string was created

Tham khảo

How To Publish MediatR Notifications In Parallel

.NET Core MediatR with Notification(Publish) and Behaviors

The Power of MediatR Notifications in CQRS and Microservices