PHP RabbitMQ 手冊介紹
PHP RabbitMQ 是一個實現(xiàn)消息傳遞機制的開源軟件，它可以提供一個完整的 AMQP（高級消息隊列協(xié)議）客戶端庫，讓開發(fā)人員可以基于 AMQP 隊列、交換機和綁定來構(gòu)建分布式系統(tǒng)。
使用 RabbitMQ 需要 First in First out（FIFO）隊列，假設(shè)我們需要處理用戶提交的表單數(shù)據(jù)，這個數(shù)據(jù)需要異步處理并且優(yōu)先級比較高。我們就可以使用 RabbitMQ 構(gòu)建一個名叫 test_foobar 的隊列，并將數(shù)據(jù)序列化后發(fā)送到隊列中，然后開啟一個訂閱，監(jiān)聽 test_foobar 隊列，處理其中的數(shù)據(jù)。
接著我們就可以用 PHP RabbitMQ 客戶端庫來實現(xiàn)這個過程。首先，我們需要使用 Composer 安裝 rabbitmq/rabbitmq-bundle：

<?php
// 安裝 rabbitmq/rabbitmq-bundle
composer install rabbitmq/rabbitmq-bundle
?>

通過命令行工具來添加一個新的消費者：

$ bin/console rabbitmq:consumer test_consumer

這個消費者就會監(jiān)聽名為 test_foobar 的隊列，當(dāng)隊列中有數(shù)據(jù)時，就會把數(shù)據(jù)取出來并調(diào)用消費者的相關(guān)方法來處理數(shù)據(jù)。
如果我們想在消費者中實現(xiàn) FIFO 隊列的功能，我們可以在消費者內(nèi)部添加一個參數(shù)，用來標(biāo)示目前正在處理的消息是否是優(yōu)先消息，如果是則將其立即處理；如果不是，則將其暫時存放在隊列的后面等待處理。

$channel->queue_bind($queue_name, $exchange_name);
do {
$msg = $consumer->receive();
$priority = $msg->priority;
<br>
    if ($priority > PRIORITY_HIGH) {
// 當(dāng)消息優(yōu)先級大于 PRIORITY_HIGH 時立即處理
$handleMessage($msg);
} else {
// 當(dāng)消息優(yōu)先級小于或等于 PRIORITY_HIGH 時將其暫時存放在隊列的后面等待處理
$queue->publish($msg->body, $exchange_name, $msg->routing_key, $msg->getHeaders(), $msg->getProperties(), array('delivery_mode' => 2));
}
} while (true);

PHP RabbitMQ 客戶端庫還支持發(fā)送和接收“租賃確認(rèn)”（lease acknowledgements）和“事務(wù)機制”（transaction mechanism）等高級特性，可以幫助你構(gòu)建更加安全和穩(wěn)定的分布式系統(tǒng)。