.NET操作RabbitMQ組件EasyNetQ使用中文簡版文檔。
本文出自EasyNetQ官方文檔，內容為自己理解加翻譯。文檔地址：https://github.com/EasyNetQ/EasyNetQ/wiki/Quick-Start
EasyNetQ簡介
EasyNetQ是基於官方.NET組件RabbitMQ.Client 的又一層封裝，使用起來更加方便，開發者不用關心具體隊列聲明，路由聲明等細節，幾句簡單代碼即可發送消息到隊列，接收消息也很簡單，下面將簡單介紹EasyNetQ的使用方法。不知道什麽是RabbitMQ？您可以關閉網頁了。
安裝EasyNetQ
從NuGet上安裝即可，由於EasyNetQ是依賴RabbitMQ.Client所以，會同時安裝兩個dll。
PM> Install-Package EasyNetQ
連接RabbitMQ
使用EasyNetQ連接RabbitMQ，是在應用程序啟動時創建一個IBus對象，並且，在應用程序關閉時釋放該對象。RabbitMQ連接是基於IBus接口的，當IBus中的方法被調用，連接才會開啟。創建一個IBus對象的方法如下：
var bus = RabbitHutch.CreateBus(“host=myServer;virtualHost=myVirtualHost;username=mike;password=topsecret”);
根據上述代碼可以看出，連接字符串中是基於Key/Value形式的，每個Key中間用分號（;）斷開。其中host是必須要寫的，其他的值都是可以不用寫，會采用默認的配置。連接中可能用到的Key如下：
- host，host=localhost 或者host =192.168.1.102或者host=my.rabbitmq.com,如果用到集群配置的話，那麽可以用逗號將服務地址隔開，例如host=a.com,b.com,c.com
- virtualHost,虛擬主機，默認為‘/‘
- username,用戶登錄名
- password，用戶登錄密碼
- requestedHeartbeat,心跳設置，默認是10秒
- prefetchcount，默認是50
- pubisherConfirms，默認為false
- persistentMessages，消息持久化，默認為true
- product,產品名
- platform,平臺
- timeout，默認為10秒
關閉連接，可以使用 bus.Dispose();
EasyNetQ日誌（Logging）
EasyNetQ提供了一個日誌接口 IEasyNetQLogger
public interface IEasyNetQLogger
{
void DebugWrite(string format, params object[] args);
void InfoWrite(string format, params object[] args);
void ErrorWrite(string format, params object[] args);
void ErrorWrite(Exception exception);
}
內部默認用的是NullLogger，即什麽也不做，不記錄日誌。在測試的時候也可以用ConsoleLogger來顯示EasyNetQ運行中的各種信息。不過一般在正式使用環境中，可以自定義日誌並實現IEasyNetQLogger接口。然後在RabbitHutch.CreateBus的重載方法中註冊想用的日誌類型。（日誌中會記錄連接RabbitMQ的過程和隊列創建細節等信息，對於不懂RabbitMQ的同學，可能這些日誌沒有什麽意義）。代碼如下：
var logger = new MyLogger() // 繼承自 IEasyNetQLogger var bus = RabbitHutch.CreateBus(“my connection”, x => x.Register<IEasyNetQLogger>(_ => logger));
消息發布（Publish）
EasyNetQ支持最簡單的消息模式是發布和訂閱。發布消息後，任意消費者可以訂閱該消息，也可以多個消費者訂閱。並且不需要額外配置。首先，如上文中需要先創建一個IBus對象，然後，在創建一個可序列化的.NET對象。調用Publish方法即可。
var bus = RabbitHutch.CreateBus(...);
var message = new MyMessage { Text = "Hello Rabbit" }; bus.Publish<MyMessage>(message);
警告，Publish只顧發送消息到隊列，但是不管有沒有消費端訂閱，所以，發布之後，如果沒有消費者，該消息將不會被消費甚至丟失。
消息訂閱（Subscribe）
EasyNetQ提供了消息訂閱，當調用Subscribe方法時候，EasyNetQ會創建一個用於接收消息的隊列，不過與消息發布不同的是，消息訂閱增加了一個參數，subscribe_id.代碼如下：
bus.Subscribe<MyMessage>("my_subscription_id", msg => Console.WriteLine(msg.Text));
第一個參數是訂閱id，另外一個是delegate參數，用於處理接收到的消息。這裏要註意的是，subscribe_id參數很重要，假如開發者用同一個subscribeid訂閱了同一種消息類型兩次或者多次，RabbitMQ會以輪訓的方式給每個訂閱的隊列發送消息。接收到之後，其他隊列就接收不到該消息。如果用不同的subscribeid訂閱同一種消息類型，那麽生成的每一個隊列都會收到該消息。
舉個例子：出庫發貨，我們有五個商品倉庫，每個倉庫的商品都是一樣的，假如來了一堆訂單，那麽我們需要五個倉庫共同工作，分別處理訂單。而同樣，總倉庫需要知道總出貨量，正常情況下，可以用每個倉庫的出貨量相加即可。不過如果我們在總倉庫也監聽商品訂單消息，那麽，每次來訂單，總倉庫也都會收到一份，那麽可以作相應的統計了。
需要註意的是，在收到消息處理消息時候，不要占用太多的時間，會影響消息的處理效率，所以，遇到占用長時間的處理方法，最好用異步處理。代碼如下：
bus.SubscribeAsync<MyMessage>("subscribe_async_test", message =>
new WebClient().DownloadStringTask(new Uri("http://localhost:1338/?timeout=500"))
.ContinueWith(task =>
Console.WriteLine("Received: ‘{0}‘, Downloaded: ‘{1}‘",
message.Text,
task.Result)));
取消訂閱，可以用如下方法：
var subscriptionResult = bus.Subscribe<MyMessage>("sub_id", MyHandler);
...
subscriptionResult.Dispose();
或者直接IBus.Dispose();
消息發送（Send）和接收（Receive）
與Publish/Subscribe略有不同的是，Send/Receive 可以自己定義隊列名稱。
bus.Send("my.queue", new MyMessage{ Text = "Hello Widgets!" });
bus.Receive<MyMessage>("my.queue", message => Console.WriteLine("MyMessage: {0}", message.Text));
並且，也可以在同一個隊列上發送不同的消息類型，Receive方法可以這麽寫：
bus.Receive("my.queue", x => x
.Add<MyMessage>(message => deliveredMyMessage = message)
.Add<MyOtherMessage>(message => deliveredMyOtherMessage = message));
如果消息到達隊列，但是沒有發現相應消息類型的處理時，EasyNetQ會發送一條消息到error隊列，並且，帶上一個異常信息：No handler found for message type <message type>。與Subscribe類型，如果在同一個隊列，同一個消息類型，多次調用Receive方法時，消息會通過輪詢的形式發送給每個Receive端。
消息路由（Topic Based Routing）
Publish方法，可以加一個topic參數。
bus.Publish(message, "X.A");
消息訂閱方可以通過路由來過濾相應的消息。
* 匹配一個字符
#匹配0個或者多個字符
所以 X.A.2 會匹配到 "#", "X.#", "*.A.*" 但不會匹配 "X.B.*" 或者 "A". 當消息訂閱需要用到topic時候，需要調用Subscribe的重載方法
bus.Subscribe("my_id", handlerOfXDotStar, x => x.WithTopic("X.*"));
bus.Subscribe("my_id", handlerOfStarDotB, x => x.WithTopic("*.B"));
上述這種方式，會將消息輪詢發送給兩個訂閱者，如果只需要一個訂閱者的話，可以這麽調用：
bus.Subscribe("my_id", handler, x => x.WithTopic("X.*").WithTopic("*.B"));
總結
以上就是EasyNetQ的一些基本用法了，是不是很簡單呢，就這麽輕松實現了消息隊列的使用。當然，要深入內部還是有很多東西的。比如依賴註入，自定義EasyNetQ組件，RPC實現等。而且，他的源碼也是比較有參考價值的，相對於之前自己寫的基於RabbitMQ的封裝，自己的簡直是不能看呀。希望本文能給讀完的你帶來幫助。
http://www.cnblogs.com/panzi/p/6337568.html
.NET操作RabbitMQ組件EasyNetQ使用中文簡版文檔。