RabbitMQ C# (Funktionsweise für Entwickler)

Schlüsselkonzepte

1. Produzent: Die Komponente, die für das Senden von Nachrichten an einen RabbitMQ-Exchange verantwortlich ist.
2. Exchange: Ein Routing-Mechanismus, der bestimmt, wie Nachrichten an Queues verteilt werden sollen. Gängige Typen sind direct, fanout, topic und headers.
3. Queue: Ein Puffer, der Nachrichten speichert, die von Produzenten gesendet wurden, bis sie von einem Konsumenten abgerufen werden.
4. Konsument: Die Komponente, die für den Empfang und die Verarbeitung von Nachrichten aus einer RabbitMQ-Queue verantwortlich ist.
5. Binding: Definiert die Beziehung zwischen einem Exchange und einer Queue und gibt an, wie Nachrichten geroutet werden sollen.

RabbitMQ .NET Client-Installation

Installieren Sie die RabbitMQ-Clientbibliothek über die NuGet-Paket-Manager-Konsole:

Install-Package RabbitMQ.Client

Oder Sie können den NuGet-Paket-Manager für Lösungen verwenden, um RabbitMQ.Client zu durchsuchen und zu installieren:

Einrichten der Connection Factory

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

Der obige Code-Schnipsel erstellt ein ConnectionFactory-Objekt mit dem HostName auf "localhost" gesetzt. Dieses Objekt wird verwendet, um die Verbindung zum RabbitMQ-Server zu konfigurieren.

Erstellen einer Verbindung und eines Kanals

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

Eine Verbindung zum RabbitMQ-Server wird mit der CreateConnection-Methode des ConnectionFactory hergestellt. Anschließend wird ein Kanal mit der CreateModel-Methode der Verbindung erstellt. Kanäle werden für die Kommunikation zwischen Anwendungen und dem RabbitMQ-Server verwendet.

Warteschlange deklarieren

Queues spielen eine entscheidende Rolle bei der Handhabung großer Nachrichtenpuffer und bieten einen Puffermechanismus in verteilten Systemen. Hier ist die QueueDeclare-Methode für diesen Zweck:

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

Der Code deklariert eine Queue namens "hello" mit bestimmten Eigenschaften:

• durable: false - Die Queue überlebt keinen Broker-Neustart.
• exclusive: false - Die Queue kann von anderen Verbindungen verwendet werden.
• autoDelete: false - Die Queue wird nicht gelöscht, wenn der letzte Konsument abmeldet.
• arguments: Zusätzliche Queue-Argumente (in diesem Fall auf null gesetzt).

Vorbereitung der Nachrichtendaten

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

Eine einfache Nachricht, "Hello World!", wird vorbereitet, und ihre binäre Darstellung (UTF-8-kodiert) wird in der body-Variable gespeichert.

Veröffentlichung der Nachricht

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

Die BasicPublish-Methode wird verwendet, um die Nachricht an den angegebenen Exchange zu veröffentlichen ("string.Empty" zeigt den Standard-Exchange an) mit dem Routing-Schlüssel "hello". Der basicProperties-Parameter ist auf null gesetzt, und das body enthält die tatsächliche Nachricht.

Konsolenausgabe

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

Eine Nachricht wird im Konsolenfenster gedruckt, die angibt, dass die Nachricht gesendet wurde.

Warten auf Benutzereingaben

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

Die Anwendung wartet darauf, dass der Benutzer Enter drückt, bevor sie beendet wird. Dies ermöglicht das Veröffentlichen der Nachricht und stellt sicher, dass die Anwendung nicht sofort beendet wird.

Dieser Code richtet eine Verbindung zu einem RabbitMQ-Server ein, deklariert eine Queue, bereitet eine Nachricht vor, veröffentlicht die Nachricht in der angegebenen Queue und wartet dann auf Benutzereingaben, bevor er endet. RabbitMQ-Server können Nachrichten ebenfalls auf die gleiche Weise wie oben beschrieben empfangen. In diesem Kontext agiert der Server als Nachrichtenbroker.

1. Entkopplung von Microservices

RabbitMQ erleichtert die lose Kopplung zwischen Microservices. Jeder Microservice kann entweder als Produzent oder Konsument agieren, Nachrichten austauschen, um Kommunikation ohne direkte Abhängigkeiten zu erreichen.

2. die Verarbeitung von Hintergrundaufträgen

Verwenden Sie RabbitMQ zur Verarbeitung von Hintergrundaufgaben. Produzenten schieben Aufgaben in eine Queue, und Konsumenten (Arbeiter) verarbeiten diese Aufgaben asynchron, um eine effiziente Ressourcennutzung sicherzustellen.

3. ereignisgesteuerte Architekturen

Implementieren Sie ereignisgesteuerte Architekturen, bei denen Komponenten über Ereignisse kommunizieren. Ereignisse werden produziert und konsumiert, was dynamische und ansprechbare Systeme ermöglicht.

4. die Skalierung von Anwendungen

RabbitMQ unterstützt die horizontale Skalierung von Anwendungen, indem es Workloads auf mehrere Instanzen verteilt. Es stellt eine effiziente Ressourcennutzung sicher und erhält die Systemzuverlässigkeit aufrecht.

Erzeugung einer PDF-Datei aus HTML

Ein PDF aus HTML mit IronPDF zu erstellen, ist mit IronPDF einfach. Hier ist der Quellcode eines einfachen HTML-String-in-PDF-Beispiels:

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

Weitere PDF-bezogene Funktionalitäten in C# mit IronPDF finden Sie auf dieser IronPDF-Codebeispiele-Seite.