轉自: http://hi.baidu.com/lubezhang/blog/item/bd308b3b7ecce3ec14cecb4f.html
IBM MQ(IBM Message Queue)是IBM的一款商業消息中間產品,適用于分布式計算環境或異構系統之中。消息隊列技術是分布式應用間交換信息的一種技術。消息隊列可駐留在內存或磁盤上,隊列存儲消息直到它們被應用程序讀走。通過消息隊列,應用程序可獨立地執行--它們不需要知道彼此的位置、或在繼續執行前不需要等待接收程序接收此消息。
MQ基本概念
1、對列管理器
???? 隊列管理器是MQ系統中最上層的一個概念,由它為我們提供基于隊列的消息服務。
2、消息
???? 在MQ中,我們把應用程序交由MQ傳輸的數據定義為消息,我們可以定義消息的內容并對消息進行廣義的理解,比如:用戶的各種類型的數據文件,某個應用向其它應用發出的處理請求等都可以作為消息。消息有兩部分組成:消息描述符(Message Discription或Message Header),描述消息的特征,如:消息的優先級、生命周期、消息Id等;消 息體(Message Body),即用戶數據部分。在MQ中,消息分為兩種類型,非永久性(non-persistent)消息和永久性(persistent)消息,非永久 性消息是存儲在內存中的,它是為了提高性能而設計的,當系統掉電或MQ隊列管理器重新啟動時,將不可恢復。當用戶對消息的可靠性要求不高,而側重系統的性 能表現時,可以采用該種類型的消息,如:當發布股票信息時,由于股票信息是不斷更新的,我們可能每若干秒就會發布一次,新的消息會不斷覆蓋舊的消息。永久 性消息是存儲在硬盤上,并且紀錄數據日志的,它具有高可靠性,在網絡和系統發生故障等情況下都能確保消息不丟、不重。
?????? 此外,在MQ中,還有邏輯消息和物理消息的概念。利用邏輯消息和物理消息,我們可以將大消息進行分段處理,也可以將若干個本身完整的消息在應用邏輯上歸為一組進行處理。
3、對列
???? 隊列是消息的安全存放地,隊列存儲消息直到它被應用程序處理。
消息隊列以下述方式工作:
a) 程序A形成對消息隊列系統的調用,此調用告知消息隊列系統,消息準備好了投向程序B;
b) 消息隊列系統發送此消息到程序B駐留處的系統,并將它放到程序B的隊列中;
c) 適當時間后,程序B從它的隊列中讀此消息,并處理此信息。
由于采用了先進的程序設計思想以及內部工作機制,MQ能夠在各種網絡條件下保證消息的可靠傳遞,可以克服網絡線路質量差或不穩定的現狀,在傳輸過程中,如果 通信線路出現故障或遠端的主機發生故障,本地的應用程序都不會受到影響,可以繼續發送數據,而無需等待網絡故障恢復或遠端主機正常后再重新運行。
????? 在MQ中,隊列分為很多種類型,其中包括:本地隊列、遠程隊列、模板隊列、動態隊列、別名隊列等。本地隊列又分為普通本地隊列和傳輸隊列,普通本地隊列是應用程序通過API對其進行讀寫操作的隊列;傳輸隊列可以理解為存儲-轉發隊列,比如:我們將某個消 息交給MQ系統發送到遠程主機,而此時網絡發生故障,MQ將把消息放在傳輸隊列中暫存,當網絡恢復時,再發往遠端目的地。遠程隊列是目的隊列在本地的定義,它類似一個地址指針,指向遠程主機上的某個目的隊列,它僅僅是個定義,不真正占用磁盤存儲空間。模 板隊列和動態隊列是MQ的一個特色,它的一個典型用途是用作系統的可擴展性考慮。我們可以創建一個模板隊列,當今后需要新增隊列時,每打開一個模板隊 列,MQ便會自動生成一個動態隊列,我們還可以指定該動態隊列為臨時隊列或者是永久隊列,若為臨時隊列我們可以在關閉它的同時將它刪除,相反,若為永久隊 列,我們可以將它永久保留,為我所用。
4、通道
???? 通道是MQ系統中隊列管理器之間傳遞消息的管道,它是建立在物理的網絡連接之上的一個邏輯概念,也是MQ產品的精華。在 MQ中,主要有三大類通道類型,即消息通道,MQI通道和Cluster通道。消息通道是用于在MQ的服務器和服務器之間傳輸消息的,需要強調指出的是, 該通道是單向的,它又有發送(sender), 接收(receive), 請求者(requestor), 服務者(server)等不同類型,供用戶在不同情況下使用。MQI通道是MQ Client和MQ Server之間通訊和傳輸消息用的,與消息通道不同,它的傳輸是雙向的。群集(Cluster)通道是位于同一個MQ 群集內部的隊列管理器之間通訊使用的。
MQ工作原理
?
如圖所示:
首先來看本地通訊的情況,應用程序A和應用程序B運行于同一系統A,它們之間可以借助消息隊列技術進行彼此的通訊:應用程序A向隊列1發送一條信息,而當應用程序B需要時就可以得到該信息。
其 次是遠程通訊的情況,如果信息傳輸的目標改為在系統B上的應用程序C,這種變化不會對應用程序A產生影響,應用程序A向隊列2發送一條信息,系統A的MQ 發現Q2所指向的目的隊列實際上位于系統B,它將信息放到本地的一個特殊隊列-傳輸隊列(Transmission Queue)。我們建立一條從系統A到系統B的消息通道,消息通道代理將從傳輸隊列中讀取消息,并傳遞這條信息到系統B,然后等待確認。只有MQ接到系統 B成功收到信息的確認之后,它才從傳輸隊列中真正將該信息刪除。如果通訊線路不通,或系統B不在運行,信息會留在傳輸隊列中,直到被成功地傳送到目的地。 這是MQ最基本而最重要的技術--確保信息傳輸,并且是一次且僅一次(once-and-only-once)的傳遞。
MQ提供了用于應用集成的松耦合的連接方法,因為共享信息的應用不需要知道彼此物理位置(網絡地址);不需要知道彼此間怎樣建立通信;不需要同時處于運行狀態;不需要在同樣的操作系統或網絡環境下運行。
<!--EndFragment-->
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號聯系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
