如何使用PHP和RabbitMQ實現消息發布與訂閱模式

M66 2025-06-07

如何使用PHP和RabbitMQ實現消息發布與訂閱模式

RabbitMQ是一款高性能且可靠的消息隊列系統，結合PHP這門流行的服務器端腳本語言，可以輕鬆實現消息發布與訂閱的功能。本文將帶你一步步完成PHP與RabbitMQ的集成，附有清晰的示例代碼，幫助你快速搭建消息傳遞機制。

安裝RabbitMQ

首先需要在服務器上安裝RabbitMQ。可前往RabbitMQ的官方網站下載適合系統的安裝包，並按照官方文檔完成安裝和基礎配置。

安裝PHP的AMQP擴展

在PHP中操作RabbitMQ需要使用AMQP擴展。可以通過以下命令安裝該擴展：

 <span class="fun">sudo apt-get install php-amqp</span>

配置RabbitMQ連接信息

連接RabbitMQ服務器時，需要配置相關連接參數。以下示例使用默認的本地連接配置：

 $connection = new AMQPConnection([
    'host' => 'localhost',
    'port' => '5672',
    'vhost' => '/',
    'login' => 'guest',
    'password' => 'guest'
]);

聲明exchange和queue

RabbitMQ中，消息通過exchange路由到指定的queue。 exchange負責消息分發，queue負責消息存儲和消費。

下面的示例聲明了一個名為test_exchange的exchange和一個test_queue的隊列：

 $channel = $connection->channel();
<p>$channel->exchange_declare('test_exchange', 'fanout', false, false, false);</p>
<p>list($queue_name, ,) = $channel->queue_declare('test_queue', false, false, true, false);</p>
<p>$channel->queue_bind($queue_name, 'test_exchange');

消息的發布與訂閱

現在開始發布消息，並通過指定隊列進行訂閱和消費。示例如下：

 $message = 'Hello, RabbitMQ!';
<p>$channel->basic_publish(<br>
new AMQPMessage($message),<br>
'test_exchange',<br>
''<br>
);</p>
<p>echo " [x] Sent '$message'\n";</p>
<p>$channel->basic_consume(<br>
$queue_name,<br>
'',<br>
false,<br>
true,<br>
false,<br>
false,<br>
function($msg) {<br>
echo ' [x] Received ', $msg->body, "\n";<br>
}<br>
);</p>
<p>while (count($channel->callbacks)) {<br>
$channel->wait();<br>
}

運行示例代碼

將上述代碼保存為PHP文件，比如example.php ，通過終端運行：

 <span class="fun">php example.php</span>

即可看到消息發布與訂閱的輸出，表示消息傳遞機制已成功運行。

總結

本文介紹瞭如何結合PHP和RabbitMQ實現消息發布與訂閱，涵蓋了從環境搭建到代碼實現的詳細步驟。借助RabbitMQ高性能的消息隊列系統，PHP應用可以實現靈活且可靠的消息傳遞，為複雜分佈式系統提供堅實基礎。