先分析這么一個(gè)場(chǎng)景：當(dāng)我們?cè)诰W(wǎng)站上購物時(shí)，必須經(jīng)過，下訂單、發(fā)票創(chuàng)建、付款處理、訂單履行、航運(yùn)等。但是，當(dāng)用戶下單后，立即跳轉(zhuǎn)到“感謝那您的訂單” 頁面。不僅如此，若果沒有延遲，用戶還會(huì)受到一封電子郵件。如果我們使用傳統(tǒng)方式去實(shí)現(xiàn)，一般是對(duì)數(shù)據(jù)庫操作一通，然后調(diào)用各種接口、各種服務(wù)等待各種響應(yīng)，這樣一來下個(gè)訂單需要很久時(shí)間才能看到結(jié)果，如果某個(gè)環(huán)節(jié)出了問題，那這個(gè)訂單結(jié)果一時(shí)半會(huì)是看不到了，對(duì)于現(xiàn)代電子商務(wù)來說，這是不能容忍的。 那么ActiveMQ久可以很好的解決這個(gè)問題：當(dāng)用戶下單后，有一個(gè)對(duì)ActiveMQ的調(diào)用，用來提交訂單，然后系統(tǒng)就可以返回結(jié)果頁面，而整個(gè)訂單流程不會(huì)同步調(diào)用，后臺(tái)JOB可以邊聊天邊跑。前臺(tái)訂單量很大的情況下每個(gè)訂單也只需要調(diào)用一次，后臺(tái)一下子處理不了？ 慢慢來，沒人逼你，訂單都在ActiveMQ中排隊(duì)等待呢，他們可不會(huì)煩躁。 這個(gè)場(chǎng)景非常適合一種緩存隊(duì)列，這種隊(duì)列叫消息隊(duì)列，很多產(chǎn)品都能實(shí)現(xiàn)這個(gè)功能，順便回答下一個(gè)潛在的問題：他可比數(shù)據(jù)庫操作快多了。
創(chuàng)新互聯(lián)建站專注于企業(yè)營銷型網(wǎng)站建設(shè)、網(wǎng)站重做改版、滎經(jīng)網(wǎng)站定制設(shè)計(jì)、自適應(yīng)品牌網(wǎng)站建設(shè)、HTML5、成都做商城網(wǎng)站、集團(tuán)公司官網(wǎng)建設(shè)、外貿(mào)網(wǎng)站建設(shè)、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁設(shè)計(jì)等建站業(yè)務(wù)，價(jià)格優(yōu)惠性價(jià)比高，為滎經(jīng)等各大城市提供網(wǎng)站開發(fā)制作服務(wù)。本文就從基礎(chǔ)開始一起學(xué)習(xí)下，本文系統(tǒng)運(yùn)行環(huán)境：Window7 32位
官方網(wǎng)站下載地址：http://activemq.apache.org/
解壓縮apache-activemq-5.10.0-bin.zip，然后雙擊apache-activemq-5.10.0\bin\win32\activemq.bat運(yùn)行ActiveMQ程序。
看見控制臺(tái)最后一行輸出： “access to all MBeans is allowed” 證明啟動(dòng)成功。
啟動(dòng)ActiveMQ以后，可以使用瀏覽器登陸：http://localhost:8161/admin/驗(yàn)證， 默認(rèn)用戶名是：admin 密碼是：admin
（前提是安裝好Java環(huán)境）
同時(shí)下載.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/
先使用C#編寫一個(gè)消息源，也就是生產(chǎn)者：
界面很簡(jiǎn)單，一個(gè)Lable，一個(gè)TextBox，一個(gè)Button，然后添加Apache.NMS.dll和Apache.NMS.ActiveMQ.dll引用，在上述另外2個(gè)下載包里面找，注意版本號(hào)。
重慶分公司
重慶分公司
public Form1()
{
InitializeComponent();
InitProducer();
}
private IConnectionFactory factory;
public void InitProducer()
{
try
{
//初始化工廠，這里默認(rèn)的URL是不需要修改的
factory = new ConnectionFactory("tcp://localhost:61616");
}
catch
{
lbMessage.Text = "初始化失敗!!";
}
}
private void btnConfirm_Click(object sender, EventArgs e)
{
//通過工廠建立連接
using (IConnection connection = factory.CreateConnection())
{
//通過連接創(chuàng)建Session會(huì)話
using (ISession session = connection.CreateSession())
{
//通過會(huì)話創(chuàng)建生產(chǎn)者，方法里面new出來的是MQ中的Queue
IMessageProducer prod = session.CreateProducer(new Apache.NMS.ActiveMQ.Commands.ActiveMQQueue("firstQueue"));
//創(chuàng)建一個(gè)發(fā)送的消息對(duì)象
ITextMessage message = prod.CreateTextMessage();
//給這個(gè)對(duì)象賦實(shí)際的消息
message.Text = txtMessage.Text;
//設(shè)置消息對(duì)象的屬性，這個(gè)很重要哦，是Queue的過濾條件，也是P2P消息的唯一指定屬性
message.Properties.SetString("filter","demo");
//生產(chǎn)者把消息發(fā)送出去，幾個(gè)枚舉參數(shù)MsgDeliveryMode是否長鏈，MsgPriority消息優(yōu)先級(jí)別，發(fā)送最小單位，當(dāng)然還有其他重載
prod.Send(message, MsgDeliveryMode.NonPersistent, MsgPriority.Normal, TimeSpan.MinValue);
lbMessage.Text = "發(fā)送成功!!";
txtMessage.Text = "";
txtMessage.Focus();
}
}
}
可以點(diǎn)擊按鈕發(fā)送一些消息，這些消息就被暫存到ActiveMQ中了，可以登錄剛才要密碼的那個(gè)網(wǎng)頁去查看。
然后編寫接收端，也就是消費(fèi)者：
同樣添加那2個(gè)DLL的引用，界面很簡(jiǎn)單只有一個(gè)Lable：
public Form1()
{
InitializeComponent();
InitConsumer();
}
public void InitConsumer()
{
//創(chuàng)建連接工廠
IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616");
//通過工廠構(gòu)建連接
IConnection connection = factory.CreateConnection();
//這個(gè)是連接的客戶端名稱標(biāo)識(shí)
connection.ClientId = "firstQueueListener";
//啟動(dòng)連接，監(jiān)聽的話要主動(dòng)啟動(dòng)連接
connection.Start();
//通過連接創(chuàng)建一個(gè)會(huì)話
ISession session = connection.CreateSession();
//通過會(huì)話創(chuàng)建一個(gè)消費(fèi)者，這里就是Queue這種會(huì)話類型的監(jiān)聽參數(shù)設(shè)置
IMessageConsumer consumer = session.CreateConsumer(new Apache.NMS.ActiveMQ.Commands.ActiveMQQueue("firstQueue"), "filter='demo'");
//注冊(cè)監(jiān)聽事件
consumer.Listener += new MessageListener(consumer_Listener);
//connection.Stop();
//connection.Close();
}
void consumer_Listener(IMessage message)
{
ITextMessage msg = (ITextMessage)message;
//異步調(diào)用下，否則無法回歸主線程
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);
}一啟動(dòng)就會(huì)發(fā)現(xiàn)，這邊已經(jīng)接收到了這些消息，并且服務(wù)器端的已經(jīng)被刪除了。
4.總結(jié)以上實(shí)現(xiàn)了一個(gè)p2p方式的消息隊(duì)列，就是暫時(shí)存進(jìn)去等待處理，處理完了這個(gè)消息就沒了，保證送達(dá)，不會(huì)丟失，也不會(huì)被掉包。這種模式使用場(chǎng)合有限，而且客戶只能有一個(gè)，屬于快遞形式，滿足不了訂單處理要求，原因很簡(jiǎn)單：黑名單檢查環(huán)節(jié)獲取了這個(gè)訂單信息，審核環(huán)節(jié)就獲取不到了，下一節(jié)我們一起學(xué)習(xí)“消息群發(fā)”，就是大喊一聲，訂單來了，大家開始忙吧...
代碼下載
http://www.cnblogs.com/madyina/p/4121458.html
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。
