RabbitMQ 使用入門

專案需要接觸了幾天 RabbitMQ ，在此把自己學習的東西記錄下來和大家交流，望大家指教。

什麼是 RabbitMQ

RabbitMQ主要是在AMQP協議標準基礎上完成的，主要是用於大型應用程式，作為不同應用程式之間傳遞訊息的元件，RabbitMQ包括Server和Client，一個server可以擁有多個Client。RabbitMQ也將Server稱為broker，意為訊息中間人。

RabbitMQ 安裝

因為我是在64位win8.1環境使用MQ，並且是用於unity的，所以這裡只介紹win8.1和unity的情況。安裝過程基本參考官網教程

1. Erlang 環境安裝
   RabbitMQ是建立在Erlang OTP平臺上的，所以要先安裝Erlang環境，檔案較大，

   Erlang下載，下載完直接按預設路徑安裝。

2. RabbitMQ Server 安裝
   直接下載後按預設路徑安裝，下載地址，安裝完成後在Start Menu 搜尋RabbitMQ可以看到RabbitMQ Command Prompt和RabbitMQ Service-Start等，啟動RabbitMQ。

3. RabbitMQ Management Plugin 安裝
   這是一個RabbitMQ server的管理外掛，可以在瀏覽器對server進行視覺化管理，開啟RabbitMQ Command Prompt，在命令列中輸入一下命令：

   rabbitmq-plugins enable rabbitmq_management
    
   

   

4. Client 客戶端下載
   我下的是.NET/C#版本的，但要注意的是再unity4.0中不支援rabbitmq-dotnet-client-3.5.4-dotnet-4.0，我用的是rabbitmq-dotnet-client-3.4.4-dotnet-3.5，下載地址，.NET版本的Client直接將其中的dll和xml檔案取出放在程式目錄中使用就行。

tips:注意安裝過程全部選擇預設路徑，這樣安裝後無需配置環境變數即可使用

RabbitMQ 簡易使用

RabbitMQ還有很多複雜的操作，這裡只介紹簡單的使用以及我自己的理解，主要參考360doc的一篇文章RabbitMQ中 exchange、route、queue的關係

“Hello World!”

1. 基本概念
   Producer ：傳送訊息的客戶端
   Consumer : 接收訊息的客戶端
   Queue ：Producer傳送的訊息的存放地方，Consumer從其中獲取訊息

2. 例項（以下的程式碼都以在unity中的使用方法為例 ）
   Producer(P)傳送單個訊息”Hello World”到指定的佇列，Consumer(C)從佇列中讀取這個訊息

   

   Sending

   using UnityEngine;
   using System.Collections;
   using System.Threading;
   using RabbitMQ.Client;
   using System.Text;
   
   public class MQSenderV2 : MonoBehaviour {
   
   void Start () {
       Thread t = new Thread (new ThreadStart (ProcessMsg));
       t.Start ();
   }
   
   void ProcessMsg()
   {
       var factory = new ConnectionFactory() { HostName = "localhost" };
       using (var connection = factory.CreateConnection())
       {
           using (var channel = connection.CreateModel())
           {
               channel.ExchangeDeclare("topic_logs", "topic");
               channel.QueueDeclare("blowball_data", false, false, false, null);   
               channel.QueueBind("blowball_data", "topic_logs", "blowball.data.*");
   
               var routingKey = "blowball.data.test";
               var routingKey2 = "blowball.data.PK";
               var routingKey3 = "BBBGoal.data";
   
               int i;
               var body = Encoding.UTF8.GetBytes("");
               for(i=0;i<3;i++)
               {
                   body = Encoding.UTF8.GetBytes(message[i]);
                   channel.BasicPublish("topic_logs", routingKey, null, body);
               }
   
   
               Debug.Log("send side: "+"\n"+"routingKey: "+routingKey+"\nmessage: "+message);
           }
       }
   }
   }