RabbitMQ C# (Geliştiriciler İçin Nasıl Çalışır)

Anahtar Kavramlar

1. Üretici: RabbitMQ değişimine mesaj göndermekten sorumlu bileşen.
2. Değişim: Mesajların kuyruklara nasıl dağıtılacağını belirleyen bir yönlendirme mekanizması. Yaygın türler arasında doğrudan, dağıtım, konu ve başlıklar bulunur.
3. Kuyruk: Üreticiler tarafından gönderilen mesajları bir tüketici tarafından tüketilinceye kadar depolayan bir arabellek.
4. Tüketici: RabbitMQ kuyruğundan mesaj almak ve işlemekten sorumlu bileşen.
5. Bağlama: Değişim ile kuyruk arasındaki ilişkiyi tanımlar, mesajların nasıl yönlendirileceğini belirtir.

RabbitMQ .NET İstemci Kurulumu

NuGet Paket Yöneticisi Konsolu aracılığıyla RabbitMQ İstemci kütüphanesini kurun:

Install-Package RabbitMQ.Client

Ya da RabbitMQ.Client'i göz atarak ve kurarak NuGet Paket Yöneticisini kullanabilirsiniz:

Bağlantı Fabrikasını Kurmak

// Creates a ConnectionFactory object to configure the connection settings
var factory = new ConnectionFactory { HostName = "localhost" };

// Creates a ConnectionFactory object to configure the connection settings
var factory = new ConnectionFactory { HostName = "localhost" };

' Creates a ConnectionFactory object to configure the connection settings
Dim factory = New ConnectionFactory With {.HostName = "localhost"}

Yukarıdaki kod parçası, "localhost" olarak ayarlanan HostName ile bir ConnectionFactory nesnesi oluşturur. Bu nesne, RabbitMQ sunucusuna bağlantıyı yapılandırmak için kullanılır.

Bağlantı ve Kanal Oluşturma

// Establishes a connection to the RabbitMQ server
using var connection = factory.CreateConnection();

// Creates a channel, which is the means of communication with RabbitMQ
using var channel = connection.CreateModel();

// Establishes a connection to the RabbitMQ server
using var connection = factory.CreateConnection();

// Creates a channel, which is the means of communication with RabbitMQ
using var channel = connection.CreateModel();

' Establishes a connection to the RabbitMQ server
Dim connection = factory.CreateConnection()

' Creates a channel, which is the means of communication with RabbitMQ
Dim channel = connection.CreateModel()

RabbitMQ sunucusuna bağlantı, ConnectionFactory yönteminin CreateConnection metodu kullanılarak kurulur. Daha sonra, bağlantının CreateModel yöntemi kullanılarak bir kanal oluşturulur. Kanallar, uygulamalar ile RabbitMQ sunucusu arasında iletişim için kullanılır.

Bir Kuyruk Deklare Etmek

Kuyruklar, büyük mesaj arabelleklerini yönetmede ve dağıtık sistemlerde bir arabellek mekanizması sağlamada hayati bir rol oynar. Bu amaç için QueueDeclare metodu bulunmaktadır:

// Declares a queue within the channel
channel.QueueDeclare(queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null);

// Declares a queue within the channel
channel.QueueDeclare(queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null);

' Declares a queue within the channel
channel.QueueDeclare(queue:= "hello", durable:= False, exclusive:= False, autoDelete:= False, arguments:= Nothing)

Kod, belirli özellikler ile 'hello' adında bir kuyruk deklare eder:

• durable: false - Kuyruk, broker yeniden başlatıldığında kalmaz.
• exclusive: false - Kuyruk diğer bağlantılar tarafından kullanılabilir.
• autoDelete: false - Son tüketici abone olmadığında kuyruk silinmeyecek.
• arguments: Ek kuyruk argümanları (bu durumda null olarak ayarlanmıştır).

Mesaj Verisini Hazırlama

// Prepares the message to be sent
var message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);

// Prepares the message to be sent
var message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);

' Prepares the message to be sent
Dim message = "Hello World!"
Dim body = Encoding.UTF8.GetBytes(message)

Basit bir mesaj, "Hello World!", hazırlanır ve bu mesajın ikili temsili (UTF-8 kodlu) body değişkenine depolanır.

Mesajı Yayınlama

// Publishes the message to the specified exchange and routing key
channel.BasicPublish(exchange: string.Empty, routingKey: "hello", basicProperties: null, body: body);

