.Net平臺下ActiveMQ入門實例

1.ActiveMQ簡介

先分析這麼一個場景：當咱們在網站上購物時，必須通過，下訂單、發票建立、付款處理、訂單履行、航運等。可是，當用戶下單後，當即跳轉到「感謝那您的訂單」 頁面。不只如此，若果沒有延遲，用戶還會受到一封電子郵件。若是咱們使用傳統方式去實現，通常是對數據庫操做一通，而後調用各類接口、各類服務等待各類響應，這樣一來下個訂單須要好久時間才能看到結果，若是某個環節出了問題，那這個訂單結果一時半會是看不到了，對於現代電子商務來講，這是不能容忍的。 那麼ActiveMQ久能夠很好的解決這個問題：當用戶下單後，有一個對ActiveMQ的調用，用來提交訂單，而後系統就能夠返回結果頁面，而整個訂單流程不會同步調用，後臺JOB能夠邊聊天邊跑。前臺訂單量很大的狀況下每一個訂單也只須要調用一次，後臺一會兒處理不了？ 慢慢來，沒人逼你，訂單都在ActiveMQ中排隊等待呢，他們可不會煩躁。    這個場景很是適合一種緩存隊列，這種隊列叫消息隊列，不少產品都能實現這個功能，順便回答下一個潛在的問題：他可比數據庫操做快多了。

本文就從基礎開始一塊兒學習下，本文系統運行環境：Window7 32位

2.下載ActiveMQ

官方網站下載地址：http://activemq.apache.org/

3.運行ActiveMQ

解壓縮apache-activemq-5.10.0-bin.zip，而後雙擊apache-activemq-5.10.0\bin\win32\activemq.bat運行ActiveMQ程序。

看見控制檯最後一行輸出： 「access to all MBeans is allowed」 證實啓動成功。

啓動ActiveMQ之後，可使用瀏覽器登錄：http://localhost:8161/admin/驗證， 默認用戶名是：admin  密碼是：admin

（前提是安裝好Java環境）

同時下載.net版Dll：Apache.NMS-1.6.0-bin.zip和Apache.NMS.ActiveMQ-1.6.4-bin.zip

都從這裏下載：http://archive.apache.org/dist/activemq/apache-nms/1.6.0/

3.第一個ActiveMQ例子

先使用C#編寫一個消息源，也就是生產者：

界面很簡單，一個Lable，一個TextBox，一個Button，而後添加Apache.NMS.dll和Apache.NMS.ActiveMQ.dll引用，在上述另外2個下載包裏面找，注意版本號。

 

        public Form1()
        {
            InitializeComponent();
            InitProducer();
        }
        private IConnectionFactory factory;

        public void InitProducer()
        {
            try
            {
                //初始化工廠，這裏默認的URL是不須要修改的
                factory = new  ConnectionFactory("tcp://localhost:61616");

            }
            catch
            {
                lbMessage.Text = "初始化失敗!!";
            }
        }

        private void btnConfirm_Click(object sender, EventArgs e)
        {
            //經過工廠創建鏈接
            using (IConnection connection = factory.CreateConnection())
            {
                //經過鏈接建立Session會話
                using (ISession session = connection.CreateSession())
                {
                    //經過會話建立生產者，方法裏面new出來的是MQ中的Queue
                    IMessageProducer prod = session.CreateProducer(new Apache.NMS.ActiveMQ.Commands.ActiveMQQueue("firstQueue"));
                    //建立一個發送的消息對象
                    ITextMessage message = prod.CreateTextMessage();
                    //給這個對象賦實際的消息
                    message.Text = txtMessage.Text;
                    //設置消息對象的屬性，這個很重要哦，是Queue的過濾條件，也是P2P消息的惟一指定屬性
                    message.Properties.SetString("filter","demo");
                    //生產者把消息發送出去，幾個枚舉參數MsgDeliveryMode是否長鏈，MsgPriority消息優先級別，發送最小單位，固然還有其餘重載
                    prod.Send(message, MsgDeliveryMode.NonPersistent, MsgPriority.Normal, TimeSpan.MinValue);
                    lbMessage.Text = "發送成功!!";
                    txtMessage.Text = "";
                    txtMessage.Focus();
                }
            }
        }

能夠點擊按鈕發送一些消息，這些消息就被暫存到ActiveMQ中了，能夠登陸剛纔要密碼的那個網頁去查看。

而後編寫接收端，也就是消費者：

一樣添加那2個DLL的引用，界面很簡單隻有一個Lable：

 

        public Form1()
        {
            InitializeComponent();
            InitConsumer();

        }
         public void InitConsumer()
         {
             //建立鏈接工廠
             IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616");
             //經過工廠構建鏈接
             IConnection connection = factory.CreateConnection();
             //這個是鏈接的客戶端名稱標識
             connection.ClientId = "firstQueueListener";
             //啓動鏈接，監聽的話要主動啓動鏈接
             connection.Start();
             //經過鏈接建立一個會話
             ISession session = connection.CreateSession();
             //經過會話建立一個消費者，這裏就是Queue這種會話類型的監聽參數設置
             IMessageConsumer consumer = session.CreateConsumer(new Apache.NMS.ActiveMQ.Commands.ActiveMQQueue("firstQueue"), "filter='demo'");
             //註冊監聽事件
             consumer.Listener += new MessageListener(consumer_Listener);
             //connection.Stop();
             //connection.Close();  
 
         }
 
         void consumer_Listener(IMessage message)
         {
             ITextMessage msg = (ITextMessage)message;
             //異步調用下，不然沒法迴歸主線程
             tbReceiveMessage.Invoke(new DelegateRevMessage(RevMessage),msg);
 
         }
 
         public delegate void DelegateRevMessage(ITextMessage message);
 
         public void RevMessage(ITextMessage message)
         {
             tbReceiveMessage.Text += string.Format(@"接收到:{0}{1}", message.Text, Environment.NewLine);
         }

 

一啓動就會發現，這邊已經接收到了這些消息，而且服務器端的已經被刪除了。

 4.總結

以上實現了一個p2p方式的消息隊列，就是暫時存進去等待處理，處理完了這個消息就沒了，保證送達，不會丟失，也不會被掉包。這種模式使用場合有限，並且客戶只能有一個，屬於快遞形式，知足不了訂單處理要求，緣由很簡單：黑名單檢查環節獲取了這個訂單信息，審覈環節就獲取不到了，下一節咱們一塊兒學習「消息羣發」，就是大喊一聲，訂單來了，你們開始忙吧...

 

代碼下載

http://www.cnblogs.com/madyina/p/4121458.html