Mikro Servisler Arasında (Event-based) Mesajlaşma: MassTransit ile Kolaylık vs. Manuel Kontrol

Mesaj tabanlı iletişim, mikro hizmetler arasında veri iletimi için kritik bir rol oynar. Bu iletişim modeli, hizmetlerin asenkron olarak birbirleriyle haberleşmesine olanak tanır ve bu sayede hizmetlerin bağımsız olarak çalışabilmesini sağlar. MassTransit, bu iletişimi kolaylaştırmak ve optimize etmek için kullanılan güçlü bir kütüphanedir. Ancak, kütüphane kullanmadan da mesaj tabanlı iletişim kurmak mümkündür. Bu makalede, MassTransit ile mesaj tabanlı iletişimin nasıl yapıldığını ve aynı işlerin kütüphane kullanmadan nasıl gerçekleştirilebileceğini karşılaştırmalı olarak inceleyeceğiz.

MassTransit Nedir?

MassTransit, .NET uygulamaları için açık kaynaklı bir mesajlaşma kütüphanesidir. Mikro servisler arasında mesaj tabanlı iletişimi kolaylaştırmak amacıyla geliştirilmiştir. MassTransit, mesajlaşma altyapılarıyla (RabbitMQ, Azure Service Bus, Amazon SQS vb.) uyumlu çalışarak asenkron iletişimi ve iş yükü dağıtımını sağlar.

Temel Özellikler

1. Kolay Entegrasyon: MassTransit, .NET Core ve .NET Framework ile sorunsuz bir şekilde entegre olabilir. NuGet paket yöneticisi kullanılarak kolayca kurulabilir.
2. Desteklenen Mesajlaşma Altyapıları: MassTransit, RabbitMQ, Azure Service Bus, Amazon SQS ve diğer popüler mesajlaşma altyapılarıyla uyumludur. Bu sayede, farklı altyapılar arasında geçiş yapmayı kolaylaştırır.
3. Pub/Sub: MassTransit, pub/sub modelini ve queue tabanlı mesajlaşmayı destekler. Bu sayede, mesajların birden fazla tüketiciye ulaşmasını sağlar.
4. Gelişmiş Özellikler: MassTransit, otomatik yeniden deneme (retry), zamanlayıcılar (schedulers), hata işleme (error handling) ve dağıtık işlemler (distributed transactions) gibi gelişmiş özellikler sunar.
5. Konfigürasyon ve Kullanım Kolaylığı: MassTransit, basit ve anlaşılır bir API ile gelir. Konfigürasyon dosyaları ve kod tabanlı ayarlar ile esnek bir yapı sunar.

MassTransit’in Kurulumu ve Konfigürasyonu

MassTransit kullanarak mesaj tabanlı iletişim kurmak oldukça kolaydır. Öncelikle, MassTransit’in nasıl kurulduğunu ve konfigüre edildiğini görelim.

MassTransit’in Kurulumu

1.Projeye MassTransit NuGet paketini ekleyin:

Install-Package MassTransit

2.RabbitMQ veya başka bir mesajlaşma altyapısı ile konfigüre edin:

public class Message
{
    public string Text { get; set; }
}

var busControl = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    cfg.Host(new Uri("rabbitmq://localhost"), h =>
    {
        h.Username("guest");
        h.Password("guest");
    });
});
await busControl.StartAsync();
try
{
    await busControl.Publish(new Message { Text = "Hello World!" });
}
finally
{
    await busControl.StopAsync();
}

3. MassTransit ile Mesaj Alma: mesajların nasıl alınacağını görelim.

public class MessageConsumer : IConsumer<Message>
{
    public async Task Consume(ConsumeContext<Message> context)
    {
        Console.WriteLine("Received message: {0}", context.Message.Text);
    }
}

//Configurations
var busControl = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    cfg.Host(new Uri("rabbitmq://rabbitmq"), h =>
    {
        h.Username("guest");
        h.Password("guest");
    });
    cfg.ReceiveEndpoint("message_queue", ep =>
    {
        ep.Consumer<MessageConsumer>();
    });
});
await busControl.StartAsync();
Console.WriteLine("Press any key to exit");
Console.ReadKey();
await busControl.StopAsync();

Kütüphane Kullanmadan Mesaj Tabanlı İletişim

