RabbitMQ官網官方介紹: 譯文: RabbitMQ是目前部署最廣泛的開源消息代理(何為代理?可以理解為一個提供功能服務的中間件)。 在全球範圍內的大小企業中的生產環境中,RabbitMQ的部署兩已經超過了35000,它也是目前最受歡迎的開源消息代理(沒有之一)。 RabbitMQ是輕量級的,並 ...
RabbitMQ官網官方介紹:
譯文:
RabbitMQ是目前部署最廣泛的開源消息代理(何為代理?可以理解為一個提供功能服務的中間件)。
在全球範圍內的大小企業中的生產環境中,RabbitMQ的部署兩已經超過了35000,它也是目前最受歡迎的開源消息代理(沒有之一)。
RabbitMQ是輕量級的,並且很容易部署在伺服器和雲上。它支持多個消息傳遞協議。RabbitMQ可以部署在分散式和集中式的配置中,用來滿足高規模以及高可用性的需求。
下麵通過一個demo來演示RabbitMQ的最基礎的使用方法:
* 在這裡我們假定讀者已經成功安裝了RabbitMQ,並且啟用了該服務。一個Producer向隊列中插入數據,另一個Customer從隊列中取數據。
在這個demo中我們將寫兩個應用程式,一個應用程式負責發送簡單的字元串消息,另一個應用程式負責接收消息並列印出來。
創建一個Producer應用並使用Nuget添加RabbitMQ.Client包.
添加成功後就可以使用此包的功能來操作RabbitMQ,我們接下來編寫一個向RabbitMQ提供消息的程式:
在啟動此程式之前我們先來查看一下RabbitMQ當前的狀態,在瀏覽器中打開http://localhost:15672。
然後運行我們Producer程式再來查看RabbitMQ的狀態:
再次進入瀏覽器查看:
在這個時候我們看到Connection,Channel,Queue的數量都變成1了,這是因為我們利用Producer程式創建了一個connection,channel,queue。再來查看queue的詳細情況:
能看到這個界面說明我們將一條“hello world”的數據已經發送到了hello隊列。
接下來我們編寫Consumer(消費者)程式:
運行這段程式會出現一下結果:
Consumenr消費者會從hello隊列中不斷的獲取消息,直到消息完全被拿出。
這是RibbitMQ最簡單的使用方法。下一篇我們利用python語言介紹高級一點的使用方法。