RabbitMQ 簡介

概述

RabbitMQ 是基於 AMQP 實現的一個開源消息組件,主要用於在分佈式系統中存儲轉發消息,由因高性能、高可用以及高擴展而出名的 Erlang 語言寫成。

特點

高可靠:RabbitMQ 提供了多種多樣的特性讓你在可靠性和性能之間做出權衡,包括持久化、發送應答、發佈確認以及高可用性。

高可用隊列:支持跨機器集羣,支持隊列安全鏡像備份,消息的生產者與消費者不論哪一方出現問題,均不會影響消息的正常發出與接收。

靈活的路由:所有的消息都會通過路由器轉發到各個消息隊列中,RabbitMQ 內建了幾個常用的路由器,並且可以通過路由器的組合以及自定義路由器插件來完成複雜的路由功能。

工作原理

消息從發送端到接收端的流轉過程即 RabbitMQ 的消息工作機制,請見下圖:

基本用法

共有 6 種基本用法:單對單、單對多、發佈訂閱模式、按路由規則發送接收、主題、RPC(即遠程存儲調用)。我們將介紹單對單、單對多和主題的用法。

1、單對單:單發送、單接收

2、單對多:一個發送端,多個接收端,如分佈式的任務派發

3、主題:Exchange Type 爲 topic,發送消息時需要指定交換機及 Routing Key,消費者的消息隊列綁定到該交換機並匹配到 Routing Key 實現消息的訂閱,訂閱後則可接收消息。只有消費者將隊列綁定到該交換機且指定的 Routing Key 符合匹配規則,才能收到消息。

其中 Routing Key 可以設置成通配符,如:* 或 #(* 表示匹配 Routing Key 中的某個單詞,# 表示任意的 Routing Key 的消息都能被收到)。如果 Routing Key 由多個單詞組成,則單詞之間用. 來分隔。

命名規範:

交換機名的命名建議:Ex{AppID}.{自定義 ExchangeName},隊列名的命名建議:MQ{AppID}.{自定義 QueueName} 。

好用的輪子

其中 EasyNetQ 是. NET 上 RabbitMQ 的領先客戶端 API,在 NuGet.org 上有超過 400 萬次下載。這是一個開放源代碼項目。

EasyNetQ 是爲了提供一個儘可能簡潔的適用與 RabbitMQ 的. NET 類庫。爲了實現這些目標,EasyNetQ 提供一種自認爲你會在. NET 下使用 RabbitMQ 的視圖。爲了保持使用靈活性,簡單起見,EasyNetQ 強制使用了一些簡單的約定。包括如下:

開源地址

更多功能見:

https://github.com/EasyNetQ/EasyNetQ

本文由 Readfog 進行 AMP 轉碼,版權歸原作者所有。
來源https://mp.weixin.qq.com/s/wC4R4n9kYEEIHp9MbG0TkA