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

Anahtar Kavramlar

1. Üretici: Bir RabbitMQ değişim yerine mesaj göndermekten sorumlu bileşen.
2. Değişim: Mesajların kuyruklara nasıl dağıtılması gerektiğini belirleyen bir yönlendirme mekanizması. Yaygın türler arasında doğrudan, yayılma, konu ve başlıklar bulunur.
3. Kuyruk: Üreticiler tarafından gönderilen mesajların bir tüketici tarafından tüketilene kadar saklandığı bir tampon.
4. Tüketici: RabbitMQ kuyruğundan mesaj almak ve işlemekten sorumlu bileşen.
5. Bağlama: Bir değişim ve bir kuyruk arasındaki ilişkiyi tanımlar, mesajların nasıl yönlendirilmesi gerektiğini belirler.

RabbitMQ .NET İstemcisi Kurulumu

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

Install-Package RabbitMQ.Client

Ya da, RabbitMQ.Client'i göz atmak ve yüklemek için Çözümler İçin NuGet Paket Yöneticisini kullanabilirsiniz:

Bağlantı Fabrikasının Ayarlanması

// 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.

Bir 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 bir bağlantı, ConnectionFactory yönteminin CreateConnection metodu kullanılarak kurulur. Daha sonra, bağlantının CreateModel metodu kullanılarak bir kanal oluşturulur. Kanallar, uygulamalar ile RabbitMQ sunucusu arasında iletişim için kullanılır.

Bir Kuyruk İlan Etme

Kuyruklar, büyük mesaj tamponlarını işlemek ve dağıtılmış sistemlerde bir tampon mekanizması sağlamak için kritik bir rol oynar. Bu amaç için kullanılan QueueDeclare yöntemi burada:

// 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 "hello" adlı bir kuyruk, belirli özelliklerle ilan eder:

• durable: false - Kuyruk bir aracı yeniden başlatıldığında hayatta kalmayacak.
• exclusive: false - Kuyruk diğer bağlantılar tarafından kullanılabilir.
• autoDelete: false - Son tüketici aboneliğini iptal ettiğinde kuyruk silinmeyecek.
• arguments: Ek kuyruk argümanları (null olarak ayarlanmıştır).

Mesaj Verilerini 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 onun ikili temsili (UTF-8 kodlamalı) body değişkeninde saklanı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)

BasicPublish metodu, mesajı belirtilen değiş tokuşa ("string.Empty" varsayılan exchange'i gösterir) "hello" yönlendirme anahtarı ile yayınlamak için kullanılır. basicProperties parametresi null olarak ayarlanmıştır ve body gerçek mesajı içerir.

Konsol Çıktısı

// 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}")

Mesajın gönderildiğini belirten bir mesaj konsol penceresine yazdırılır.

Kullanıcı Girdisi Bekleme

// 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 sona ermemesini garanti eder.

Bu kod, bir RabbitMQ sunucusuna bağlantı kurar, bir kuyruk ilan eder, bir mesaj hazırlar, mesajı belirli kuyruğa yayınlar ve ardından çıkmadan önce kullanıcı girdiğini bekler. RabbitMQ sunucuları da yukarıda açıklanan şekilde mesaj alabilirler. Bu bağlamda sunucu bir mesaj aracısı olarak hareket eder.

1. Mikro Hizmetleri Gevşek Birleştirme

RabbitMQ, mikro hizmetler arasında gevşek bağlanmayı kolaylaştırır. Her mikro hizmet, mesaj alışverişi yaparak doğrudan bağımlılıklar olmadan iletişimi gerçekleştirmek için bir üretici veya tüketici olarak hareket edebilir.

2. Arka Plan Görevi İşleme

RabbitMQ ile arka plan görevi işlemeyi uygulayın. Üreticiler işleri bir kuyruğa itip tüketiciler (çalışanlar) bu işleri senkronizasyon dışı olarak işleyerek kaynakların etkin kullanımını sağlar.

3. Olay Odaklı Mimariler

Olaylar aracılığıyla iletişim kuran olay odaklı mimariler uygulayın. Olaylar üretilir ve tüketilir, dinamik ve duyarlı sistemler sağlar.

4. Uygulamaların Ölçeklendirilmesi

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

HTML'den PDF Oluşturma

IronPDF ile HTML'den PDF oluşturmak, IronPDF ile basittir. İşte basit bir HTML Dizesi ile PDF örneğinin 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")

IronPDF kullanarak C# ile ilgili daha fazla PDF işlevselliği için lütfen bu IronPDF Kod Örnekleri sayfasını ziyaret edin.