Asynchronous Communications Using RabbitMQ Message Broker

The rabbitmq_management plugin is a combination of the following plugins. All of the following plugins will be enabled when you execute the above command,

• mochiweb
• web machine
• rabbitmq_web_dispatch
• amqp_client
• rabbitmq_management_agent
• rabbitmq_management

After this, just type http://localhost:15672/. It will open the following RabbitMQ web page.

By default, RabbitMQ runs on 15672 port No.

Now, the default user and password for this is "guest". After logging in with the Userid and Password, it will take you to the portal where you can check your Queues, create Queues, delete Queues, etc.

Now, let's start Visual Studio, and create a Windows Application project. Now, go to the NuGet Package console and install the RabbitMQ Client.

And, here I have designed my Form as below.

Now, Under the Submit button click, and write the following code.

private void button1_Click(object sender, EventArgs e)
{
    var factory = new ConnectionFactory()
    {
        HostName = "localhost"
    };

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

        string message = textBox1.Text;
        var body = Encoding.UTF8.GetBytes(message);

        channel.BasicPublish(exchange: "",
                             routingKey: "MyQueue",
                             basicProperties: null,
                             body: body);
    }

    MessageBox.Show("Message sent successfully.");
}

Note. To work with RabbitMQ, we need the following Namespace.

using RabbitMQ.Client;

Code Explanation

First, we are creating a connection to the RabbitMQ Server. Here, we are connecting to a broker on the local machine; so we put the localhost.

If we wanted to connect to a broker on a different machine, we'd simply specify its name or IP Address here. So mainly, for the connection, it will take 3 parameters.

1. Server Address
2. Username
3. Password
4. Creating a channel for communication between UI and Server.
5. Creating a queue for storing messages.

After that, we are simply collecting the messages from UI and sending to the Server. Now, just try to send some messages, and let's check the queue.

Here, if you want to check the MyQueue by double click on it, it will take you to a page where you can see your messages in the queue.

Here is the overview of the MyQueue.

So far, we have successfully sent the message from the sender to the RabbitMQ Server. In our next part, we will learn how to retrieve these messages by creating a client.

I hope you understand the basics of RabbitMQ message broker. If you have any doubts, you can give your feedback so that we can try to explain it to you more clearly.