Peki MassTransit kullanmadan da RabbitMQ ile mesaj tabanlı iletişimi manuel olarak gerçekleştirebilir miyiz? İşte adım adım nasıl yapacağımızı göstereceğim.

İlk olarak, .NET projenize RabbitMQ.Client NuGet paketini ekleyin:

Install-Package RabbitMQ.Client 

Ardından, RabbitMQ’ya bağlanmak ve mesaj göndermek için aşağıdaki adımları izleyelim:

1.Bağlantı oluşturma:

• RabbitMQ’ya bağlanmak için ConnectionFactory sınıfını kullanın ve bağlantı parametrelerini ayarlayın.

2.Channel oluşturma:

• Mesaj göndermek ve almak için bir kanal oluşturun.

3.Queue oluşturma:

• Mesajların gönderileceği bir kuyruk oluşturun.

4.Mesaj gönderme:

• Mesajı uygun formatta hazırlayın ve gönderin.

İşte örnek kod:

Bu kod, hello adlı bir kuyruk oluşturur ve bu kuyruğa "Hello World!" mesajını gönderir.

using RabbitMQ.Client;
using System;
using System.Text;

class Send
{
    public static void Main()
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using(var connection = factory.CreateConnection())
        using(var channel = connection.CreateModel())
        {
            channel.QueueDeclare(queue: "hello",
                                 durable: false,
                                 exclusive: false,
                                 autoDelete: false,
                                 arguments: null);

            string message = "Hello World!";
            var body = Encoding.UTF8.GetBytes(message);

            channel.BasicPublish(exchange: "",
                                 routingKey: "hello",
                                 basicProperties: null,
                                 body: body);
            Console.WriteLine(" [x] Sent {0}", message);
        }
    }
}

Mesajları dinlemek için bir consumer tanımlayalım: Bu kod, hello adlı queue’yu dinler ve bir mesaj alındığında konsola yazdırır.

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Text;

class Receive
{
    public static void Main()
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using(var connection = factory.CreateConnection())
        using(var channel = connection.CreateModel())
        {
            channel.QueueDeclare(queue: "hello",
                                 durable: false,
                                 exclusive: false,
                                 autoDelete: false,
                                 arguments: null);

            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body.ToArray();
                var message = Encoding.UTF8.GetString(body);
                Console.WriteLine(" [x] Received {0}", message);
            };
            channel.BasicConsume(queue: "hello",
                                 autoAck: true,
                                 consumer: consumer);

            Console.WriteLine(" Press [enter] to exit.");
            Console.ReadLine();
        }
    }
}

Bu yöntemler kullanılarak, kütüphane olmadan RabbitMQ ile mesaj tabanlı iletişim kurabilirsiniz. Ancak, bu manuel yöntemler daha fazla kod yazmayı ve daha fazla ayrıntıyı yönetmeyi gerektirir.

Hangisini Kullanmalı?

• Manuel Çözümler: Daha fazla kontrol ve esneklik sağlar ancak kod karmaşıklığını ve hata yapma olasılığını artırır. Performans optimizasyonları zaman alıcı olabilir ve her mesajlaşma altyapısı için ayrı kod yazmak gerekebilir. Güvenlik ve ölçeklenebilirlik sağlamak için ekstra çaba gerektirir.
• MassTransit: Optimizasyonlar ve yerleşik çözümler sunarak performansı artırır, daha az kod yazmayı gerektirir ve yüksek performanslı, ölçeklenebilir bir mesajlaşma altyapısı sağlar. Kullanım kolaylığı, basit konfigürasyon ve geniş topluluk desteği sunar. Ek güvenlik ve ölçeklenebilirlik özellikleri ile hızlı ve güvenli sistemler oluşturulabilir.

Sonuç

Her iki yöntem de belirli senaryolarda avantajlar sunar. Manuel çözümler, daha fazla esneklik ve kontrol sağlarken, MassTransit gibi kütüphaneler kullanım kolaylığı ve performans avantajları sunar.

Proje gereksinimlerine göre en uygun yöntemi seçmek önemlidir. Eğer hızlı bir şekilde mesaj tabanlı iletişim kurmak ve yönetmek istiyorsanız, MassTransit gibi bir kütüphane kullanmak daha mantıklı olabilir. Ancak, daha fazla kontrol ve özelleştirme gerekiyorsa manuel çözümler tercih edilebilir.

Kaynaklar

MassTransit

.NET/C# RabbitMQ Client Library | RabbitMQ