鍦≒HP涓紝鍙互浣跨敤娑堟伅闃熷垪鏉ュ鐞嗘暟鎹幏鍙栦换鍔°€備竴绉嶅父瑙佺殑鏂规硶鏄娇鐢ㄤ竴涓槦鍒楃郴缁燂紝濡俁abbitMQ鎴朢edis锛屾潵瀛樺偍浠诲姟骞跺鐞嗗畠浠€?/p>

涓嬮潰鏄竴涓娇鐢≧abbitMQ鏉ュ鐞嗘暟鎹幏鍙栦换鍔＄殑绠€鍗曠ず渚嬶細

1. 棣栧厛锛屽畨瑁卲hp-amqplib搴擄紝鐢ㄤ簬涓嶳abbitMQ杩涜閫氫俊锛?/li>

composer require php-amqplib/php-amqplib

2. 鍒涘缓涓€涓敓浜ц€呰剼鏈紝鐢ㄤ簬灏嗕换鍔℃帹閫佸埌闃熷垪涓細

<?php

require_once __DIR__ . '/vendor/autoload.php';

$connection = new PhpAmqpLib\Connection\AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

$channel->queue_declare('tasks_queue', false, true, false, false);

$data = 'data to be processed';

$msg = new PhpAmqpLib\Message\AMQPMessage($data);

$channel->basic_publish($msg, '', 'tasks_queue');

echo " [x] Sent '$data'\n";

$channel->close();
$connection->close();

3. 鍒涘缓涓€涓秷璐硅€呰剼鏈紝鐢ㄤ簬浠庨槦鍒椾腑鑾峰彇浠诲姟骞跺鐞嗗畠浠細

<?php

require_once __DIR__ . '/vendor/autoload.php';

$connection = new PhpAmqpLib\Connection\AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

$channel->queue_declare('tasks_queue', false, true, false, false);

echo " [*] Waiting for messages. To exit press CTRL+C\n";

$callback = function ($msg) {
    echo ' [x] Received ', $msg->body, "\n";
    // Process the data here
};

$channel->basic_consume('tasks_queue', '', false, true, false, false, $callback);

while ($channel->is_consuming()) {
    $channel->wait();
}

$channel->close();
$connection->close();

杩愯鐢熶骇鑰呰剼鏈彲浠ュ悜闃熷垪涓帹閫佷换鍔★紝鑰岃繍琛屾秷璐硅€呰剼鏈彲浠ヤ粠闃熷垪涓幏鍙栦换鍔″苟澶勭悊瀹冧滑銆傝繖鏍凤紝灏卞彲浠ュ疄鐜颁娇鐢ㄦ秷鎭槦鍒楀鐞嗘暟鎹幏鍙栦换鍔＄殑鍔熻兘銆?/p>