// Publishes the message to the specified exchange and routing key
channel.BasicPublish(exchange: string.Empty, routingKey: "hello", basicProperties: null, body: body);

' Publishes the message to the specified exchange and routing key
channel.BasicPublish(exchange:= String.Empty, routingKey:= "hello", basicProperties:= Nothing, body:= body)

Mesaj, belirtilen değişim yerine ("string.Empty" varsayılan değişim yerini belirtir) "hello" yönlendirme anahtarıyla yayımlamak için BasicPublish yöntemi kullanılır. basicProperties parametresi null olarak ayarlanır ve body gerçek mesajı içerir.

Konsol Çıkışı

// Outputs to the console that the message has been sent
Console.WriteLine($" [x] Sent {message}");

// Outputs to the console that the message has been sent
Console.WriteLine($" [x] Sent {message}");

' Outputs to the console that the message has been sent
Console.WriteLine($" [x] Sent {message}")

Bir mesaj konsol penceresine mesajın gönderildiğini belirterek yazdırılır.

Kullanıcının Girişi Bekleniyor

// Waits for user input to prevent the application from exiting immediately
Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();

// Waits for user input to prevent the application from exiting immediately
Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();

' Waits for user input to prevent the application from exiting immediately
Console.WriteLine(" Press [enter] to exit.")
Console.ReadLine()

Uygulama çıkmadan önce kullanıcının Enter tuşuna basmasını bekler. Bu, mesajın yayınlanmasını sağlar ve uygulamanın hemen kapanmasını önler.

Bu kod, bir RabbitMQ sunucusuna bağlantı kurar, bir kuyruk deklare eder, bir mesaj hazırlayıp, belirtilen kuyrukta mesajı yayınlar, ve çıkmadan önce kullanıcı girişini bekler. RabbitMQ sunucuları, yukarıda anlatıldığı gibi, mesaj almak için de kullanılabilir. Bu bağlamda sunucu, bir mesaj aracısı olarak davranır.

1. Mikroservisleri Dekuple Etme

RabbitMQ, mikroservisler arasında gevşek bir bağ kurmayı kolaylaştırır. Her bir mikroservis, doğrudan bağımlılıklar olmadan iletişim sağlamak amacıyla mesaj alışverişinde bulunarak üretici veya tüketici olarak hareket edebilir.

2. Arka Plan İşi İşleme

Arka plan işleme uygulamak için RabbitMQ'yu kullanın. Üreticiler işleri bir kuyruk içerisine iter ve tüketiciler (işçiler) bu işleri asenkron olarak işler, kaynakların etkin kullanımını sağlar.

3. Olay Tabanlı Mimariler

Bileşenlerin olaylar aracılığıyla iletişim kurduğu olay tabanlı mimariler uygulayın. Olaylar üretilir ve tüketilir, dinamik ve tepki veren sistemlerin çalışmasını sağlar.

4. Uygulamaları Ölçekleme

RabbitMQ, iş yüklerini birden fazla örnek üzerinde dağıtarak uygulamaların yatay olarak ölçeklenmesine yardımcı olur. Kaynakların etkin kullanımını sağlar ve sistem güvenilirliğini korur.

HTML'den PDF Üretme

IronPDF ile HTML'den PDF oluşturmak IronPDF ile basittir. İşte basit bir HTML String'den PDF'ye örnek kaynak kodu:

using IronPdf;

var htmlContent = "<h1>Hello, IronPDF!</h1>";
var renderer = new ChromePdfRenderer();

// Create a PDF from an HTML string using C#
var pdf = renderer.RenderHtmlAsPdf(htmlContent);

// Export to a file or Stream
pdf.SaveAs("output.pdf");

using IronPdf;

var htmlContent = "<h1>Hello, IronPDF!</h1>";
var renderer = new ChromePdfRenderer();

// Create a PDF from an HTML string using C#
var pdf = renderer.RenderHtmlAsPdf(htmlContent);

// Export to a file or Stream
pdf.SaveAs("output.pdf");

Imports IronPdf

Private htmlContent = "<h1>Hello, IronPDF!</h1>"
Private renderer = New ChromePdfRenderer()

' Create a PDF from an HTML string using C#
Private pdf = renderer.RenderHtmlAsPdf(htmlContent)

' Export to a file or Stream
pdf.SaveAs("output.pdf")

C# içinde IronPDF kullanılarak daha fazla PDF ile ilgili işlevsellik için lütfen bu IronPDF Kod Örnekleri sayfasına bakın.