AMQP extension wrapper to communicate with RabbitMQ server. Based on php-amqplib/php-amqplib.
The preferred way to install this extension is through composer.
Either run
$ php composer.phar require webtoucher/yii2-amqp "*"
or add
"webtoucher/yii2-amqp": "*"
to the require
section of your composer.json
file.
Add the following in your console config:
return [
...
'components' => [
...
'amqp' => [
'class' => 'rooooodik\amqp\components\Amqp',
'host' => '127.0.0.1',
'port' => 5672,
'user' => 'your_login',
'password' => 'your_password',
'vhost' => '/',
],
...
],
...
'controllerMap' => [
...
'rabbit' => [
'class' => 'rooooodik\amqp\controllers\AmqpListenerController',
'interpreters' => [
'my-exchange' => 'app\components\RabbitInterpreter', // interpreters for each exchange
],
'exchange' => 'my-exchange', // default exchange
],
...
],
...
];
Add messages interpreter class @app/components/RabbitInterpreter
with your handlers for different routing keys:
<?php
namespace app\components;
use rooooodik\amqp\components\AmqpInterpreter;
class RabbitInterpreter extends AmqpInterpreter
{
/**
* Interprets AMQP message with routing key 'hello_world'.
*
* @param array $message
*/
public function readHelloWorld($message)
{
// todo: write message handler
$this->log(print_r($message, true));
}
}
Just run command
$ php yii rabbit
to listen topics with any routing keys on default exchange or
$ php yii rabbit my_routing_key
to listen topics with one routing key.
$ php yii rabbit my_routing_key direct --exchange=my_exchange
to listen direct messages on selected exchange.
Run command
$ php yii rabbit my_routing_key direct --noAck=true
to enable auto acknowledge.
Also you can create controllers for your needs. Just use for your web controllers class
rooooodik\amqp\controllers\AmqpConsoleController
instead of yii\web\Controller
and for your console controllers
class rooooodik\amqp\controllers\AmqpConsoleController
instead of yii\console\Controller
. AMQP connection will be
available with property connection
. AMQP channel will be available with property channel
.