‫جایگزینی MediatR با System.Threading.Channels

• وابستگی خارجی: نیاز به نصب بسته‌های NuGet و به‌روزرسانی مداوم آن‌ها.
• پیچیدگی‌های پنهان: استفاده از بازتاب (Reflection) برای یافتن و اجرای هندلرها (Handlers) ممکن است شفافیت کد را کاهش دهد.
• عملکرد در بار بالا: در سناریوهای با توان عملیاتی بالا، سربارهای MediatR ممکن است محسوس باشد.

• بدون محدودیت (Unbounded): هیچ محدودیتی در ظرفیت صف وجود ندارد و داده‌ها بدون توقف ذخیره می‌شوند.
• محدود (Bounded): ظرفیت صف محدود است و در صورت پر شدن، فشار بازگشتی اعمال می‌شود تا تولیدکننده (Producer) منتظر بماند.

internal sealed class InMemoryMessageQueue
{
    private readonly Channel<IIntegrationEvent> _channel = Channel.CreateUnbounded<IIntegrationEvent>();
    public ChannelReader<IIntegrationEvent> Reader => _channel.Reader;
    public ChannelWriter<IIntegrationEvent> Writer => _channel.Writer;
}

• Channel.CreateUnbounded یک کانال بدون محدودیت ایجاد می‌کند.
• ChannelReader و ChannelWriter به ترتیب برای خواندن و نوشتن پیام‌ها استفاده می‌شوند.
• IIntegrationEvent یک رابط (Interface) است که رویدادهای یکپارچه‌سازی (Integration Events) را تعریف می‌کند.

internal sealed class EventBus : IEventBus
{
    private readonly InMemoryMessageQueue _queue;
    public EventBus(InMemoryMessageQueue queue) => _queue = queue;

    public async Task PublishAsync<T>(
        T integrationEvent, 
        CancellationToken cancellationToken = default)
        where T : class, IIntegrationEvent
    {
        await _queue.Writer.WriteAsync(integrationEvent, cancellationToken);
    }
}

• رویدادها را از طریق PublishAsync به کانال می‌نویسد.
• نیازی به تزریق وابستگی‌های پیچیده یا دکوراتورها (Decorators) ندارد.
• کاملاً شفاف و قابل‌تنظیم است.

using System.Threading.Channels;
using System.Threading.Tasks;

var channel = Channel.CreateBounded<int>(3);
var writer = channel.Writer;
var reader = channel.Reader;

Task.Run(async () =>
{
    for (int i = 1; i <= 5; i++)
    {
        await writer.WriteAsync(i);
        Console.WriteLine($"Sent: {i}");
        await Task.Delay(500);
    }
    writer.Complete();
});

Task.Run(async () =>
{
    while (await reader.WaitToReadAsync())
    {
        while (reader.TryRead(out int value))
        {
            Console.WriteLine($"Received: {value}");
        }
    }
});

await Task.Delay(3000);

• یک کانال محدود با ظرفیت 3 ایجاد می‌شود.
• تولیدکننده (Producer) اعداد 1 تا 5 را با تأخیر 500 میلی‌ثانیه ارسال می‌کند.
• مصرف‌کننده (Consumer) به‌صورت ناهمگام داده‌ها را می‌خواند و نمایش می‌دهد.
• متد writer.Complete() پایان نوشتن را اعلام می‌کند.

1. بدون وابستگی خارجی: کاهش ریسک‌های مرتبط با به‌روزرسانی بسته‌ها و مشکلات مجوز.
2. شفافیت کامل: کد کاملاً قابل‌فهم و بدون استفاده از بازتاب است.
3. عملکرد بالا: طراحی شده برای سناریوهای با توان عملیاتی بالا، مشابه آنچه در ASP.NET Core استفاده می‌شود.
4. انعطاف‌پذیری: امکان افزودن قابلیت‌هایی مانند لاگ‌گیری، دسته‌بندی (Batching) یا محدودسازی (Throttling) به‌صورت دستی.
5. آینده‌نگری: با تکیه بر ابزارهای بومی، معماری برنامه در برابر تغییرات کتابخانه‌های خارجی مقاوم است.

var options = new BoundedChannelOptions(3) { FullMode = BoundedChannelFullMode.Wait };
var channel = Channel.CreateBounded<int>(options);

while (await reader.WaitToReadAsync())
{
    var list = new List<int>();
    while (reader.TryRead(out int value)) list.Add(value);
    Console.WriteLine($"Batch: {string.Join(", ", list)}");
}