RabbitMQ隊列初探（一）

一簡介

消息隊列提供了一個異步通信協(xié)議泥技，消息的發(fā)送者不用一直等待消息是否被成功處理，而是發(fā)完消息立即返回。消息被暫存于隊列之中，對消息感興趣的消費者會訂閱消息并處理它們界拦。

消息隊列使用場景：

1 ：需要將同一條消息發(fā)送給多個感興趣的系統(tǒng)斋否，這時用消息隊列不用把同一條消息分別發(fā)送給它們

2：系統(tǒng)的同步處理方式嚴(yán)重影響性能及吞吐量時魄健，如用戶訂單處理妄荔、消息通知等修改為異步處理方式

二服務(wù)安裝

1 服務(wù)環(huán)境安裝：erlang環(huán)境是RabbitMQ運(yùn)行的前提環(huán)境，必須安裝迄薄。下載并安裝最新版Eralng OTP For Windows

2 服務(wù)安裝：從RabbitMQ官網(wǎng)（http://www.rabbitmq.com/download.html）下載最新安裝包安裝默認(rèn)安裝的Rabbit MQ 監(jiān)聽端口是5672琅关。

2.1運(yùn)行命令提示符（管理員權(quán)限）定位到RabbitMQ安裝目錄下

2.2 運(yùn)行下面命令來啟用管理插件：rabbitmq-plugins enable rabbitmq_management

2.3服務(wù)重啟

rabbitmq-service install? //RabbitMq服務(wù)安裝

rabbitmq-service? start? //服務(wù)啟動

2.4打開瀏覽器，輸入http://localhost:15672/回車，會要求輸入用戶名和密碼涣易，用默認(rèn)的guest/guest

這是RabbitMQ的監(jiān)控界面画机，到此RabbitMQ安裝成功。

三術(shù)語解釋

RabbitMQ 是信息傳輸?shù)闹虚g者新症。本質(zhì)上步氏，他從生產(chǎn)者（producers）接收消息，轉(zhuǎn)發(fā)這些消息給消費者（consumers）.換句話說徒爹，他能夠按根據(jù)你指定的規(guī)則進(jìn)行消息轉(zhuǎn)發(fā)荚醒、緩沖、和持久化RabbitMQ 中有一些概念術(shù)語隆嗅，主要包括以下幾個：Broker界阁、Exchange、Queue胖喳、Binding泡躯、Routingkey、Producter丽焊、Consumer较剃、Channel。

1.Broker

簡單來說就是消息隊列服務(wù)器的實體技健。

2.Exchange

接收消息写穴，轉(zhuǎn)發(fā)消息到綁定的隊列上，指定消息按什么規(guī)則凫乖，路由到哪個隊列确垫。

3.Queue

消息隊列載體弓颈，用來存儲消息帽芽，相同屬性的 queue 可以重復(fù)定義，每個消息都會被投入到一個或多個隊列翔冀。

4.Binding

綁定导街，它的作用就是把 Exchange 和 Queue 按照路由規(guī)則綁定起來。

5.RoutingKey

路由關(guān)鍵字纤子，Exchange 根據(jù)這個關(guān)鍵字進(jìn)行消息投遞搬瑰。

6.Producter

消息生產(chǎn)者，產(chǎn)生消息的程序控硼。

7.Consumer

消息消費者泽论，接收消息的程序。

8.Channel

消息通道卡乾，在客戶端的每個連接里可建立多個 Channel翼悴，每個 channel 代表一個會話。

四消息傳遞過程

RabbitMQ消息傳遞過程：生產(chǎn)者創(chuàng)建消息幔妨，然后發(fā)布到RabbitMQ服務(wù)器鹦赎。消息的內(nèi)容包含兩部分內(nèi)容谍椅，消息標(biāo)簽和消息體。消息體就是你想要傳遞的數(shù)據(jù)古话。它可以是任何格式的數(shù)據(jù)雏吭，例如JSON數(shù)據(jù)。消息標(biāo)簽用來描述消息體陪踩，RabbitMQ服務(wù)器通過它決定由誰獲得消息體的內(nèi)容杖们。消費者連接到RabbitMQ,并訂閱到隊列（Quenue）上。我們可以把消息隊列想象成一個具體的郵箱肩狂，每當(dāng)生產(chǎn)者發(fā)送的消息到達(dá)郵箱時胀莹，RabbitMQ會根據(jù)消息標(biāo)簽，把消息體發(fā)送到訂閱或者監(jiān)聽的消費者婚温。當(dāng)然消費者接受到消息只是消息的一部分：消息體描焰。在消息的路由中，消息的標(biāo)簽并沒有隨消息體一塊傳遞栅螟。如果消費者需要知道消息是由誰生產(chǎn)的的話荆秦，就要看消息體中是否包含發(fā)送方（消息生產(chǎn)者）的信息。其實整個過程很簡單力图，生產(chǎn)者生產(chǎn)消息步绸，消費者消費消息。你的應(yīng)用程序既可以是生產(chǎn)者也可以作為消費者吃媒。應(yīng)用程序（生產(chǎn)者/消費者）和Rabbit代理服務(wù)器之間創(chuàng)建一條TCP連接瓤介。一旦TCP連接創(chuàng)建，應(yīng)用程序就可以創(chuàng)建一條AMQP信道赘那。信道是創(chuàng)立在TCP連接之上,RabbitMQ信息都是通過信道發(fā)送出去并且每條信道會創(chuàng)建一個唯一ID（RabbitMQ系統(tǒng)會自動記錄）刑桑。一般不通過TCP連接發(fā)送消息，TCP連接的建立或者銷毀很費內(nèi)存募舟。一個TCP連接上可以創(chuàng)建任意多的信道祠斧。

五 RabbitMQ(c#) Hello World

1 消息生產(chǎn)者

using System;

using RabbitMQ.Client;

using System.Text;

class Send

{

public static void Main()

{

//設(shè)置MabbitMQ所在主機(jī)ip或者主機(jī)名

var factory = new ConnectionFactory() { HostName = "localhost" };

using(var connection = factory.CreateConnection())//創(chuàng)建一個連接

using(var channel = connection.CreateModel())//創(chuàng)建一個信道

{

channel.QueueDeclare(queue: "hello",durable: false,exclusive: false,autoDelete: false,arguments:null);//創(chuàng)建隊列

string message = "Hello World!";//要發(fā)送的消息

var body = Encoding.UTF8.GetBytes(message);

channel.BasicPublish(exchange: "",routingKey: "hello",basicProperties: null,

body: body);//發(fā)送消息

Console.WriteLine(" [x] Sent {0}", message);

}

Console.WriteLine(" Press [enter] to exit.");

Console.ReadLine();

}

2 消息消費者

class Receive

{

public static void Main()

{

var factory = new ConnectionFactory() { HostName = "localhost" };//設(shè)置MabbitMQ所在主機(jī)ip或者主機(jī)名

using(var connection = factory.CreateConnection())

using(var channel = connection.CreateModel())//聲明信道

{

channel.QueueDeclare(queue: "hello",//聲明隊列

durable: false,

exclusive: false,

autoDelete: false,

arguments: null);

var consumer = new EventingBasicConsumer(channel);//訂閱模式 (有消息到達(dá)將被自動接收) 消費者

consumer.Received += (model, ea) =>//注冊接收事件

{

var body = ea.Body;

var message = Encoding.UTF8.GetString(body);

Console.WriteLine(" [x] Received {0}", message);

};

channel.BasicConsume(queue: "hello",

noAck: true,//接受到消息自動應(yīng)答

consumer: consumer);