PHP? ?? ????? ? ??? ?? RabbitMQ ? Kafka ? ?? ??? ? ???? ???? ??? ?? ? ??? ?????. 1. PHP-AMQPLIB ????? ?? AMQP ??? ???? RabbitMQ? ???? ???? ???? ???? ????? ?????. 2. PHP-RDKAFKA ?????? ???? PHP? Kafka? ???? ??? ?? ???? ???? ???? ??? ??????. 3. ??? ?? ? ? ???? ???? ?? ?? ? ????????? ?? ?? ?, ? ?? ???? ? ??? ???? ?? ??? ?????. 4. RabbitMQ?? ACK/Nack? ??? ??? ???? ??? ??? ? ??? Kafka? ???? ???? ???????. 5. ?? ???? CLI ????? ???? ???? ????, ?? ?? ??? ????, ???? ??, ?? ?? ? ??? ??? ?????? ???? ????? ?? ????.

PHP? PHP ?? ????? ???? ???? ?? ? ? ??? ????? ????? ? ??? ?? Rabbitmq ? Kafka? ?? ??? ??? ???? ?????. ??? ??? ????? ?? ????? ?? ??? ???? ???? ?? ???? ???? ?????.

PHP? ???? ??? ???? ???? ??? ??? ????.

php? ?? Rabbitmq ??

RabbitMQ? AMQP (Advanced Message Queuing Protocol)? ??? ?? ??? ????? ???? ?? ???? ??? ??????. PHP? php-amqplib ????? ?? ext-bcmath ?? ?? amqp PECL ??? ???? RabbitMQ? ?? ??? ? ????.

?? ?? ?? :

• ????? ?? ( composer require php-amqplib/php-amqplib )
• RabbitMQ ??? ??????
• ???? ??????
• ???? ????? ?????

?? ??, php-amqplib ???? ???? ???? ??? ??? ????.

 phpamqplib \ connection \ amqpStreamConnection? ?????.
phpamqplib \ message \ amqpmessage? ??????.

$ connection = new AMQPStReamConnection ( 'localhost', 5672, 'Guest', 'Guest');
$ ?? = $ connection-> ?? ();

$ ??-> queue_declare ( 'task_queue', false, true, false, false);

$ msg = ??? amqpmessage ( 'Hello World!');
$ ??-> basic_publish ($ msg, '', 'task_queue');

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

??? ???? ???? ???? ?? ??? ???? ?? ?????.

Kafka ?? PHP

Apache Kafka? ???? ?? ?? ??? ????? ? ?????. PHP? Kafka ???? ????? ?? ???? ??? ???? php-rdkafka ? ?? ?????? ?? ??? ?????.

PHP?? Kafka? ???? ?? :

• PECL? ?? php-rdkafka ?? ( pecl install rdkafka )
• ??? ?? ???? ???? ????
• ???? ???? ???? ????

Kafka ??? ???? ??? ? :

 $ conf = ??? rdkafka \ conf ();
$ conf-> set ( 'metadata.broker.list', 'localhost : 9092');

$ producer = ??? rdkafka \ producer ($ conf);
$ topic = $ producer-> newtopic ( "??? ??");

$ topic-> produce (rd_kafka_partition_ua, 0, "??? ??? ????");

$ producer-> flush (10000);

???? ??? ?? ??? ???????.

?? ?? ? ??

PHP?? ??? ???? ?? ? ?? ??? ???? ???? ?? ?????.

? ?? ? :

• ???? ?? ?? ? ????? ??? ?? ??????
• ??? ????? ?? ?? ??? (DLQ)? ??????
• ?? ? ??? ?? ??? ??????
• ?? ??? ??? ?? ?? ?? ? ?? ??? ?????

?? ??, RabbitMQ??? ??? ?? ?? ??? ???? ???? ???? ????? ??? ? ????.

 $ ??-> basic_consume ( 'task_queue', '', false, false, false, false, function ($ msg) {
    ???? {
        // ???? ???
        $ msg-> ack ();
    } catch (?? $ e) {
        // ?? ??
        $ msg-> nack (true); // ?? ?? DLQ? ?????
    }
});

Kafka??? RabbitMQ? ?? ?? ?? ????? ???? ?? ? ???? ???? ???????.

?? ?? ??

PHP? ?? ??? ???? ?? ???? ????? ?? ???? ????? ?? ?? ?? ??? ?????.

• Supervisord ?? ??? ??? ???? CLI ????? ???? ??????.
• ???? ?? ???? ??? ??????
• ???? ?? ??? ??
• ?? ?? ?????? ??? ??? ???????

?? PHP? ??? ??? ?? ????? ????? ?? ?? ??? ??? ??? ?????? ?? ??????.

????? ?? ??.

? ??? PHP? ??? ??? ??? (? : Rabbitmq, Kafka)? ??? ??????? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!