持久化和應答機制Ack

消息隊列中間件系列的最后一篇了，RabbitMQ消息的持久化、確認機制、死信隊列、負載均衡等一系列進行說明。

消息持久化

• 當RabbitMq重啟以后，未消費的消息，可以在服務重啟后繼續(xù)消費，不會丟失。

應答機制Ack

兩種方式：一種是自動確認，一種是手動確認

• 自動確認就是消費者接收消息以后，立即ack，然后再慢慢處理業(yè)務邏輯，假如業(yè)務邏輯出現(xiàn)異常，消息也會被確認的。
• 手動確認，消費者接收消息以后，消息狀態(tài)被置為unack狀態(tài)，然后由業(yè)務邏輯指定ack的位置，假如沒有手動ack，則mq中的消息不回減少。

死信隊列

死信隊列 DLX(Dead-Letter-Exchange) 也可以成為死信交換機，就是當一個隊列中的消息變成死信以后，會被重新發(fā)送到另一個交換機，這個交換機就是DLX，而綁定DLX的隊列就是死信隊列。

死信隊列的成因：

**消息被拒絕，**消費者中使用 （basic.reject/basic.nack），并且 requeue = false , 消息被拒絕接收后就會進入到死信隊列中。

# 消費者
$callback = function ($msg) {
   // 拒絕接收消息
   $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
};
$channel->basic_qos(null, 1, null);
$channel->basic_consume($queueName,'', false,false,false,false,$callback);

**消息過期,**可以使用 x-message-ttl 參數(shù)設置當前隊列中所有消息的過期時間（單位毫秒）。一旦消息過期，就會從隊列中刪除。

// 在正常隊列中設置消息過期時間
$channel->exchange_declare('logs', 'direct',false, false, false);
$args = new AMQPTable([
   // 消息過期時間
   'x-message-ttl'             => 20000,
   // 死信交換機
   'x-dead-letter-exchange'    => 'dead-exc',
   // 死信路由鍵
   'x-dead-letter-routing-key' => 'dead-key'
]);
$channel->queue_declare($queue_name, false, true,false,false,false,$args);
$channel->queue_bind($queue_name, 'logs');

隊列達到最大長度: x-max-length 設置最大消息數(shù),x-max-length-bytes 設置最大長度（以字節(jié)為單位）。如果設置了兩個參數(shù)，則兩者都將適用，將強制執(zhí)行首先達到的限制。

$args = new AMQPTable([
// 設置最大消息數(shù)
   'x-max-length' => 2,
   'x-dead-letter-exchange'    => 'dead-exc',
   'x-dead-letter-routing-key' => 'dead-key'
]);

設置死信隊列，只需要定義隊列的時候設置x-dead-letter-exchange指定交換機就可以了

延時隊列

延時隊列就是當消息發(fā)送以后，并不想讓消費者立刻拿到消息，而是等待特定時間后消費者才能拿到消息來消費。

集群模式

• 允許生產(chǎn)者和消費者在RabbitMQ節(jié)點崩潰的情況下繼續(xù)運行。
• 允許通過添加更多的節(jié)點來擴展消息通信的吞吐量。

RabbitMQ會始終記錄以下四種類型的內(nèi)部元數(shù)據(jù)：

• 隊列元數(shù)據(jù)，隊列名稱和它們的屬性（是否持久化，是否自動刪除）
• 交換機元數(shù)據(jù)，交換器類型、名稱和屬性
• 綁定元數(shù)據(jù)，一張簡單的表格展示了如何將消息路由到隊列
• vhost元數(shù)據(jù)，為vhost內(nèi)的隊列、交換機和綁定提供命名空間和安全屬性

RabbitMQ集群分為3個模式，主備模式，鏡像模式，異地多活模式。

• 主備模式，從節(jié)點相當于主節(jié)點的鏈接，所有從節(jié)點收到的請求，真實轉(zhuǎn)向的都是主節(jié)點，一般在并發(fā)和數(shù)據(jù)不是特別多的情況下使用，當主節(jié)點掛掉會從備份的節(jié)點中選擇一個節(jié)點出來作為主節(jié)點對外提供服務。
• 鏡像模式，將需要消費的隊列變成鏡像隊列，存在于多個節(jié)點，這樣就可以實現(xiàn)RabbitMQ的HA高可用，作用就是消息實體會主動在鏡像節(jié)點之間實現(xiàn)同步，任何一個節(jié)點宕機都都關(guān)系，保證100%數(shù)據(jù)不丟失，在實際工作中用的最多的。
• 異地多活模式，用來實現(xiàn)異地的數(shù)據(jù)復制，使用多活模式需要借助federation插件來實現(xiàn)集群間或節(jié)點間的消費復制，廣泛用于多互聯(lián)網(wǎng)公司。

以上就是消息隊列中間件 - RabbitMQ消息的持久化、確認機制、死信隊列的詳細內(nèi)容，更多關(guān)于消息隊列中間件 - RabbitMQ的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論