1. 安裝rabbitmq 之前首先

(1)安裝erlang.:

下載erlang:

1. 我的是Mac OSX系統 所以我直接在 http://www.erlang-solutions.com/section/132/download-erlang-otp下載的對應版本的安裝包，省的自己配置和安裝了
2. 然後解壓下載的gz包 tar zxcf *.tar.gz
3. cd 進入解壓出來的資料夾
4. 執行./configure --prefix=/opt/erlang 就會開始編譯安裝 會編譯到 /opt/erlang 下 然後執行
5. make 和 make install
6. 編譯完成以後，進入/opt/erlang，輸入erl測試erlang是否安裝成功。
7. 修改/etc/profile檔案，增加下面的環境變數：
8. #set erlang environment
9. export PATH=$PATH:/opt/erlang/bin
10. source profile使得檔案生效

yum install erlang

(2）.安裝python

yum install python -y

(3) 安裝simplejson

(4)安裝rabbitmq
1.下載：
 # wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.4.2/rabbitmq-server-generic-unix-3.4.2.tar.gz
2.解壓縮：
 # tar -zxf rabbitmq-server-generic-unix-3.4.2.tar.gz

3.移動這個目錄到 /usr/local下並且重新命名為rabbitmq:
 # mv rabbitmq-server-generic-unix-3.4.2 /usr/local/rabbitmq
4.開啟/etc/profile檔案，在檔案最後添如下兩行環境變數
   #set rabbitmq environment
   export PATH=$PATH:/usr/local/rabbitmq/sbin
5.使環境變數生效:
 # source /etc/profile
6.安裝rabbitmq網頁管理外掛：
 # cd /usr/local/rabbitmq/sbin/
 #./rabbitmq-plugin enable rabbitmq-management
7.啟動rabbitmq:
 # cd /usr/local/rabbitmq/sbin
 # ./rabbitmq-server -detached (可以實現後臺執行)
8.檢視啟動是否成功: # netstat -tunlp | grep beam
 tcp 0 0 0.0.0.0:25672 0.0.0.0:* LISTEN 3308/beam.smp
 tcp 0 0 0.0.0.0:15672 0.0.0.0:* LISTEN 3308/beam.smp
 tcp 0 0 :::5672 :::* LISTEN 3308/beam.smp
可以看到啟動成功: 15672是rabbimq網頁管理監聽埠,5672是php客戶端使用的埠，在瀏覽器中輸入localhost:15672，可以看到如下頁面：

輸入使用者名稱guest和密碼guest即可通過網頁管理rabbitmq。
 9. 關閉rabbitmq ： # cd /usr/local/rabbitmq/sbin 然後：#./rabbitmqctl stop

(5)php客戶端使用rabbitmq

composer是PHP用來管理依賴（dependency）關係的工具。你可以在自己的專案中宣告所依賴的外部工具庫（libraries），Composer 會幫你安裝這些依賴的庫檔案,具體可參考composer權威網站：http://www.phpcomposer.com/

{
"reqire": {
"videlalvaro/php-amqplib": "v2.1.0"
}
}

3.使用 Composer

<?php
include(__DIR__ . '/vendor/autoload.php');
use PhpAmqpLib\Connection\AMQPConnection;
use PhpAmqpLib\Message\AMQPMessage;
define('HOST', '127.0.0.1');
define('PORT', 5672);
define('USER', 'guest');
define('PASS', 'guest');
define('VHOST', '/');
$exchange = 'router';
$queue = 'msgs';
$conn = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
$ch = $conn->channel();
/*
    The following code is the same both in the consumer and the producer.
    In this way we are sure we always have a queue to consume from and an
        exchange where to publish messages.
*/
/*
    name: $queue
    passive: false
    durable: true // the queue will survive server restarts
    exclusive: false // the queue can be accessed in other channels
    auto_delete: false //the queue won't be deleted once the channel is closed.
*/
$ch->queue_declare($queue, false, true, false, false);
/*
    name: $exchange
    type: direct
    passive: false
    durable: true // the exchange will survive server restarts
    auto_delete: false //the exchange won't be deleted once the channel is closed.
*/
$ch->exchange_declare($exchange, 'direct', false, true, false);
$ch->queue_bind($queue, $exchange);
$msg_body = implode(' ', array_slice($argv, 1));
$msg = new AMQPMessage($msg_body, array('content_type' => 'text/plain', 'delivery_mode' => 2));
$ch->basic_publish($msg, $exchange);
$ch->close();
$conn->close();

<?php
include(__DIR__ . '/vendor/autoload.php');
use PhpAmqpLib\Connection\AMQPConnection;
define('HOST', '127.0.0.1');
define('PORT', 5672);
define('USER', 'guest');
define('PASS', 'guest');
define('VHOST', '/');
$exchange = 'router';
$queue = 'msgs';
$consumer_tag = 'consumer';
$conn = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
$ch = $conn->channel();
/*
    The following code is the same both in the consumer and the producer.
    In this way we are sure we always have a queue to consume from and an
        exchange where to publish messages.
*/
/*
    name: $queue
    passive: false
    durable: true // the queue will survive server restarts
    exclusive: false // the queue can be accessed in other channels
    auto_delete: false //the queue won't be deleted once the channel is closed.
*/
$ch->queue_declare($queue, false, true, false, false);

/*
    name: $exchange
    type: direct
    passive: false
    durable: true // the exchange will survive server restarts
    auto_delete: false //the exchange won't be deleted once the channel is closed.
*/
$ch->exchange_declare($exchange, 'direct', false, true, false);
$ch->queue_bind($queue, $exchange);
function process_message($msg)
{
    echo "\n--------\n";
    echo $msg->body;
    echo "\n--------\n";

<pre name="code" class="php">    $msg->delivery_info['channel']->
        basic_ack($msg->delivery_info['delivery_tag']);

    // Send a message with the string "quit" to cancel the consumer.
    if ($msg->body === 'quit') {
        $msg->delivery_info['channel']->
            basic_cancel($msg->delivery_info['consumer_tag']);
    }
}

/*
    queue: Queue from where to get the messages
    consumer_tag: Consumer identifier
    no_local: Don't receive messages published by this consumer.
    no_ack: Tells the server if the consumer will acknowledge the messages.
    exclusive: Request exclusive consumer access, meaning only this consumer can access the queue
    nowait:
    callback: A PHP Callback
*/

$ch->basic_consume($queue, $consumer_tag, false, false, false, false, 'process_message');

function shutdown($ch, $conn)
{
    $ch->close();
    $conn->close();
}
register_shutdown_function('shutdown', $ch, $conn);

// Loop as long as the channel has callbacks registered

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

一下：

開啟消費者監聽：
[[email protected] htdocs]# php amqp_consumer.php

釋出者釋出訊息：
[[email protected] htdocs]# php amqp_publisher.php 'lsi';
[[email protected] htdocs]# php amqp_publisher.php 'zhangsan'

可以看到監聽者打印出了這兩個訊息：
[[email protected] htdocs]# php amqp_consumer.php

--------
lsi
--------

--------
zhangsan
--------

在localhost:15672 網頁管理系統中可以看到有個msgs的佇列（剛才建立的），並且在messages中看到total為2，因為我們剛才釋出的兩條訊息，所以在這個佇列中有2個訊息。