RabbitMQ C# (jak to działa dla programistów)

Koncepcje kluczowe

1. Producent: komponent odpowiedzialny za wysyłanie wiadomości do wymiany RabbitMQ.
2. Wymiana: mechanizm routingu, który określa, jak wiadomości powinny być dystrybuowane do kolejek. Typowe rodzaje to direct, fanout, topic i headers.
3. Kolejka: bufor, który przechowuje wiadomości wysłane przez producentów, dopóki nie zostaną one skonsumowane przez konsumenta.
4. Konsument: komponent odpowiedzialny za odbieranie i przetwarzanie wiadomości z kolejki RabbitMQ.
5. Powiązanie: definiuje związek między wymianą a kolejką, określając, jak wiadomości powinny być routowane.

Instalacja klienta RabbitMQ .NET

Zainstaluj bibliotekę klienta RabbitMQ poprzez NuGet Package Manager Console:

Install-Package RabbitMQ.Client

Lub możesz użyć NuGet Package Manager for Solutions, aby przeglądać i instalować RabbitMQ.Client:

Konfiguracja fabryki połączeń

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

Powyższy fragment kodu tworzy obiekt ConnectionFactory z HostName ustawionym na "localhost". Ten obiekt służy do konfiguracji połączenia z serwerem RabbitMQ.

Tworzenie połączenia i kanału

// 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()

Połączenie z serwerem RabbitMQ jest nawiązywane za pomocą metody CreateConnection na obiekcie ConnectionFactory. Następnie za pomocą metody CreateModel na połączeniu tworzony jest kanał. Kanały używane są do komunikacji między aplikacjami a serwerem RabbitMQ.

Tworzenie kolejki

Kolejki odgrywają kluczową rolę w zarządzaniu dużymi buforami wiadomości i stanowią mechanizm buforowania w systemach rozproszonych. Oto metoda QueueDeclare do tego celu:

// 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 deklaruje kolejkę o nazwie "hello" z określonymi właściwościami:

• durable: false - Kolejka nie przetrwa ponownego uruchomienia brokera.
• exclusive: false - Kolejka może być używana przez inne połączenia.
• autoDelete: false - Kolejka nie zostanie usunięta po tym, jak ostatni konsument się wypisze.
• arguments: Dodatkowe argumenty kolejki (ustawione na null w tym przypadku).

Przygotowywanie danych wiadomości

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

Prosta wiadomość "Hello World!" jest przygotowana, a jej binarna reprezentacja (kodowanie UTF-8) jest przechowywana w zmiennej body.

Publikowanie wiadomości

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

Metoda BasicPublish jest używana do publikowania wiadomości na określonej wymianie ("string.Empty" wskazuje na domyślną wymianę) z kluczem routingu "hello". Parametr basicProperties jest ustawiony na null, a body zawiera rzeczywistą wiadomość.

Wynik konsoli

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

Na konsoli drukowana jest wiadomość wskazująca, że wiadomość została wysłana.

Oczekiwanie na dane wejściowe od użytkownika

// 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()

Aplikacja czeka na naciśnięcie klawisza Enter przez użytkownika przed zamknięciem. To pozwala na opublikowanie wiadomości i zapewnia, że aplikacja nie zakończy się natychmiast.

Ten kod ustawia połączenie z serwerem RabbitMQ, deklaruje kolejkę, przygotowuje wiadomość, publikuje wiadomość do określonej kolejki i czeka na dane wejściowe od użytkownika przed zakończeniem. Serwery RabbitMQ mogą również odbierać wiadomości w ten sam sposób, jak opisano powyżej. W tym kontekście serwer działa jako broker wiadomości.

1. Oddzielanie mikroserwisów

RabbitMQ ułatwia luźne powiązanie między mikroserwisami. Każdy mikroserwis może działać jako producent lub konsument, wymieniając się wiadomościami, aby osiągnąć komunikację bez bezpośrednich zależności.

2. Przetwarzanie zadań w tle

Użyj RabbitMQ do implementacji przetwarzania zadań w tle. Producenci umieszczają zadania w kolejce, a konsumenci (pracownicy) przetwarzają te zadania asynchronicznie, zapewniając efektywne wykorzystanie zasobów.

3. Architektury zorientowane na zdarzenia

Implementuj architektury zorientowane na zdarzenia, w których komponenty komunikują się poprzez zdarzenia. Zdarzenia są produkowane i konsumowane, umożliwiając dynamiczne i szybkie systemy.

4. Skalowanie aplikacji

RabbitMQ wspomaga skalowanie aplikacji horyzontalnie przez rozdzielanie obciążenia między wieloma instancjami. Zapewnia efektywne wykorzystanie zasobów i utrzymuje niezawodność systemu.

Generowanie pliku PDF z HTML

Tworzenie PDF z HTML za pomocą IronPDF jest prostym procesem dzięki IronPDF. Oto kod źródłowy prostego przykładu konwersji ciągu HTML na 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");

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

Aby uzyskać więcej funkcji związanych z PDF w C# za pomocą IronPDF, odwiedź stronę przykłady kodu IronPDF.