摘要

Message Queue消息隊(duì)列，簡稱MQ，是一種應(yīng)用程序?qū)?yīng)用程序的通信方法，應(yīng)用程序通過讀寫出入隊(duì)列的消息來通信，而無需專用連接來鏈接它們。消息傳遞指的是程序之間通過在消息中發(fā)送數(shù)據(jù)進(jìn)行通信，而不是通過直接調(diào)用彼此通信。

MQ是消費(fèi)-生產(chǎn)者模型的一個(gè)典型代表，一端往消息隊(duì)列中不斷寫入消息，而另一端則可以讀取或者訂閱隊(duì)列中的消息。

安裝

官網(wǎng)地址：http://www.rabbitmq.com/download.html。

下載后，需要安裝RabbitMQ服務(wù)。如果沒有Erlang環(huán)境會彈出下面的提示：

下載Erlang環(huán)境并安裝

地址：http://www.erlang.org/downloads

然后安裝RabbitMQ，安裝成功后會在服務(wù)中看到該服務(wù)。

一個(gè)例子

新建一個(gè)控制臺應(yīng)用程序，并使用Nuget引入RabbitMQ

?代碼如下：

當(dāng)type等于1時(shí)，客戶端為生產(chǎn)者，2時(shí)為消費(fèi)者

/// <summary>/// RabbitMQ/// </summary>class Program{static void Main(string[] args){string type = Console.ReadLine();//生產(chǎn)者if (type=="1"){ConnectionFactory factory = new ConnectionFactory();factory.HostName = "127.0.0.1";//默認(rèn)端口factory.Port = 5672;using (IConnection conn = factory.CreateConnection()){using (IModel channel = conn.CreateModel()){//在MQ上定義一個(gè)持久化隊(duì)列，如果名稱相同不會重復(fù)創(chuàng)建channel.QueueDeclare("MyRabbitMQ", true, false, false, null);while (true){string message = string.Format("Message_{0}", Console.ReadLine());byte[] buffer = Encoding.UTF8.GetBytes(message);IBasicProperties properties = channel.CreateBasicProperties();properties.DeliveryMode = 2;channel.BasicPublish("", "MyRabbitMQ", properties, buffer);Console.WriteLine("消息發(fā)送成功：" + message);}}}}else{//消費(fèi)者ConnectionFactory factory = new ConnectionFactory();factory.HostName = "127.0.0.1";//默認(rèn)端口factory.Port = 5672;using (IConnection conn = factory.CreateConnection()){using (IModel channel = conn.CreateModel()){//在MQ上定義一個(gè)持久化隊(duì)列，如果名稱相同不會重復(fù)創(chuàng)建channel.QueueDeclare("MyRabbitMQ", true, false, false, null);//輸入1，那如果接收一個(gè)消息，但是沒有應(yīng)答，則客戶端不會收到下一個(gè)消息channel.BasicQos(0, 1, false);Console.WriteLine("Listening...");//在隊(duì)列上定義一個(gè)消費(fèi)者QueueingBasicConsumer consumer = new QueueingBasicConsumer(channel);//消費(fèi)隊(duì)列，并設(shè)置應(yīng)答模式為程序主動應(yīng)答channel.BasicConsume("MyRabbitMQ", false, consumer);while (true){//阻塞函數(shù)，獲取隊(duì)列中的消息BasicDeliverEventArgs ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();byte[] bytes = ea.Body;string str = Encoding.UTF8.GetString(bytes);Console.WriteLine("隊(duì)列消息:" + str.ToString());//回復(fù)確認(rèn)channel.BasicAck(ea.DeliveryTag, false);}}}}}}

測試

啟動生產(chǎn)者

啟動消費(fèi)者

使用生產(chǎn)者入隊(duì)，1，2，3，4，5，6，7，8

消費(fèi)者

?參考文章

http://www.cnblogs.com/qy1141/p/4054135.html?utm_source=tuicool&utm_medium=referral

總結(jié)

以上是生活随笔為你收集整理的[c#]RabbitMQ的简单使用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。