在項目開發中，我需要從 rabbitmq 消息隊列中消費消息，并根據消息內容執行不同的處理邏輯，最后將處理結果存儲到 mysql 和 elasticsearch 中。這個過程看似簡單，但實際操作起來卻充滿了挑戰。首先，消息隊列中的消息只包含了 mysql 中的 id 和一些額外的信息，這意味著我需要從 mysql 中讀取詳細信息，然后再進行處理和存儲。此外，不同的項目可能有不同的處理邏輯和存儲需求，這使得代碼的復用性和可維護性變得非常重要。
為了解決這些問題，我選擇了使用 mysic/phpamqplib-consumer 庫。這個庫提供了一個靈活的框架，允許我根據不同的項目需求定制消息消費和處理邏輯。以下是如何使用 composer 安裝和配置這個庫的步驟：
-
安裝庫： 通過 Composer 安裝 mysic/phpamqplib-consumer 非常簡單，只需在命令行中執行：
composer require mysic/phpamqplib-consumer
-
配置項目結構： 安裝完成后，按照庫的目錄結構組織項目代碼。核心文件和類位于 core/ 目錄下，而每個項目的具體業務邏輯則放在 task/ 目錄下的相應文件夾中。例如：
/ core/ Db.php Dispatcher.php MqConnector.php Processor.php Storage.php task/ project_1/ config/ processor/ storage/ project_n/ config/ processor/ storage/ run.php
-
配置文件： 在每個項目目錄下的 config/ 文件夾中，配置數據源、消息隊列和數據存儲的相關參數。例如：
config/ db.php messageQueue.php storage.php
-
編寫處理邏輯： 在 processor/ 文件夾中，編寫具體的消息處理邏輯。例如，對于處理文檔存儲到 Elasticsearch 的邏輯，可以在 Document.php 中實現：
// Document.php class Document extends Processor { public function process($message) { // 從MySQL中讀取詳細信息 $data = $this->db->fetch($message['id']); // 處理數據并存儲到Elasticsearch $this->storage->save($data, $message['extra']); } } -
運行消費者： 最后，通過 run.php 文件啟動消息消費者，指定項目名稱、處理器名稱和存儲名稱：
php run.php project_name processor_name storage_name
使用 mysic/phpamqplib-consumer 庫后，我能夠輕松地管理和擴展消息消費邏輯。它的模塊化設計使得我可以根據不同項目的需求靈活地添加新的處理器和存儲器，大大提高了代碼的可維護性和復用性。此外，庫提供的 Dispatcher 類可以有效地管理消息的分發和處理，確保了消息隊列的穩定性和高效性。
總的來說，mysic/phpamqplib-consumer 庫不僅解決了我項目中遇到的 RabbitMQ 消息消費問題，還為未來的擴展提供了堅實的基礎。如果你也在處理類似的消息隊列消費需求，不妨嘗試一下這個庫，它會讓你的事半功倍。
