关于rabbitmq:RabbitMQ-简单队列的使用

简略队列通常为一个生产者、一个消费者、一个队列的构造。

装置依赖

# composer.json
{
    "require": {"php-amqplib/php-amqplib": ">=3.0"}
}

> composer.phar install

模式构造

生产者

生产者连贯到 RabbitMQ，发送一条音讯，而后退出。

# send.php

<?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->queue_declare('hello', false, false, false, false);

$msg = new AMQPMessage('Hello World!');
// 通过默认的交换机发送音讯到队列 (音讯内容, 默认交换机, 路由键)
$channel->basic_publish($msg, '','hello');

echo "[x] Sent'Hello World!'\n";

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

消费者

消费者监听来自 RabbitMQ 的音讯，通常须要始终放弃运行状态以监听音讯。

# receive.php

<?php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;

// 创立连贯
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');

// 创立通道
$channel = $connection->channel();

// 创立队列，已存在的不会反复创立
$channel->queue_declare('hello', false, false, false, false);

echo "[*] Waiting for messages. To exit press CTRL+C\n";

// 定义音讯解决回调函数
$callback = function ($msg) {echo '[x] Received', $msg->body, "\n";
};

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

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

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

运行

关上一个终端，运行消费者：

php receive.php

关上另一个终端，运行生产者：

php send.php

应用 rabbitmqctl 工具查看队列

# Linux
sudo rabbitmqctl list_queues

# Windows
rabbitmqctl.bat list_queues