Ի՞նչ է RabbitMQ-ն։

RabbitMQ — դա հաղորդագրությունների բրոքեր է, որը իրականացնում է AMQP (Advanced Message Queuing Protocol) պրոտոկոլը: Այն թույլ է տալիս հավելվածներին ասինխրոն կերպով փոխազդել, ուղարկելով և ստանալով հաղորդագրություններ կենտրոնական համակարգի միջոցով: RabbitMQ ապահովում է հուսալի առաքում, երթևեկության ուղղում և հաղորդագրությունների պահպանում:

Հիմնական բաղադրիչներ:

• Արտադրող (Producer): Ուղարկում է հաղորդագրություններ RabbitMQ-ին:
• Փոխանակիչ (Exchange): Ստանում է հաղորդագրություններ արտադրողներից և ուղղորդում դրանք մեկ կամ մի քանի հերթերի՝ երթևեկության կանոնների հիման վրա:
• Հերթ (Queue): Պահպանում է հաղորդագրությունները մինչև որ դրանք վերցնեն սպառողները:
• Սպառող (Consumer): Ստանում է հաղորդագրություններ հերթերից՝ մշակելու համար:

Փոխանակիչների տեսակներ:

• Direct: Ուղարկում հաղորդագրություններ այն հերթերին, որտեղ երթևեկության բանալին հստակ համընկնում է հերթի կապի բանալու հետ:
• Fanout: Ուղարկում հաղորդագրություններ բոլոր կապակցված հերթերին՝ անտեսելով երթևեկության բանալին:
• Topic: Ուղարկում հաղորդագրություններ երթևեկության բանալիի մասնակի համընկնումով՝ կապի բանալիի ձևանմուշի հետ (օգտագործելով * և # նշանները):
• Headers: Ուղարկում հաղորդագրություններ՝ հիմնվելով հաղորդագրության վերնագրերի վրա, ոչ թե երթևեկության բանալու վրա:

PHP-ում կիրառումը:

• Աշխատանքների հետաձգված մշակումը: օրինակ՝ էլփոստ ուղարկում, հաշվետվությունների ստեղծում, պատկերների մշակում:
• Միկրոսերվիսային ճարտարապետություն: Սպառողների միջև ասինխրոն փոխազդեցություն:
• Անցումային համակարգեր: Մեծ թվով իրադարձությունների մշակումը:
• Բեռի հավասարակշռում: Աշխատանքների բաշխում մի քանի աշխատողների միջև:

Նմուշ հաղորդագրության ուղարկում php-amqplib գրադարանի միջոցով:

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

$channel->exchange_declare('my_exchange', 'direct', false, false, false);
$channel->queue_declare('my_queue', false, false, false, false);
$channel->queue_bind('my_queue', 'my_exchange', 'my_routing_key');

$data = 'Hello, RabbitMQ!';
$msg = new AMQPMessage($data);

$channel->basic_publish($msg, 'my_exchange', 'my_routing_key');

echo " [x] Ուղարկված '" . $data . "'\n";

$channel->close();
$connection->close();

Հաղորդագրության ստացման օրինակ:

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

$channel->queue_declare('my_queue', false, false, false, false);

echo " [*] Սպասում հաղորդագրությունների համար: Դուրս գալու համար սեղմեք CTRL+C\n";

$callback = function ($msg) {
    echo " [x] Ստացվեց '" . $msg->body . "'\n";
};

$channel->basic_consume('my_queue', '', false, true, false, false, $callback);

while ($channel->is_consuming()) {
    $channel->wait();
}

$channel->close();
$connection->close();

RabbitMQ ապահովում է սխալների դիմացկունություն, ընդարձակելիություն և ճկունություն տարածված համակարգերի նախագծման համար։