av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

以PHP代碼為實例詳解RabbitMQ消息隊列中間件的6種模式

瀏覽:170日期:2022-06-10 15:45:11
目錄
  • RabbitMQ 6種工作模式
    • 安裝
    • 6種模式
  • 最后

    RabbitMQ 6種工作模式

    對RabbitMQ 6種工作模式(簡單模式、工作模式、訂閱模式、路由模式、主題模式、RPC模式)進行場景和參數進行講解,PHP代碼作為實例。

    安裝

    客戶端實現:添加擴展,執(zhí)行composer.phar install命令

    {    "require": {"php-amqplib/php-amqplib": ">=3.0"    }}

    引入包

    require_once __DIR__ . "/vendor/autoload.php";use PhpAmqpLib\Connection\AMQPStreamConnection;use PhpAmqpLib\Message\AMQPMessage;

    建立一個鏈接,

    # 鏈接服務$connection = new AMQPStreamConnection("127.0.0.1", 5672, "stark", "1990@stark");$channel = $connection->channel();$channel->queue_declare("hello", false, false, false, false);$msg = new AMQPMessage("Hello World!");$channel->basic_publish($msg, "", "hello");echo " [x] Sent "Hello World!"\n";# 關閉信道和鏈接$channel->close();$connection->close();

    6種模式

    1.簡單模式

    簡單模式是最簡單的使用方式,P代表生產者,C代表消費者,紅色的代表隊列,執(zhí)行過程生產者發(fā)送消息到隊列,右面的消費者消費消息,需要注意的是這里沒有交換機。

    生產者代碼(PHP)

    # 聲明隊列$queueName = "MqName";$channel->queue_declare($queueName, false, false, false, false);

    queue_declare 參數說明:

    • 隊列名
    • 檢測隊列是否存在,true只檢測不創(chuàng)建,false會創(chuàng)建
    • 是否持久化隊列,true持久化
    • 是否私有隊列 true代表私有
    • 當消費者斷開后,隊列是否自動刪除
    # 創(chuàng)建AMQP消息類型$msg = new AMQPMessage($data,    array("delivery_mode" => AMQPMessage::DELIVERY_MODE_PERSISTENT));

    AMQPMessage 參數說明: 1.消息體 2.是否持久化

    $channel->basic_publish($msg, "", $queueName);

    basic_publish參數詳解:

    • 發(fā)送內容
    • 交換機名稱,簡單模式沒有使用交換機
    • 隊列名稱

    消費者代碼:

    $channel->basic_consume("hello", "", false, true, false, false, $callback);# 阻塞隊列,做監(jiān)聽while ($channel->is_open()) {    $channel->wait();}

    basic_consume 參數說明:

    • 隊列名
    • 消費者標簽
    • AMQP標準
    • 是否自動應答 ack true 自動應答,false應答
    • 是否排他
    • ?
    • 回調函數

    2.工作模式

    它由一個生產者發(fā)送在隊列中,work隊列會分配消息給不同的消費者,讓每個消費者接收到不同的消息。

    工作模式的場景特別適合集群模式的異步處理,最大程度發(fā)揮每一臺服務器的性能。

    3.訂閱模式

    從訂閱模式開始就使用了交換機,訂閱模式使用了廣播類型的交換機,它會讓每個隊列的消息都是一樣的。

    生產者把消息發(fā)送給交換機,交換機把消息發(fā)送給和它綁定的隊列,讓消費者來消費,需要強調的是綁定的隊列獲得的消息是一模一樣的,訂閱模式就是讓所有的消費者獲得相同的消息。

    訂閱模式使用場景,天氣、微博的訂閱,收費文章的訂閱等等。

    生產者實現:

    $channel->exchange_declare("logs", "fanout", false, false, false);# 綁定交換機和隊列$channel->queue_bind($queue_name, "logs");

    交換機參數詳解:

    • 交換機名
    • 交換機類型
    • 檢查是否存在
    • 是否持久化
    • 是否自動刪除
    $channel->basic_publish($msg, "這里是交換機的名字", $queueName);

    消費者和生產者一樣,先綁定交換機:

    4.路由模式

    路由模式使用direct定向類型的交換機,生產者發(fā)送一個消息到交換機,交換機根據發(fā)送來的路由鍵發(fā)送到相匹配的隊列中,來和隊列綁定的消費者進行消費。

    訂閱模式和路由模式的區(qū)別,訂閱模式無條件的把消息發(fā)送給所有的消費者,每一個消費者收到的消息都是一樣的,而路由模式對消息進行篩選發(fā)送給對應的消費者隊列。

    5.主題模式

    主題模式采用的事topic的交換機,通過通配符進行匹配,通配符主要有*#

    6.RPC模式

    RabbitMQ的RPC模式,支持生產者和消費者不在同一個系統中,即允許遠程調用的情況。通常,消費者作為服務端,放置在遠程的系統中,提供接口,生產者調用接口,并發(fā)送消息。

    RPC模式是一種遠程調用的模式,因為需要http請求,因此速度比系統內部調用慢。而且rpc模式下,通常不易區(qū)分哪些是來自外部的請求,哪些是內部的請求,導致整體速度較慢。因此,不能濫用rpc模式。

    最后

    后面的3個模式不做詳細的代碼講解了,可以看參考官網,實現起來都是差不多的。

    • 官網:www.rabbitmq.com/getstarted.…

    以上就是以PHP代碼為實例詳解RabbitMQ消息隊列中間件的6種模式的詳細內容,更多關于RabbitMQ模式php實例的資料請關注其它相關文章!

    標簽: PHP
    主站蜘蛛池模板: 成人精品网 | 午夜小电影 | 久草视频观看 | 久久久久国产一区二区三区 | 亚洲精品二区 | 欧美亚洲一区二区三区 | 成人亚洲精品久久久久软件 | 欧美日韩福利视频 | 一级片免费视频 | 午夜av电影 | 精品久久99 | 性一交一乱一伦视频免费观看 | 青青草一区 | 视频一区二区国产 | 国产高清久久久 | jav成人av免费播放 | 国产精品成人国产乱一区 | 久久精品国产一区二区电影 | 国产美女在线精品免费 | 蜜桃特黄a∨片免费观看 | 玖玖精品视频 | 国产精品电影在线观看 | 自拍偷拍小视频 | 精品久久久久久久久久久久 | av网站免费观看 | h视频在线免费 | 欧美一区二区三区在线观看视频 | 在线一区二区三区 | 亚洲国产成人av | 羞羞视频网站 | 天堂av中文 | 成人欧美日韩一区二区三区 | 毛片入口 | 国产精品无码专区在线观看 | 成人福利电影 | 久久狠狠 | 91av免费看 | 性做久久久久久免费观看欧美 | 国产精品大片在线观看 | 亚洲欧美日韩中文字幕一区二区三区 | 一区二区三区视频在线观看 |