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

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

2.创建生产者 send.php

require(__DIR__ . '/../protected/vendor/autoload.php');

use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;


$connection = new AMQPStreamConnection('192.168.38.129', 5672, 'fanwq', 'ysq');
$channel = $connection->channel();
$channel->queue_declare('hello', false, false, false, false);

$msg = new AMQPMessage($i.'-Hello World! --' . $_SERVER['SSH_CONNECTION']);
$channel->basic_publish($msg, '', 'hello');
echo " [{$i}] Sent 'Hello World!'
";
$channel->close();
$connection->close();

3.创建消费者 receive.php

require(__DIR__ . '/../protected/vendor/autoload.php');

use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;

$connection = new AMQPStreamConnection('192.168.38.129', 5672, 'fanwq', 'ysq');
$channel = $connection->channel();

$channel->queue_declare('hello', false, false, false, false);
echo ' [*] Waiting for messages. To exit press CTRL+C', "
";
$callback = function($msg) {
    echo " [x] Received ", $msg->body, "
";
};

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

while(count($channel->callbacks)) {
    $channel->wait();
}

4.在cli模式下 分别执行 send.php  receive.php 可以看到如下：

说明生产 消费端均ok。

5.管理 查看队列消息：安装rabbitmq_management插件

【5-1】查看当前可用插件：

【5-2】 安装启用 rabbitmq_management插件

【5-3】进入rabbitmq_management管理端：http://192.168.38.129:15672/

【5-4】 guest用户没有权限 需要授权

rabbitmqctl set_user_tags guest monitoring 

rabbitmqctl set_user_tags guest management

【5-5】登陆成功