PHP 連接 Rabbitmq 實例代碼

教程 shanhuhai 10344℃ 0評論

接下來我們用 php 連接 rabbitmq 玩一玩。
還沒有安裝 rabbitmq ,請參考 Rabbitmq 安裝
還沒有安裝 PHP 的 AMQP 擴展,參考 PHP AMQP 擴展安裝

一些概念

Rabbitmq 是一個功能很強大消息隊列系統,使用起來可能不像某些 push 、pop 類型的隊列簡單(比如 redis 的list),Rabbitmq 支持消息的訂閱發布模式,方便大型系統各個服務組件之間解耦和通信。我們首先要了解一些基本概念

Vhost: 可以先不深究,固定為 /
Connection:即連接, 與你日常理解的連接沒有什么不同,比如 redis的連接,mysql的連接
Channel:即通道, 可以理解為一個連接中的子通道,想象一條高速公路,可能是 4車道的,也可能是 8 車道的,這些車道就是 Channel。

Exchange : 交換機,如果你知道交換機設備的話,它的原理跟交換機是基本一樣的。
routingkey : 用來綁定交換機和隊列的一個字符串。發送消息時需要指定 routingKey, 綁定了此 routingKey的隊列將接收到此消息。
queue隊列: 消息經過交換機,最終發送到隊列中。

發布消息


<?php $conn = [ // Rabbitmq 服務地址 'host' => '127.0.0.1', // Rabbitmq 服務端口 'port' => '5672', // Rabbitmq 帳號 'login' => 'admin', // Rabbitmq 密碼 'password' => 'admin', 'vhost'=>'/' ]; //創建連接和channel $conn = new AMQPConnection($conn); if(!$conn->connect()) { die("Cannot connect to the broker!\n"); } $channel = new AMQPChannel($conn); // 用來綁定交換機和隊列 $routingKey = 'key_1'; $ex = new AMQPExchange($channel); // 交換機名稱 $exchangeName = 'ex1'; $ex->setName($exchangeName); // 設置交換機類型 $ex->setType(AMQP_EX_TYPE_DIRECT); // 設置交換機是否持久化消息 $ex->setFlags(AMQP_DURABLE); $ex->declare(); for($i=0; $i<5; ++$i){ echo "Send Message:".$ex->publish(date('H:i:s')."用戶".$i."注冊" , $routingKey )."\n"; }

以上代碼保存為 send.php

消費消息

<?php
$conn = [
    // Rabbitmq 服務地址
    'host' => '127.0.0.1',
    // Rabbitmq 服務端口
    'port' => '5672',
    // Rabbitmq 帳號
    'login' => 'admin',
    // Rabbitmq 密碼
    'password' => 'admin',
    'vhost'=>'/'
];


//創建連接和channel
$conn = new AMQPConnection($conn);
if(!$conn->connect()) {
    die("Cannot connect to the broker!\n");
}
$channel = new AMQPChannel($conn);
$exchangeName = 'ex1';

//創建交換機
$ex = new AMQPExchange($channel);
$ex->setName($exchangeName);

$ex->setType(AMQP_EX_TYPE_DIRECT); //direct類型
$ex->setFlags(AMQP_DURABLE); //持久化
$ex->declare();

//  創建隊列
$queueName = 'queue1';
$q = new AMQPQueue($channel);
$q->setName($queueName);
$q->setFlags(AMQP_DURABLE);
$q->declareQueue();

// 用于綁定隊列和交換機,跟 send.php 中的一致。
$routingKey = 'key_1';
$q->bind($exchangeName,  $routingKey);

//接收消息
$q->consume(function ($envelope, $queue) {
    $msg = $envelope->getBody();
    echo $msg."\n"; //處理消息
}, AMQP_AUTOACK);

$conn->disconnect();

以上代碼保存為 consume.php

運行代碼

一開始隊列是不存在的,我們需要先啟動 consume.php 來初始化隊列,打開終端,運行

php consume.php

啟動后 , php consume.php 將阻塞監聽隊列消息。
然后打開新終端窗口運行:

php send.php

然后在新 consume.php 所在的終端窗口將看到接收到的消息。

消費 rabbitmq 消息

轉載請注明:大后端 » PHP 連接 Rabbitmq 實例代碼

喜歡 (12)or分享 (0)
發表我的評論
取消評論

表情

Hi,您需要填寫昵稱和郵箱!

  • 昵稱 (必填)
  • 郵箱 (必填)
  • 網址
春梓美 种子,av全裸挂历,日本女护士mm裸照写真,超碰地址发布页 <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <蜘蛛词>| <文本链> <文本链> <文本链> <文本链> <文本链> <文本链>