RabbitMQ使用

codeKK 發(fā)布于2019-06-28 14:18 / 1097人閱讀

摘要：的定義是使用語言開發(fā)的開源消息隊(duì)列系統(tǒng)，完整的實(shí)現(xiàn)了高級抽象層消息通信協(xié)議。交換機(jī)接受發(fā)送的消息，并根據(jù)綁定規(guī)則轉(zhuǎn)發(fā)到對應(yīng)的隊(duì)列。默認(rèn)是無名交換使用空字符串標(biāo)識。消息隊(duì)列是內(nèi)部對象，用于存儲(chǔ)未被消費(fèi)的消息。

RabbitMQ的定義

RabbitMQ是使用erlang語言開發(fā)的開源消息隊(duì)列系統(tǒng)，完整的實(shí)現(xiàn)了AMPQ（高級抽象層消息通信協(xié)議）。

Mac下RabbitMQ安裝

使用Homebrew安裝

$ brew install rabbitmq

修改 ~/.bash_profile 配置環(huán)境變量：

# RabbitMQ Config
export PATH=$PATH:/usr/local/sbin

重啟配置

$ source ~/.bash_profile

啟動(dòng)mq服務(wù)（后臺(tái)啟動(dòng)為rabbitmq-server -detached）

$ rabbitmq-server

登錄管理界面 http://127.0.0.1:15672 賬號密碼為：guest

客戶端

RabbitMQ官方提供了三種PHP可用的擴(kuò)展：php-amqp，php-rabbit，php-amqplib

php-amqplib 安裝

php的客戶端現(xiàn)在常用的是php-amqplib

直接拉取github上面的代碼

    $ git clone https://github.com/php-amqplib/php-amqplib.git

composer安裝（官網(wǎng)提供）

將composer.json文件添加到您的項(xiàng)目中

{

 “require”：{
     “php-amqplib / php-amqplib”：“> = 2.6.1”
}

}

下載依賴

$ composer install

概念

Virtual vhosts

virtual vhosts是一個(gè)命名空間，可以存在多個(gè)exchange和queue。實(shí)現(xiàn)了環(huán)境（用戶，用戶組，exchange，queue）隔離，是權(quán)限控制的最小粒度。默認(rèn)的virtual host為/。

Exchange(交換機(jī))

接受producer發(fā)送的消息，并根據(jù)binding綁定規(guī)則轉(zhuǎn)發(fā)到對應(yīng)的隊(duì)列。默認(rèn)是無名交換使用空字符串標(biāo)識。exchange type(交換機(jī)類型)包含四種類型：direct，topic，headers，fanout

direct

轉(zhuǎn)發(fā)消息到routigKey指定的隊(duì)列

topic

類似于direct類型，只不過routigKey為一個(gè)句點(diǎn)號“.”分隔的字符串

*可以替代一個(gè)字。

＃可以替換零個(gè)或多個(gè)單詞。

headers

根據(jù)發(fā)送的消息內(nèi)容中的headers屬性進(jìn)行匹配。

fanout

將所有收到的消息廣播到所有已知的隊(duì)列。

Queue(消息隊(duì)列)

queue是mq內(nèi)部對象，用于存儲(chǔ)未被customer消費(fèi)的消息。相同屬性的queue可以重復(fù)定義，每個(gè)消息都會(huì)被投入到一個(gè)或多個(gè)隊(duì)列。

Binding(綁定)

binding是將exchange和queue按照路由規(guī)則綁定起來?？梢岳斫鉃閎inding是exchange和queue之間的關(guān)系

Connection（連接）

消息tcp連接

Channel(信道)

每個(gè)connection里，可建立多個(gè)channel，每個(gè)channel代表一個(gè)會(huì)話任務(wù)。做到盡量共用connection

RabbitMQ使用示例

1.send.php:

    require_once __DIR__ . "/vendor/autoload.php";
    use PhpAmqpLibConnectionAMQPStreamConnection;
    use PhpAmqpLibMessageAMQPMessage;

    // 創(chuàng)建連接
    $connection = new AMQPStreamConnection("localhost", 5672, "guest", "guest");
    // 創(chuàng)建channel，多個(gè)channel可以共用連接
    $channel = $connection->channel();

    // 創(chuàng)建交換機(jī)以及隊(duì)列（如果已經(jīng)存在，不需要重新再次創(chuàng)建并且綁定）

    // 創(chuàng)建直連的交換機(jī)
    $channel->exchange_declare("direct_logs", "direct", false, false, false);
    // 創(chuàng)建隊(duì)列
    $channel->queue_declare("hello", false, false, false, false);
    // 交換機(jī)跟隊(duì)列的綁定，
    $channel->queue_bind("hello", "direct_logs", "routigKey");


    // 設(shè)置消息bady傳送字符串logs(消息只能為字符串，建議消息均json格式)
    $msg = new AMQPMessage("logs");
    // 發(fā)送數(shù)據(jù)到對應(yīng)的交換機(jī)direct_logs并設(shè)置對應(yīng)的routigKey
    $channel->basic_publish($msg, "direct_logs", "routigKey");

