Implementing RabbitMQ🐰, For Point to Point Communication 🚀

using RabbitMQ.Models;
using RabbitMQ.Client;
using Microsoft.Extensions.Configuration;
using System.Text;

public void Produce(string message)
{
    var factory = new ConnectionFactory()
    {
        Uri = new Uri(configuration["Rabbit-MQ-AMPQ"]) // Through DI
    };

    using (var conn = factory.CreateConnection())
    {
        using (var channel = conn.CreateModel())
        {
            channel.QueueDeclare(queue: "messages_share",
                                 durable: false,
                                 exclusive: false,
                                 autoDelete: false,
                                 arguments: null);

            var body = Encoding.UTF8.GetBytes(message);
            channel.BasicPublish(exchange: "",
                                 routingKey: "messages_share",
                                 basicProperties: null,
                                 body: body);

            Console.WriteLine("[x] Sent {0}", message);
        }
    }
}

Explanation of Producer Code

Create a connection, open a channel, and create the queue. Send the message to the queue. After completion of the task, auto-dispose of the connections.

Consumer, In Application 2

/* 
using Microsoft.Extensions.Configuration;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Text;
*/
   
public void Consume()
{
    var factory = new ConnectionFactory()
    {
        Uri = new Uri(configuration["Rabbit-MQ-AMPQ"]) //Through DI
    };

    var conn = factory.CreateConnection();

    var channel = conn.CreateModel();

    channel.QueueDeclare(queue: "messages_share",
                         durable: false,
                         exclusive: false,
                         autoDelete: false,
                         arguments: null);

    var consumer = new EventingBasicConsumer(channel);

    consumer.Received += (ch, ea) =>
    {
        var body = Encoding.UTF8.GetString(ea.Body.ToArray());
        Console.WriteLine(body + "\n");
        channel.BasicAck(ea.DeliveryTag, false);
    };

    channel.BasicConsume("messages_share", false, consumer);
}

Explanation of Consumer Code

Connect to the channel, and declare the queue (this helps us to ensure that the queue exists). Subscribe to the channel. When a message is received, then perform logic on that message. Do not close the connection, as the channel is open for messages to arrive.

Execution Flow

1. Call the Consumer function once, only at the startup of the application to open the communication channel. The channel will be visible in the RabbitMQ Channels Admin UI.
   
2. Now send the execution call from the producer function.
3. The consumer will automatically catch this as the channel is open.
4. Monitor the activity in the Queues Section of RabbitMQ.

Overall communication will look like this, the image should be self-explanatory.

This image shows that the message “Hello There” was fired from Application 1. This message went to the RabbitMQ server. The Application 2 had subscribed through a Received event. The message was forwarded from RabbitMQ to Application 2 as part of the subscription. This Application 2 Channel was open so it was able to receive the message at the same time.

Summary

We covered Message Broker, About RabbitMQ, and Implement RabbitMQ in .NET for Point-to-Point Communication.

Please feel free to share your thoughts, and comments and share your knowledge for improvement.