This content originally appeared on Twilio Blog and was authored by Kenneth Ekandem
As your software applications become complex, you may need to decouple some parts of them into smaller components to reduce your applications' dependency on them. That way, if any of these components fail, your applications don’t fail with them. Apart from that, having all your application’s components in one place means that when one part of it is updated, the whole application needs to be redeployed.
However, after decoupling applications into components, you will need to worry about how they will communicate. Some of the ways to facilitate communication between components include using APIs (e.g., REST and GraphQL), RPC (Remote Procedure Calls), and Message Brokers (e.g., RabbitMQ and Kafka).
In this tutorial, we will focus on the last one. Our broker of choice will be RabbitMQ.
What is RabbitmQ?
RabbitMQ is a message broker that provides ways to create queues for connected applications to exchange messages. In a typical RabbitMQ application, you have queues, producers, and consumers.
The queue serves as the underlying pipeline between the producers and the consumer, and a producer sends a message to a queue for the consumer to accept, remove from the queue, and process. When the task/process has been completed, the broker is notified to take the message out of the queue.
In this tutorial, you will learn how to decouple a part of a Laravel application into a worker (a PHP process that runs in the background) and how to communicate between the worker and the parent application. To do this we will build a basic Laravel application that will send a message from the web browser and get a response on the worker’s console.
Why use RabbitMQ?
RabbitMQ comes in handy in so many ways to simplify the development process. For example:
- Task Queues: RabbitMQ can be used as a task queue to manage background jobs. When a task is submitted to the queue, RabbitMQ stores it until a worker process is available to execute it. With this approach, tasks are not skipped or dropped till a response is received from the consumer.
- Event-Driven Architecture: RabbitMQ can be used to implement an event-driven architecture, where applications communicate with each other by publishing and subscribing (pub/sub) to events. This allows for a loosely-coupled system where components can be added or removed without affecting the rest of the system.
- Micro-services Communication: RabbitMQ can be used as a communication channel between micro-services. In a micro-service architecture, each service performs a specific task, with communication between services being critical. RabbitMQ provides a reliable and scalable way for this communication to be possible, with no noticeable delay in response.
- Distributed Systems: RabbitMQ can be used to build distributed systems. In a distributed system, different nodes need to communicate with each other. RabbitMQ provides a way to exchange messages between nodes, ensuring reliability and consistency.
- Internet of Things (IoT) Messaging: RabbitMQ can be used to connect IoT devices. IoT devices generate a lot of data, and RabbitMQ can help manage that data by providing a messaging system that allows for efficient communication between devices and applications.
- Chat Applications: RabbitMQ can be used in chat applications to deliver messages between users in real-time. RabbitMQ provides a scalable and reliable messaging system that can handle large volumes of messages and users.
Prerequisites
Create a Laravel application
For the installation, we’ll be using Composer, but before we start, let’s create a Laravel project, by running the command below.
composer create-project laravel/laravel rabbitmq-tut
Next, step into the folder and start the application by running the commands below.
cd rabbitmq-tut
php artisan serve
If everything went well, you should have a server running at http://localhost:8000 serving the Laravel template page.
Now, let’s add php-amqplib to our project, so that PHP can communicate with RabbitMQ. To do that, run the command below.
composer require php-amqplib/php-amqplib
For the purpose of this article, we will use CloudAMQP as the default RabbitMQ server. Navigate to the CloudAMQP console. Below is what the dashboard looks like without any instances.
The next thing we’ll do is create a new RabbitMQ instance. To do that, click the Create New Instance button on the far right hand side and fill out the form that will be presented.
After that, click on the newly created instance to retrieve the server details, as can be seen below. In this instance, it was named laravel_rabbitmq.
Next, we connect the php-amqplib client to this instance. To do that, add the following variables to the .env file in the project's top-level directory.
MQ_HOST="CLOUDAMQP_HOST"
MQ_PORT="CLOUDAMQP_PORT"
MQ_USER="CLOUDAMQP_USER"
MQ_PASS="CLOUDAMQP_PASS"
MQ_VHOST="CLOUDAMQP_VHOST"
The variables listed are the AMPQP host, port, user, password, and vhost respectively. These keys can be retrieved from the CloudAMQP instance dashboard.
Check out this post to learn more about working with environment variables in PHP.
Create a RabbitMQ service
Now that the application has been scaffolded, the next thing we’ll have to do is create a service to handle RabbitMQ operations. Create a new directory named app/Services and in that directory create a new file named RabbitMQService.php and add the content below to it.
<?php
namespace App\Services;
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Connection\AMQPSSLConnection;
use PhpAmqpLib\Message\AMQPMessage;
class RabbitMQService
{
public function publish($message)
{
$connection = new AMQPStreamConnection(env('MQ_HOST'), env('MQ_PORT'), env('MQ_USER'), env('MQ_PASS'), env('MQ_VHOST'));
$channel = $connection->channel();
$channel->exchange_declare('test_exchange', 'direct', false, false, false);
$channel->queue_declare('test_queue', false, false, false, false);
$channel->queue_bind('test_queue', 'test_exchange', 'test_key');
$msg = new AMQPMessage($message);
$channel->basic_publish($msg, 'test_exchange', 'test_key');
echo " [x] Sent $message to test_exchange / test_queue.\n";
$channel->close();
$connection->close();
}
public function consume()
{
$connection = new AMQPStreamConnection(env('MQ_HOST'), env('MQ_PORT'), env('MQ_USER'), env('MQ_PASS'), env('MQ_VHOST'));
$channel = $connection->channel();
$callback = function ($msg) {
echo ' [x] Received ', $msg->body, "\n";
};
$channel->queue_declare('test_queue', false, false, false, false);
$channel->basic_consume('test_queue', '', false, true, false, false, $callback);
echo 'Waiting for new message on test_queue', " \n";
while ($channel->is_consuming()) {
$channel->wait();
}
$channel->close();
$connection->close();
}
}
This service will be in charge of publishing and consuming messages from the job queue. To fully understand the code above, you will need to understand the RabbitMQ message flow. It works something like this:
- The producer publishes a message to an exchange.
- The exchange receives the message and routes the message to the appropriate queue. The exchange also takes message attributes into account, such as the routing key, depending on the exchange type.
- For the exchange to communicate with the queue, a binding must be created between the two of them. Then the exchange routes the message into the queues depending on any provided message attributes.
- The routed messages will stay in the queue until they are handled by a consumer.
- The consumer handles the message and marks it as received/consumed.
Next, we create a consumer command that will listen to our queue and consume it when there’s a new message. Run the command below to generate a new command.
php artisan make:command MQConsumerCommand
Now, add the following code to the app/Console/Commands/MQConsumerCommand.php file.
<?php
namespace App\Console\Commands;
use Illuminate\Console\Command;
use App\Services\RabbitMQService;
class MQConsumerCommand extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'mq:consume';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Consume the mq queue';
/**
* Execute the console command.
*/
public function handle(): void
{
$mqService = new RabbitMQService();
$mqService->consume();
}
}
When this command is run, it will trigger the RabbitMQService's consume() function, which will in turn listen for incoming messages from the queue named test_queue.
Next, to the consumer. In the consumer application, we will create a form to publish out test_queue. To do that, update resources/views/welcome.blade.php to match the code below.
<!DOCTYPE html>
<html lang="{{ str_replace('_', '-', app()->getLocale()) }}">
<head>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<title>Rabbitmq-tut</title>
<!-- Fonts -->
<link rel="preconnect" href="https://fonts.bunny.net">
<link href="https://fonts.bunny.net/css?family=figtree:400,600&display=swap" rel="stylesheet" />
<script src="https://cdn.tailwindcss.com"></script>
</head>
<body class="antialiased">
<div class="h-[100vh] flex justify-center items-center ">
<form action="/api/message" method="post" class="w-[700px]">
<textarea class="border border-gray-300 w-full rounded-[10px] min-h-[300px] p-4" placeholder="enter message" name="message" id="message"></textarea>
<button class="bg-blue-500 px-10 py-[12px] rounded-[10px] text-white mt-2">Send message</button>
</form>
</div>
</body>
</html>
Next, add the following route definition to the end of routes/api.php.
Route::post("/message", function (Request $request) {
$message = $_POST['message'];
$mqService = new \App\Services\RabbitMQService();
$mqService->publish($message);
return view('welcome');
});
Test that the code works
To test, we will start the consumer command, then navigate to the home page, and then send our custom message. If everything works, a message will be sent to the consumer console.
Start the application again, by running the following command.
php artisan serve
Then, in a new terminal window or tab, run the command below to start the consumer.
php artisan mq:consume
You will get a message like the one below.
Now, navigate to the home page at http://localhost:8000 and send a custom message. You will see this before sending the message.
And you will see the following after sending the message.
Take note of the test at the top right. It shows that the message is sent.
Now let’s take a look at our consumers. Here’s what it should print out.
If all went well, you should get something similar to this. Congratulations, you have a fully working pub/sub in Laravel. Depending on the message sent, you can now perform the operation you want in your consumer.
That's been a quick introduction to RabbitMQ and how to use it with Laravel
In this tutorial, we went through how to install RabbitMQ on a Laravel project. We also learned how to connect to a remote client by leveraging the free plan of CloudAMQP to build a fully working pub/sub RabbitMQ app. I hope you’ve learned how to use RabbitMQ and will use it on your next project. If you have any questions, let me know in the comments below.
Kenneth Ekandem is a full-stack developer from Nigeria currently in the blockchain space, but interested in learning everything computer science has to offer. He'd love to go to space one day and own his own vlogging channel to teach the next generation of programmers.
This content originally appeared on Twilio Blog and was authored by Kenneth Ekandem
Kenneth Ekandem | Sciencx (2023-03-24T08:40:18+00:00) What Is RabbitMQ and How Do You Use It With Laravel?. Retrieved from https://www.scien.cx/2023/03/24/what-is-rabbitmq-and-how-do-you-use-it-with-laravel/
Please log in to upload a file.
There are no updates yet.
Click the Upload button above to add an update.