之前的文章已经介绍RabbitMQ以及安装，本文就介绍PHP使用RabbitMQ的示例。

安装PHP的RabbitMQ扩展

本文介绍AMQP 0-9-1，这是一个开放的、通用的协议消息，这里我们使用php-amqplib这个PHP扩展。更多PHPAMQP扩展见官网。

通过composer安装

composer require php-amqplib/php-amqplib -vvv

如果你还不知道composer，那就out了。：）

Publisher（生产者，消息发送方）

创建publisher.php文件，并引入composer自动加载文件

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

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

Connection（创建连接）

创建RabbitMQ连接以及channel通道，AQMP的命令都是通过通道发出去的。

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
// 创建通道
$channel = $connection->channel();

Send（发送消息）

发消息前，我们必须声明一个队列为我们发送做准备；然后我们可以向队列发布消息：

/**
 * 创建队列(Queue)
 * name: hello         // 队列名称
 * passive: false      // 如果设置true存在则返回OK，否则就报错。设置false存在返回OK，不存在则自动创建
 * durable: true       // 是否持久化，设置false是存放到内存中的，RabbitMQ重启后会丢失
 * exclusive: false    // 是否排他，指定该选项为true则队列只对当前连接有效，连接断开后自动删除
 *  auto_delete: false // 是否自动删除，当最后一个消费者断开连接之后队列是否自动被删除
 */
$channel->queue_declare('hello', false, false, false, false);

/**
 * 创建交换机(Exchange)
 * name: vckai_exchange// 交换机名称
 * type: direct        // 交换机类型，分别为direct/fanout/topic，参考另外文章的Exchange Type说明。
 * passive: false      // 如果设置true存在则返回OK，否则就报错。设置false存在返回OK，不存在则自动创建
 * durable: false      // 是否持久化，设置false是存放到内存中的，RabbitMQ重启后会丢失
 * auto_delete: false  // 是否自动删除，当最后一个消费者断开连接之后队列是否自动被删除
 */
$channel->exchange_declare('vckai_exchange', AMQPExchangeType::DIRECT, false, false, false);

// 绑定消息交换机和队列
$channel->queue_bind('hello', 'vckai_exchange');

/**
 * 创建AMQP消息类型
 * delivery_mode 消息是否持久化
 * AMQPMessage::DELIVERY_MODE_NON_PERSISTENT  不持久化
 * AMQPMessage::DELIVERY_MODE_PERSISTENT      持久化 
 */
$msg = new AMQPMessage('Hello World!', ['delivery_mode' => AMQPMessage:: DELIVERY_MODE_NON_PERSISTENT]);

/**
 * 发送消息
 * msg: $msg                // AMQP消息内容
 * exchange: vckai_exchange // 交换机名称
 * queue: hello             // 队列名称
 */
$channel->basic_publish($msg, 'vckai_exchange', 'hello');

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

这里需要特别说明的是关于Exchange、Queue和Message持久化的问题

如过将Queue的持久化标识durable设置为true，则代表是一个持久的队列，那么在服务重启之后，也会存在，因为服务会把持久化的Queue存放在硬盘上，当服务重启的时候，会重新加载之前被持久化的Queue。

队列是可以被持久化，但是里面的消息是否为持久化那还要看消息的持久化设置。也就是说，重启之前那个Queue里面还没有发出去的消息的话，重启之后那队列里面是不是还存在原来的消息，这个就要取决于发生着在发送消息时对消息的设置了。

上面阐述了队列的持久化和消息的持久化，如果不设置Exchange的持久化对消息的可靠性来说没有什么影响，但是同样如果Exchange不设置持久化，那么当Broker服务重启之后，Exchange将不复存在，那么既而发送方RabbitMQ Producer就无法正常发送消息。

Close（关闭链接）

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