首先安裝 erl 環境，其次安裝 rabbitmq-server ，最後安裝 amqp 擴充套件，安裝完成之後使用 rabbitmqctl status 檢視狀態 。文末附上一個 生產消費訊息 的 例子。

用到的命令如下：

#安裝erlang環境
$ apt-get install erlang



#安裝 rabbitmq-server
$ wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.5.7/rabbitmq-server-3.5.7.tar.gz
$ tar zxvf rabbitmq-server-3.5.7.tar.gz
$ 
 
cd rabbitmq-server-3.5.7/
$ make

$ apt-get update
$ apt-get install xmlto --fix-missing
$ make install 


#安裝 rabbitmq-c 
wget https://github.com/alanxz/rabbitmq-c/releases/download/v0.5.0/rabbitmq-c-0.5.0.tar.gz  --no-check-certificate
$ tar -xzvf rabbitmq-c-0.5.0.tar.gz
$ cd rabbitmq-c-0.5.0/
$ ls
$ autoconf -i
$ 
 
./configure --prefix=/usr/local/rabbitmq-c
$ make
$ make install

#安裝php-amqp擴充套件
$ apt-cache search php-rmqp

$ apt-get install php-rmqp

生產消費訊息的小例子

在專案中使用composer引入 amqp

$ composer require    php-amqplib/php-amqplib   2.6.1 

生產者 producer (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();

消費者 consumer （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(count($channel->callbacks)) {
$channel->wait();
}

1 傳送兩條訊息給佇列

2 檢視佇列中的訊息數為2

3 消費訊息

4 檢視消費之後的訊息