可以使用composer init来初始化一个测试项目，然后用composer require php-amqplib/php-amqplib来引入RabbitMQ开发包，然后就可以进行以下测试了。

下面是一个简单的生产者和消费者代码。

如果运行多个消费者，生产者的消息会通过轮训的方式平均分配给消费者。

生产者（消息发送者）：

producer.php

<?php

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


use PhpAmqpLib\Connection\AMQPStreamConnection;

use PhpAmqpLib\Message\AMQPMessage;


$connection = new AMQPStreamConnection('192.168.33.10', 5672, 'admin', 'admin');

$channel = $connection->channel(); //创建channel


//声明一个队列hello

$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和连接

$channel->close();

$connection->close();

消费者（消息接收者）：

consumer.php

<?php

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


use PhpAmqpLib\Connection\AMQPStreamConnection;


$connection = new AMQPStreamConnection('192.168.33.10', 5672, 'admin', 'admin');

$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);


//有回调函数的时候，代码会阻塞，当有消息到来的时候就会调用$callback来处理

while (count($channel->callbacks)) {

    $channel->wait();

}

消息确认

消息确认（ACK）是消费者返回给你RabbitMQ的确认信息，告诉它消息已经收到并且处理完毕了，这样RabbitMQ才会删除对应的消息。

ACK默认是关闭的，如果要打开它只需要设置basic_consume的第四个参数为false。

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

消息持久化

消息确认是确保消费者出现问题，导致的消息丢失，那么RabbitMQ服务器出现问题怎么办呢？

1. 设置queue_declare第三个参数为true：

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

1. 然后是设置消息属性delivery_mode = 2：

$msg = new AMQPMessage(

    $data,

    array('delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT)

);

通过上面的设置后，队列和消息都不会丢失了。

公平分配

$channel->basic_qos(null, 1, null);

通过上面的语句设置prefetch_count = 1，这样，在收到消费者的ack之前，不会再派发消息给同一个消费者。

参考RabbitMQ官方教程：http://www.rabbitmq.com/tutorials/tutorial-one-php.html