RabbitMQ C# (Cómo Funciona para Desarrolladores)

Conceptos clave

1. Productor: El componente responsable de enviar mensajes a un intercambio de RabbitMQ.
2. Intercambio: Un mecanismo de enrutamiento que determina cómo deben distribuirse los mensajes a las colas. Tipos comunes incluyen directo, difusión, tópico y encabezados.
3. Cola: Un buffer que almacena mensajes enviados por los productores hasta que son consumidos por un consumidor.
4. Consumidor: El componente responsable de recibir y procesar mensajes de una cola de RabbitMQ.
5. Binding: Define la relación entre un intercambio y una cola, especificando cómo deben ser enrutados los mensajes.

Instalación del cliente .NET RabbitMQ

Instala la biblioteca Cliente RabbitMQ mediante el Administrador de Consola de Paquetes NuGet:

Install-Package RabbitMQ.Client

O puedes utilizar el Administrador de Paquetes NuGet para Soluciones para buscar e instalar RabbitMQ.Client:

Configuración de la fábrica de conexiones

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

El fragmento de código anterior crea un objeto ConnectionFactory con el HostName configurado a "localhost". Este objeto se utiliza para configurar la conexión con el servidor RabbitMQ.

Creación de una conexión y un canal

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

Se establece una conexión con el servidor RabbitMQ utilizando el método CreateConnection de ConnectionFactory. Luego, se crea un canal utilizando el método CreateModel de la conexión. Los canales se utilizan para la comunicación entre aplicaciones y el servidor RabbitMQ.

Declaración de una cola

Las colas juegan un papel crucial en el manejo de grandes buffers de mensajes y ofrecen un mecanismo de buffer en sistemas distribuidos. Aquí está el método QueueDeclare para este propósito:

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

El código declara una cola llamada "hello" con propiedades específicas:

• durable: false - La cola no sobrevivirá a un reinicio del agente.
• exclusive: false - La cola puede ser utilizada por otras conexiones.
• autoDelete: false - La cola no será eliminada cuando el último consumidor se desuscriba.
• arguments: Argumentos adicionales de la cola (establecidos en null en este caso).

Preparación de los datos del mensaje

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

Se prepara un mensaje simple, "Hello World!", y su representación binaria (codificada en UTF-8) se almacena en la variable body.

Publicación del mensaje

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

Se utiliza el método BasicPublish para publicar el mensaje al intercambio especificado ("string.Empty" indica el intercambio predeterminado) con la clave de enrutamiento "hello". El parámetro basicProperties se establece en null, y el body contiene el mensaje real.

Salida de consola

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

Se imprime un mensaje en la ventana de la consola indicando que el mensaje ha sido enviado.

A la espera de la opinión del usuario

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

La aplicación espera a que el usuario presione Enter antes de salir. Esto permite que el mensaje sea publicado y asegura que la aplicación no termine inmediatamente.

Este código establece una conexión con un servidor RabbitMQ, declara una cola, prepara un mensaje, publica el mensaje en la cola especificada, y luego espera la entrada del usuario antes de salir. Los servidores RabbitMQ también pueden recibir mensajes de la misma manera que se describió anteriormente. En este contexto, el servidor actúa como un corredor de mensajes.

1. Desacoplamiento de microservicios

RabbitMQ facilita el acoplamiento flojo entre microservicios. Cada microservicio puede actuar como productor o consumidor, intercambiando mensajes para lograr comunicación sin dependencias directas.

2. Procesamiento de trabajos en segundo plano

Utiliza RabbitMQ para implementar el procesamiento de tareas en segundo plano. Los productores introducen trabajos en una cola, y los consumidores (trabajadores) procesan estos trabajos asíncronamente, asegurando una utilización eficiente de los recursos.

3. Arquitecturas basadas en eventos

Implementa arquitecturas basadas en eventos donde los componentes se comunican a través de eventos. Los eventos son producidos y consumidos, permitiendo sistemas dinámicos y receptivos.

4. Escalado de aplicaciones

RabbitMQ ayuda a escalar aplicaciones horizontalmente distribuyendo cargas de trabajo a través de múltiples instancias. Asegura una utilización eficiente de los recursos y mantiene la fiabilidad del sistema.

Generar un PDF a partir de HTML

Crear un PDF desde HTML con IronPDF es sencillo con IronPDF. Aquí está el código fuente de un ejemplo básico de HTML String a 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")

Para más funcionalidades relacionadas con PDF en C# usando IronPDF, por favor visita esta página de Ejemplos de Código de IronPDF.