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方式的消息隊列，就是暫時存進去等待處理，處理完了這個消息就沒了，保證送達，不會丟失，也不會被掉包。這種模式使用場合有限，而且客戶只能有一個，屬於快遞形式，滿足不了訂單處理要求，原因很簡單：黑名單檢查環節獲取了這個訂單信息，審核環節就獲取不到了，下一節我們一起學習“消息群發”，就是大喊一聲，訂單來了，大家開始忙吧...