基于PHP使用rabbitmq实现消息队列

Posted 2020-08-21 代码之道

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了基于PHP使用rabbitmq实现消息队列相关的知识，希望对你有一定的参考价值。

1.从github上面获取AMQP基于php的实现扩展

2.创建生产者 send.php

 1 require(__DIR__ . \'/../protected/vendor/autoload.php\');
 2 
 3 use PhpAmqpLib\\Connection\\AMQPStreamConnection;
 4 use PhpAmqpLib\\Message\\AMQPMessage;
 5 
 6 
 7 $connection = new AMQPStreamConnection(\'192.168.38.129\', 5672, \'fanwq\', \'ysq\');
 8 $channel = $connection->channel();
 9 $channel->queue_declare(\'hello\', false, false, false, false);
10 
11 $msg = new AMQPMessage($i.\'-Hello World! --\' . $_SERVER[\'SSH_CONNECTION\']);
12 $channel->basic_publish($msg, \'\', \'hello\');
13 echo " [{$i}] Sent \'Hello World!\'\\n";
14 $channel->close();
15 $connection->close();

View Code

3.创建消费者 receive.php

 1 require(__DIR__ . \'/../protected/vendor/autoload.php\');
 2 
 3 use PhpAmqpLib\\Connection\\AMQPStreamConnection;
 4 use PhpAmqpLib\\Message\\AMQPMessage;
 5 
 6 $connection = new AMQPStreamConnection(\'192.168.38.129\', 5672, \'fanwq\', \'ysq\');
 7 $channel = $connection->channel();
 8 
 9 $channel->queue_declare(\'hello\', false, false, false, false);
10 echo \' [*] Waiting for messages. To exit press CTRL+C\', "\\n";
11 $callback = function($msg) {
12     echo " [x] Received ", $msg->body, "\\n";
13 };
14 
15 $channel->basic_consume(\'hello\', \'\', false, true, false, false, $callback);
16 
17 while(count($channel->callbacks)) {
18     $channel->wait();
19 }