運行環境：https://oneinstack.com/install/

在項目中，將一些無需即時返回且耗時的操作提取出來，進行了異步處理，而這種異步處理的方式大大的節省了服務器的請求響應時間，從而提高了系統的吞吐量。如發送短信、郵件、過濾非法關鍵字等等。它還可以用於RPC。

先看一張官方圖：

[root@cloud bin]# erl
Erlang R16B02 (erts-5.10.3) [source] [64-bit] [smp:2:2] [async-threads:10] [hipe] [kernel-poll:false]
 
Eshell V5.10.3  (abort with ^G)
1>

./configure --with-php-config=/usr/local/php/bin/php-config --with-amqp

//設置連接屬性  
$connArgs = array(  
     ‘host‘           => ‘localhost‘,  
     ‘port‘           => ‘5672‘,  
     ‘login‘           => ‘guest‘,  
     ‘password‘ => ‘guest‘,  
     ‘vhost‘          => ‘/‘  
);  
  
//創建RabbitMQ連接  
$conn = new AMQPConnection($connArgs);  
if (!$conn->connect()) {  
    echo "Cannot connect to the broker <br/>\n ";  
}  
  
//創建channel  
$channel = new AMQPChannel($conn);  
  
//創建exchange  
$exchangeName = ‘exchange‘;  
$exchange = new AMQPExchange($channel);  
$exchange->setName($exchangeName);//創建名字  
$exchange->setType(AMQP_EX_TYPE_DIRECT);//設置為direct類型  
$exchange->setFlags(AMQP_DURABLE);//持久化交換機,當代理重啟動後依然存在,並包括它們中的完整數據  
$exchange->setFlags(AMQP_AUTODELETE);//對交換機而言,自動刪除標誌表示交換機將在沒有隊列綁定的情況下被自動刪除,如果從沒有隊列和其綁定過,這個交換機將不會被刪除.  
  
//發送消息  
$routingKey = ‘key_test‘;  
for($i=0;$i<10;$i++){  
     sleep(3);  
     $message = ‘Hello World ‘.$i;  
    $exchange->publish($message,$routingKey);  
}  
  
//斷開連接  
$conn->disconnect();  

//設置連接屬性  
$connArgs = array(  
                    ‘host‘           => ‘localhost‘,  
                    ‘port‘           => ‘5672‘,  
                    ‘login‘           => ‘guest‘,  
                    ‘password‘ => ‘guest‘,  
                    ‘vhost‘          => ‘/‘  
);  
  
//創建RabbitMQ連接  
$conn = new AMQPConnection($connArgs);  
if (!$conn->connect()) {  
     echo ‘cannot connect to the broker‘;  
}  
  
//創建channel  
$channel = new AMQPChannel($conn);  
  
//設置隊列名稱  
$exchangeName = ‘exchange‘;  
$routingKey = ‘key_test‘;      
$queueName = ‘queue_test_1‘;  
$queue = new AMQPQueue($channel);  
$queue->setName($queueName);//設置名稱  
$queue->setFlags(AMQP_DURABLE);//持久化隊列，當代理重啟動後依然存在,並包括它們中的完整數據  
$queue->declare();//聲明此隊列  
$queue->bind(‘exchange‘,$routingKey);//使用某交換機，並綁定某路由關鍵字  
  
//消費數據方式一：非阻塞方式  
// while(true)  
// {  
//      sleep(1);  
//      $envelope = $queue->get(AMQP_AUTOACK) ;//第一個參數表示自動ACK應答  
//      if ($envelope){  
//           $messages = $envelope->getBody();  
//           echo $messages;  
//      }  
// }  
  
  
//消費數據方式二：以阻塞模式消費數據（推薦）  
while(true)  
{  
          $queue->consume(‘processMessage‘);//第一個參數表示要回調的方法名，第二個參數設置為AMQP_AUTOACK，表示自動ACK應答  
}  
/** 
* 定義回調方法 
*/  
function processMessage($envelope, $queue)  
{  
     $messages = $envelope->getBody();#獲取消息數據  
     echo $messages;  
     $queue->ack($envelope->getDeliveryTag()); //處理成功後，手動發送ACK應答  
     //$queue->nack($envelope->getDeliveryTag()); //處理不成功，手動發送NO-ACK應答，放回隊列中   
}  

RabbitMQ的安裝與基本使用