RabbitMQ消息隊列安裝和配置以及推送消息

好久沒有寫了，最近項目用到RabbitMQ，找了一些資料試驗，最后終于成功了，把安裝配置的步驟分享給大家。

一、Erlang安裝具體過程：

1.雙擊otp_win32_R16801.exe(不同版本可能命名字不一樣)，選擇next

2.默認安裝在C盤，建議程序安裝在非系統盤比如D盤（如果安裝在C盤可能會出現一些權限問題），修改好安裝路徑后，選next：

3.進入安裝程序，選擇install，即可完成安裝。

配置環境變量：在系統變量下添加 變量名：ERLANG_HOME，變量值：C:/PRogram Files (x86)/erl6.1

二、安裝rabbitMQrabbitmq-server-3.3.5.exe安裝完成增加環境變量，雙擊path，在其后面增加：;C:/Program Files (x86)/RabbitMQ Server/rabbitmq_server-3.3.5/sbin

啟動start

cmd進到sbin目錄,輸入rabbitmq-service啟動

或是直接找到rabbitMQ安裝目錄下C:/Program Files (x86)/RabbitMQ Server/rabbitmq_server-3.3.5/sbin

打開瀏覽器登錄http://localhost:15672進入監視頁面說明配置成功，用戶名和密碼：guest

配置成功以后就是發送消息，采用Exchange。

Rabbit的核心組件包含Queue(消息隊列)和Exchanges兩部分，Exchange的主要部分就是對信息進行路由，通過將消息隊列綁定到Exchange上，則可以實現訂閱形式的消息發布及Publish/Subscribe在這種模式下消息發布者只需要將信息發布到相應的Exchange中，而Exchange則自動將信息分發到不同的Queue當中。

在.Net環境下有基于RabbitMQ有很多有API的選擇，最后選擇了比較簡單的EasyNetQ(http://easynetq.com/)

    /// <summary>    /// 消息服務器連接器    /// </summary>    public class BusBuilder    {        public static IBus CreateMessageBus()        {            //消息服務器連接字符串                     string connString = "host=172.17.186.50:5672;virtualHost=rb;username=admin;passWord=123";            return RabbitHutch.CreateBus(connString);           // return RabbitHutch.CreateBus(connectionString.ConnectionString);        }    }

 /// <summary>        /// 發送消息        /// </summary>        public static void Publish(Message msg)        {            //// 創建消息bus            IBus bus = BusBuilder.CreateMessageBus();            try            {                using (var publishChannel = bus.OpenPublishChannel())   //創建消息管道                 {                    publishChannel.Publish(msg, x => x.WithTopic(msg.MessageRouter));  //通過管道發送消息                 }            }            catch (EasyNetQException ex)            {                //處理連接消息服務器異常                 // MessageHelper.WriteFuntionExceptionLog("Publish", ex.Message + " | " + ex.StackTrace);            }            bus.Dispose();//與數據庫connection類似，使用后記得銷毀bus對象        }

    /// <summary>        /// 接收消息        /// </summary>        /// <param name="msg"></param>        public static void Subscribe(Message msg, iprocessMessage ipro)        {            //// 創建消息bus            IBus bus = BusBuilder.CreateMessageBus();            try            {                bus.Subscribe<Message>(msg.MessageID, message => ipro.ProcessMsg(message), x => x.WithTopic(msg.MessageRouter).WithArgument("x-ha-policy", "all"));            }            catch (EasyNetQException ex)            {                //處理連接消息服務器異常               //  MessageHelper.WriteFuntionExceptionLog("Subscribe", ex.Message + " | " + ex.StackTrace);            }        }

添加虛擬主機

添加用戶

執行代碼就會自動建立Exchanges,名字是根據項目名來的

點擊新建的Exchanges進入新建queue

最后調用接口測試發送，代碼如下：

  protected void Button1_Click(object sender, EventArgs e)        {            MQ.Message msg = new MQ.Message();            msg.MessageID = "testkey";            msg.MessageBody = "發送測試";            msg.MessageTitle = "hello world";            msg.MessageRouter = "testKey";            MQ.MQHelper.Publish(msg);                    }

msg.MessageRouter = "testKey"——這句配置很重要，取決于上一步的Routing Key.

推送消息成功！

源碼下載：http://pan.baidu.com/s/1sjExnWh