生活随笔
收集整理的這篇文章主要介紹了
RabbitMQ入门教程——.NET客户端使用
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
眾所周知RabbitMQ使用的是AMQP協(xié)議。我們知道AMQP是一種網(wǎng)絡(luò)協(xié)議，能夠支持符合要求的客戶端應(yīng)用和消息中間件代理之間進行通信。
其中消息代理扮演的角色就是從生產(chǎn)者那兒接受消息，并根據(jù)既定的路由規(guī)則把接受到的消息發(fā)送給消息的處理者又稱消費者。由此可以看出RabbitMQ在整個消息發(fā)送，處理的過程中有三個比較重要的角色：
生產(chǎn)者：producer，消息生產(chǎn)者，就是投遞消息的程序
消息代理：broker，簡單來說就是消息隊列服務(wù)器實體，這里簡單理解為我們安裝的RabbitMQ服務(wù)
消費者：consumer，消息消費者，就是接受消息的程序
接下來我們將以一個簡單的控制臺程序來實現(xiàn)消息隊列的發(fā)送及接收（使用.NET版RabbitMQ客戶端）：
主要功能為：?一個producer發(fā)送消息，一個consumer接收消息，并在控制臺打印出來。
使用Nuget添加RabbitMQ.Client程序包至項目中
Install-Package RabbitMQ.Client
創(chuàng)建消息的生產(chǎn)者 Producer.cs ,發(fā)送一條消息給消費者
using RabbitMQ.Client; using System; using System.Text; namespace RabbitMQProducer { ????public class Producer ????{ ????????public static void Send() ????????{ ????????????//創(chuàng)建連接連接到RabbitMQ服務(wù)器，就是一個位于客戶端和Broker之間的TCP連接，建議共用此TCP連接，每次使用時創(chuàng)建一個新的channel即可， ????????????var factory = new ConnectionFactory(); ????????????IConnection connection = null; ????????????//方式1：使用AMQP協(xié)議URL amqp://username:password@hostname:port/virtual host 可通過http://127.0.0.1:15672/ RabbitMQWeb管理頁面查看每個參數(shù)的具體內(nèi)容 ????????????factory.Uri = "amqp://guest:guest@127.0.0.1:5672//"; ????????????connection = factory.CreateConnection(); ????????????方式2：使用ConnectionFactory屬性賦值 ????????????//factory.UserName = ConnectionFactory.DefaultUser; ????????????//factory.Password = ConnectionFactory.DefaultPass; ????????????//factory.VirtualHost = ConnectionFactory.DefaultVHost; ????????????//factory.HostName = "127.0.0.1"; //設(shè)置RabbitMQ服務(wù)器所在的IP或主機名 ????????????//factory.Port = AmqpTcpEndpoint.UseDefaultPort; ????????????//connection = factory.CreateConnection(); ????????????方式3：使用CreateConnection方法創(chuàng)建連接，默認使用第一個地址連接服務(wù)端，如果第一個不可用會依次使用后面的連接 ????????????//List<AmqpTcpEndpoint> endpoints = new List<AmqpTcpEndpoint>() { ????????????// new AmqpTcpEndpoint() { HostName="localhost1",Port=5672}, ????????????// new AmqpTcpEndpoint() { HostName="localhost2",Port=5672}, ????????????// new AmqpTcpEndpoint() { HostName="localhost3",Port=5672}, ????????????// new AmqpTcpEndpoint() { HostName="localhost4",Port=5672} ????????????//}; ????????????//connection = factory.CreateConnection(endpoints); ????????????using (connection) ????????????{ ????????????????//創(chuàng)建一個消息通道，在客戶端的每個連接里，可建立多個channel，每個channel代表一個會話任務(wù)。類似與Hibernate中的Session ????????????????//AMQP協(xié)議規(guī)定只有通過channel才能指定AMQP命令，所以僅僅在創(chuàng)建了connection后客戶端還是不能發(fā)送消息的,必須要創(chuàng)建一個channel才行 ????????????????//RabbitMQ建議客戶端線程之間不要共用Channel,至少要保證共用Channel的線程發(fā)送消息必須是串行的，但是建議盡量共用Connection ????????????????using (IModel channel = connection.CreateModel()) ????????????????{ ????????????????????//創(chuàng)建一個queue（消息隊列） ????????????????????channel.QueueDeclare( ????????????????????????queue: "hello", ????????????????????????durable: false, ????????????????????????exclusive: false, ????????????????????????autoDelete: false, ????????????????????????arguments: null); ????????????????????string message = "你好消費者，我是生產(chǎn)者發(fā)送的消息"; ????????????????????//往隊列中發(fā)出一條消息 使用了默認交換機并且綁定路由鍵（route key）與隊列名稱相同 ????????????????????channel.BasicPublish( ????????????????????????exchange: "", ????????????????????????routingKey: "hello", ????????????????????????basicProperties: null, ????????????????????????body: Encoding.UTF8.GetBytes(message)); ????????????????????Console.WriteLine($"我是生產(chǎn)者，我發(fā)送了一條消息{message}"); ????????????????????Console.WriteLine(" Press [enter] to exit."); ????????????????????Console.ReadLine(); ????????????????} ????????????} ????????} ????} } ?
注意：1.隊列只會在它不存在的時候創(chuàng)建，多次聲明并不會重復(fù)創(chuàng)建。
2.信息的內(nèi)容是字節(jié)數(shù)組，也就意味著可以傳遞任何數(shù)據(jù)。
3.創(chuàng)建消息的消費者Consumer.cs ,從隊列中獲取消息并打印到屏幕
using RabbitMQ.Client; using RabbitMQ.Client.Events; using System; using System.Text; namespace RabbitMQConsumer { ????public class Consumer ????{ ????????public static void Receive() ????????{ ????????????var factory = new ConnectionFactory(); ????????????factory.Uri = "amqp://guest:guest@127.0.0.1:5672//"; ????????????using (var connection = factory.CreateConnection()) ????????????{ ????????????????using (var channel = connection.CreateModel()) ????????????????{ ????????????????????//聲明隊列，主要為了防止消息接收者先運行此程序，隊列還不存在時創(chuàng)建隊列 ????????????????????channel.QueueDeclare( ????????????????????????queue: "hello", ????????????????????????durable: false, ????????????????????????exclusive: false, ????????????????????????autoDelete: false, ????????????????????????arguments: null); ????????????????????//創(chuàng)建事件驅(qū)動的消費者類型，盡量不要使用while(ture)循環(huán)來獲取消息 ????????????????????EventingBasicConsumer consumer = new EventingBasicConsumer(channel); ????????????????????consumer.Received += (model, ea) => ????????????????????{ ????????????????????????var body = ea.Body; ????????????????????????var message = Encoding.UTF8.GetString(body); ????????????????????????Console.WriteLine(" 我是消費者我接收到消息： {0}", message); ????????????????????}; ????????????????????//指定消費隊列 ????????????????????channel.BasicConsume(queue: "hello", ?????????????????????????????????????????noAck: true, ?????????????????????????????????????????consumer: consumer); ????????????????????Console.WriteLine(" Press [enter] to exit."); ????????????????????Console.ReadLine(); ????????????????} ????????????} ????????} ????} } ?
消息隊列的使用過程大致如下：
- CreateConnection 創(chuàng)建一個連接連接到broker
- CreateModel 創(chuàng)建一個channel 使用它來發(fā)送AMQP指令
- ExchangeDeclare 創(chuàng)建一個exchange 對消息進行路由
- QueueDeclare 創(chuàng)建一個queue 消息隊列 這是一個裝載消息的容器
- QueueBind 把exchange和queue按照路由規(guī)則綁定起來
- BasicPublish 往隊列中發(fā)送一條消息
- BasicConsume 從隊列中獲取一條消息
exchange接收到消息后，就根據(jù)消息的key和已經(jīng)設(shè)置的binding，進行消息路由，將消息投遞到一個或多個隊列里。
本文中由于使用了默認交換機所以并沒有用到 ExchangeDeclare和 QueueBind兩個方法
默認交換機實際上是一個由消息代理預(yù)先聲明好的沒有名字（名字為空字符串）的直連交換機。它有一個特殊的屬性使得它對于簡單應(yīng)用特別有用處：那就是每個新建隊列（queue）都會自動綁定到默認交換機上，綁定的路由鍵（routing key）名稱與隊列名稱相同
轉(zhuǎn)載于:https://www.cnblogs.com/AlvinLee/p/6141834.html
總結(jié)
以上是生活随笔為你收集整理的RabbitMQ入门教程——.NET客户端使用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。