2.receive.php:

    require_once __DIR__ . "/vendor/autoload.php";
    use PhpAmqpLibConnectionAMQPStreamConnection;

    // 創(chuàng)建連接
    $connection = new AMQPStreamConnection("localhost", 5672, "guest", "guest");
    // 創(chuàng)建channel，多個(gè)channel可以共用連接
    $channel = $connection->channel();

    // 可能會(huì)在數(shù)據(jù)發(fā)布之前啟動(dòng)消費(fèi)者，所以我們要確保隊(duì)列存在，然后再嘗試從中消費(fèi)消息。

    // 創(chuàng)建直連的交換機(jī)
    $channel->exchange_declare("direct_logs", "direct", false, false, false);
    // 創(chuàng)建隊(duì)列
    $channel->queue_declare("hello", false, false, false, false);
    // 交換機(jī)跟隊(duì)列的綁定，
    $channel->queue_bind("hello", "direct_logs", "routigKey");

    // 回調(diào)函數(shù)
    $callback = function ($msg) {
        echo $msg->body;
    };

    // 啟動(dòng)隊(duì)列消費(fèi)者
    $channel->basic_consume("hello3", "", false, true, false, false, $callback);
    // 判斷是否存在回調(diào)函數(shù)
    while(count($channel->callbacks)) {
        // 此處為執(zhí)行回調(diào)函數(shù)
        $channel->wait();
    }

RabbitMQ備注

非持久化會(huì)導(dǎo)致，隊(duì)列重啟，數(shù)據(jù)丟失

exchange持久化，在聲明durable參數(shù)時(shí)指定為true

queue持久化，在聲明durable參數(shù)時(shí)指定true

消息持久化，實(shí)例化AMQPMessage類時(shí)指定delivery_mode為2

exchange和queue是否持久化需要一致才能綁定

消費(fèi)者設(shè)置手動(dòng)ack，在聲明no_ack參數(shù)時(shí)指定false

隊(duì)列消息異常需要將消息刪除并再次發(fā)送同樣的消息置于末尾并手動(dòng)記錄日志

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/26097.html

發(fā)表評論

登陸后可評論

0條評論

codeKK

男|高級講師

我要關(guān)注我要私信

TA的文章

debian系統(tǒng)更換軟件源鏡像優(yōu)化國內(nèi)下載速度

閱讀 3706·2021-09-30 09:59
記錄使用微PE工具箱快速制作U盤系統(tǒng)盤安裝系統(tǒng)工具

閱讀 2373·2021-09-13 10:34
打造專屬自己的html5拼圖小游戲

閱讀 590·2019-08-30 12:58
TypeScript 、React、 Redux和Ant-Design的最佳實(shí)踐

閱讀 1522·2019-08-29 18:42
阿里云攜手優(yōu)锘發(fā)布智慧園區(qū)可視化產(chǎn)品

閱讀 2215·2019-08-26 13:44
【Vue項(xiàng)目總結(jié)】后臺(tái)管理項(xiàng)目總結(jié)

閱讀 2936·2019-08-23 18:12
JavaScript數(shù)據(jù)結(jié)構(gòu)與算法——數(shù)組

閱讀 3332·2019-08-23 15:10
馬上收藏！史上最全正則表達(dá)式合集

閱讀 1637·2019-08-23 14:37

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！

RabbitMQ使用

直接拉取github上面的代碼

composer安裝（官網(wǎng)提供）

direct

topic

headers

fanout

相關(guān)文章

**基于RabbitMQ的MQTT插件搭建MQTT服務(wù)，使用MQTTX進(jìn)行收發(fā)測試**

RabbitMQ使用教程（一）RabbitMQ環(huán)境安裝配置及Hello World示例

Spring Boot 配置多源的 RabbitMQ

**慕課網(wǎng)_《RabbitMQ消息中間件極速入門與實(shí)戰(zhàn)》學(xué)習(xí)總結(jié)**

rabbitmq前言說明

發(fā)表評論

0條評論

codeKK

男|高級講師

TA的文章

debian系統(tǒng)更換軟件源鏡像優(yōu)化國內(nèi)下載速度

記錄使用微PE工具箱快速制作U盤系統(tǒng)盤安裝系統(tǒng)工具

打造專屬自己的html5拼圖小游戲

TypeScript 、React、 Redux和Ant-Design的最佳實(shí)踐

阿里云攜手優(yōu)锘發(fā)布智慧園區(qū)可視化產(chǎn)品

【Vue項(xiàng)目總結(jié)】后臺(tái)管理項(xiàng)目總結(jié)

JavaScript數(shù)據(jù)結(jié)構(gòu)與算法——數(shù)組

馬上收藏！史上最全正則表達(dá)式合集

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！

RabbitMQ使用

直接拉取github上面的代碼

composer安裝（官網(wǎng)提供）

direct

topic

headers

fanout

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動(dòng)

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！