RabbitMQ em C# (Como funciona para desenvolvedores)

Conceitos-chave

1. Produtor: O componente responsável por enviar mensagens para uma exchange do RabbitMQ.
2. Exchange: Um mecanismo de roteamento que determina como as mensagens devem ser distribuídas para as filas. Os tipos comuns incluem direct, fanout, topic e headers.
3. Fila: Um buffer que armazena mensagens enviadas pelos produtores até que sejam consumidas por um consumidor.
4. Consumidor: O componente responsável por receber e processar mensagens de uma fila do RabbitMQ.
5. Vinculação: Define a relação entre uma exchange e uma fila, especificando como as mensagens devem ser roteadas.

Instalação do cliente RabbitMQ .NET

Instale a biblioteca cliente RabbitMQ através do Console do Gerenciador de Pacotes NuGet :

Install-Package RabbitMQ.Client

Ou você pode usar o NuGet Package Manager for Solutions para procurar e instalar o RabbitMQ.Client:

Configurando a Fábrica de Conexões

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

O trecho de código acima cria um objeto ConnectionFactory com o valor HostName definido como "localhost". Este objeto é usado para configurar a conexão com o servidor RabbitMQ.

Criando uma conexão e um 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()

Uma conexão com o servidor RabbitMQ é estabelecida usando o método CreateConnection do ConnectionFactory. Em seguida, um canal é criado usando o método de conexão CreateModel. Os canais são usados ​​para comunicação entre aplicativos e o servidor RabbitMQ.

Declarando uma fila

As filas desempenham um papel crucial no gerenciamento de grandes buffers de mensagens e no fornecimento de um mecanismo de buffer em sistemas distribuídos. Aqui está o método QueueDeclare para essa finalidade:

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

O código declara uma fila chamada "hello" com propriedades específicas:

• durable: false - A fila não sobreviverá a uma reinicialização do broker.
• exclusive: false - A fila pode ser usada por outras conexões.
• autoDelete: false - A fila não será excluída quando o último consumidor cancelar a inscrição.
• arguments: Argumentos adicionais da fila (definidos como null neste caso).

Preparando os dados da mensagem

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

Uma mensagem simples, "Olá Mundo!", é preparada e sua representação binária (codificada em UTF-8) é armazenada na variável body.

Publicando a mensagem

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

O método BasicPublish é usado para publicar a mensagem na exchange especificada ("string.Empty" indica a exchange padrão) com a chave de roteamento "hello". O parâmetro basicProperties é definido como null, e o parâmetro body contém a mensagem propriamente dita.

Saída do console

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

Uma mensagem é exibida na janela do console indicando que a mensagem foi enviada.

Aguardando entrada do usuário

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

O aplicativo aguarda que o usuário pressione Enter antes de sair. Isso permite que a mensagem seja publicada e garante que o aplicativo não seja encerrado imediatamente.

Este código estabelece uma conexão com um servidor RabbitMQ, declara uma fila, prepara uma mensagem, publica a mensagem na fila especificada e, em seguida, aguarda a entrada do usuário antes de encerrar. Os servidores RabbitMQ também podem receber mensagens da mesma forma descrita acima. Nesse contexto, o servidor atua como um intermediário de mensagens.

1. Desacoplamento de microsserviços

O RabbitMQ facilita o baixo acoplamento entre microsserviços. Cada microsserviço pode atuar como produtor ou consumidor, trocando mensagens para estabelecer comunicação sem dependências diretas.

2. Processamento de tarefas em segundo plano

Utilize o RabbitMQ para implementar o processamento de tarefas em segundo plano. Os produtores inserem tarefas em uma fila, e os consumidores (trabalhadores) processam essas tarefas de forma assíncrona, garantindo a utilização eficiente dos recursos.

3. Arquiteturas Orientadas a Eventos

Implemente arquiteturas orientadas a eventos, onde os componentes se comunicam por meio de eventos. Os eventos são produzidos e consumidos, possibilitando sistemas dinâmicos e responsivos.

4. Escalando Aplicações

O RabbitMQ auxilia na escalabilidade horizontal de aplicações, distribuindo as cargas de trabalho por várias instâncias. Isso garante a utilização eficiente dos recursos e mantém a confiabilidade do sistema.

Gerando um PDF a partir de HTML

Criar um PDF a partir de HTML com o IronPDF é muito simples. Aqui está o código-fonte de um exemplo básico de conversão de uma string HTML para 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 obter mais funcionalidades relacionadas a PDF em C# usando o IronPDF, visite esta página de exemplos de código do IronPDF .