Using RabbitMQ in Laravel

1. Install packages

- Install RabbitMQ Queue driver for Laravel

composer require vladimir-yuldashev/laravel-queue-rabbitmq

- Install PHP client for RabbitMQ to work between PHP and rabbitmq

composer require enqueue/amqp-bunny

2. Update queue.php config

'connections' => [

 

'rabbitmq' => [

'driver' => 'rabbitmq',

/*

* Set to "horizon" if you wish to use Laravel Horizon.

*/

'worker' => env('RABBITMQ_WORKER', 'default'),

'dsn' => env('RABBITMQ_DSN', null),

/*

* Could be one a class that implements \Interop\Amqp\AmqpConnectionFactory for example:

* - \EnqueueAmqpExt\AmqpConnectionFactory if you install enqueue/amqp-ext

* - \EnqueueAmqpLib\AmqpConnectionFactory if you install enqueue/amqp-lib

* - \EnqueueAmqpBunny\AmqpConnectionFactory if you install enqueue/amqp-bunny

*/

// 'factory_class' => \Enqueue\AmqpBunny\AmqpConnectionFactory::class,

'host' => env('RABBITMQ_HOST', '127.0.0.1'),

'port' => env('RABBITMQ_PORT', 5672),

'vhost' => env('RABBITMQ_VHOST', '/'),

'login' => env('RABBITMQ_LOGIN', 'guest'),

'password' => env('RABBITMQ_PASSWORD', 'guest'),

'queue' => env('RABBITMQ_QUEUE', 'default'),

'options' => [

'exchange' => [

'name' => env('RABBITMQ_EXCHANGE_NAME'),

/*

* Determine if exchange should be created if it does not exist.

*/

'declare' => env('RABBITMQ_EXCHANGE_DECLARE', true),

/*

* Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html

*/

// 'type' => env('RABBITMQ_EXCHANGE_TYPE', \Interop\Amqp\AmqpTopic::TYPE_DIRECT),

'passive' => env('RABBITMQ_EXCHANGE_PASSIVE', false),

'durable' => env('RABBITMQ_EXCHANGE_DURABLE', true),

'auto_delete' => env('RABBITMQ_EXCHANGE_AUTODELETE', false),

'arguments' => env('RABBITMQ_EXCHANGE_ARGUMENTS'),

],

'queue' => [

/*

* Determine if queue should be created if it does not exist.

*/

'declare' => env('RABBITMQ_QUEUE_DECLARE', true),

/*

* Determine if queue should be binded to the exchange created.

*/

'bind' => env('RABBITMQ_QUEUE_DECLARE_BIND', true),

/*

* Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html

*/

'passive' => env('RABBITMQ_QUEUE_PASSIVE', false),

'durable' => env('RABBITMQ_QUEUE_DURABLE', true),

'exclusive' => env('RABBITMQ_QUEUE_EXCLUSIVE', false),

'auto_delete' => env('RABBITMQ_QUEUE_AUTODELETE', false),

'arguments' => env('RABBITMQ_QUEUE_ARGUMENTS'),

],

],

/*

* Determine the number of seconds to sleep if there's an error communicating with rabbitmq

* If set to false, it'll throw an exception rather than doing the sleep for X seconds.

*/

'sleep_on_error' => env('RABBITMQ_ERROR_SLEEP', 5),

/*

* Optional SSL params if an SSL connection is used

* Using an SSL connection will also require to configure your RabbitMQ to enable SSL. More details can be founds here: https://www.rabbitmq.com/ssl.html

*/

'ssl_params' => [

'ssl_on' => env('RABBITMQ_SSL', false),

'cafile' => env('RABBITMQ_SSL_CAFILE', null),

'local_cert' => env('RABBITMQ_SSL_LOCALCERT', null),

'local_key' => env('RABBITMQ_SSL_LOCALKEY', null),

'verify_peer' => env('RABBITMQ_SSL_VERIFY_PEER', true),

'passphrase' => env('RABBITMQ_SSL_PASSPHRASE', null),

],

],

        

],

3. Update .env

##############################

QUEUE_CONNECTION=rabbitmq

RABBITMQ_HOST=rabbitmq

RABBITMQ_PORT=5672

RABBITMQ_VHOST=/

RABBITMQ_LOGIN=guest

RABBITMQ_PASSWORD=guest

RABBITMQ_QUEUE=hello-world

RABBITMQ_EXCHANGE_NAME=default

RABBITMQ_EXCHANGE_DECLARE=

RABBITMQ_EXCHANGE_TYPE=

RABBITMQ_EXCHANGE_PASSIVE=

RABBITMQ_EXCHANGE_DURABLE=

RABBITMQ_EXCHANGE_AUTODELETE=

RABBITMQ_EXCHANGE_ARGUMENTS=default

RABBITMQ_QUEUE_DECLARE=

RABBITMQ_QUEUE_DECLARE_BIND=

RABBITMQ_QUEUE_PASSIVE=

RABBITMQ_QUEUE_DURABLE=

RABBITMQ_QUEUE_EXCLUSIVE=

RABBITMQ_QUEUE_AUTODELETE=

RABBITMQ_QUEUE_ARGUMENTS=default

RABBITMQ_ERROR_SLEEP=5

RABBITMQ_SSL=

RABBITMQ_SSL_CAFILE=

RABBITMQ_SSL_LOCALCERT=

RABBITMQ_SSL_LOCALKEY=

RABBITMQ_SSL_VERIFY_PEER=

RABBITMQ_SSL_PASSPHRASE=

4. Create HelloWorldJob

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;

use Illuminate\Contracts\Queue\ShouldBeUnique;

use Illuminate\Contracts\Queue\ShouldQueue;

use Illuminate\Foundation\Bus\Dispatchable;

use Illuminate\Queue\InteractsWithQueue;

use Illuminate\Queue\SerializesModels;

use Illuminate\Support\Facades\Log;

class HelloWorldJob implements ShouldQueue

{

use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

/**

* Create a new job instance.

*

* @return void

*/

protected $data;

public function __construct($data)

{

$this->data = $data;

}

/**

* Execute the job.

*

* @return void

*/

public function handle()

{

//

Log::info('Hello world job');

Log::info($this->data);

sleep(25);

}

}

* Call job

Route::get('/rabbitmq', function() {

HelloWorldJob::dispatch(['data' => 'Hello World']);

});

5. Show result

- access: http://localhost:15672/#/queues/%2F/default 

Thank you