【正文】 如果我們把隊列管理器比作是數(shù)據(jù)庫那么隊列就是其中的一張表消息就是表中的一條記錄 隊列管理器是負(fù)責(zé)向應(yīng)用程序提供消息服務(wù)的機構(gòu)在 WebSphere MQ 中隊列管理器集成了對象的定義配置管理調(diào)度以及提供各種服務(wù)的功能于一身 WebSphere MQ 的系統(tǒng)管理工具提供了對系統(tǒng)部件配置與管理的功能應(yīng)用程序必須首先連接到隊列管理器然后在隊列管理器的控制下 對各種對象進行操作 WebSphere MQ 中的隊列管理器可以含有很多個隊列但一個隊列只能屬于一個隊列管理器一個操作系統(tǒng)平臺可以創(chuàng)建一個隊列管理器也可以創(chuàng)建多個隊列管理器隊列管理器隊列通道等等都是 WebSphere MQ 的對象所有的對象都有各自的屬性有些屬性必須在對象創(chuàng)建的時候指定有些可以在創(chuàng)建以后更改 14 通道 ChannelChannel Type WebSphere MQ 用通道類型屬性 CHLTYPE 約定了通信雙方在連接握手協(xié)議中的主動方和被動方以及應(yīng)用消息的流向可選以下這些類型 SDR Sender 握手協(xié)議的主動方消息的發(fā)送方 RCVR Receiver 握手協(xié)議的被動方消息的接收方 SVR Server 在握手協(xié)議中可以是主動方也可以是被動方消息的發(fā)送方 RQSTR Requester 在握手協(xié)議中可以是主動方也可以是被動方消息的接收方 CLNTCONN Client Connection 在 ClientServer 連接時定義客戶端連接定義表 Client Channel Definition Table 時使用握手協(xié)議的主動方消息的發(fā)送方 SVRCONN Server Connection 在 ClientServer 連接 時定義服務(wù)器端連接時使用握手協(xié)議的被動方消息的接收方 CLUSSDR Cluster Sender 在群集中發(fā)送配置信息和應(yīng)用消息握手協(xié)議的主動方消息的發(fā)送方 CLUSRCVR Cluster Receiver在群集中接收配置信息和應(yīng)用消息握手協(xié)議的被動方消息的接收方 通信雙方的通道類型配對并不是可以隨意排列組合的共有六種如圖 13 所示圖中細(xì)線箭標(biāo)表示握手協(xié)議中的主動連接粗線箭標(biāo)表示應(yīng)用消息流向消息在所有的通道上都是單向傳送的 SenderReceiver是所有連接中最簡單最常用的一種 Sender是通道主動方 也是消息發(fā)送方 RequesterServer也是常用的一種連接方式 Requester是通道主動方但通道連接后它作為消息接收方 Server是消息發(fā)送方 ServerReceiver與 SenderReceiver類似 Server是消息的發(fā)送方也是連接的主動方與 Sender 定義類似 Server定義中必須指定 CONNAME參數(shù) SenderRequester 的連接過程稍微復(fù)雜一些 Requester 首先與 Sender 連接在通知對方連接參數(shù)后連接斷開 Sender 進行反向連接消息也是反向傳送的這種反向連接的方式稱為 Callback Connection Sender ConnectionReceiver Connection 與 SenderReceiver 方式相同用于 ClientServer 之間的MQI 通道 Cluster SenderClueter Receiver 與 SenderReceiver 方式相同用于群集中隊列管理器之間的連接 由于 SenderReceiverServerReceiver 的連接主動方和消息發(fā)送方相同所以可以在發(fā)送端設(shè)定通道觸發(fā) Channel Trigger 由于 SenderReceiverServerReceiverRequesterServer的連接被動方事先不需要知道主動方的連接參數(shù)所以可以用于連接主動端是動態(tài)地址的應(yīng)用場合 由于 SenderRequester 有反向建立連接的功能所以常常用于雙向安全認(rèn)證 圖 13 通道類型的配對 消息通道協(xié)議 MCP 消息通道協(xié)議是 WebSphere MQ 用來傳遞消息時使用的通信協(xié)議 MCP Message Channel Protocol 可使用多種底層通信協(xié)議傳遞消息 LU62 DECNet 消息通道協(xié)議使得消息的傳送獨立于 通信協(xié)議應(yīng)用程序通過統(tǒng)一的接口與 MQ打交道而不再需要關(guān)心通信層使用的是 TCPIP 還是 SNA目前 MCP 支持的通信協(xié)議有 LU62DECNet 和 TCPIP 消息通道代理 MCA 消息通道代理 MCAMessage Channel Agent 本質(zhì)上是一個通信程序它用來在隊列管理器之間傳遞消息通道可以以進程的方式工作即獨立的 MCA 進程也可以以線程的方式嵌入系統(tǒng) MCA 進程中工作對于前者根據(jù)不同的 MCP發(fā)送端進程和接收端進程的 MCA 名通常是不同的 15 名稱列表 Name List 名稱 列表是 WebSphere MQ 的一種對象它實質(zhì)上是多個其它 WebSphere MQ 對象的名稱集合其內(nèi)容由多個字串組成中間用逗號隔開每個字串就是一個對象名稱 名稱列表本身無法代表它所含的對象例如無法對名稱列表進行 MQPUT 或 MQGET操作類似的操作應(yīng)該由分發(fā)列表 Distribution List 完成定義名稱列表只是定義了一個集合往往是為了方便應(yīng)用訪問多個對象比如應(yīng)用程序動態(tài)地從名稱列表中讀出操作對象并依次進行操作如果操作的對象有所增減只需要修改名稱列表即可名稱列表使管理人員可以在不修改應(yīng)用的前提 下通過動態(tài)地增減名稱列表中的內(nèi)容來進行管理 名稱列表多用于群集 Cluster 環(huán)境中指定一個隊列管理器同時屬于多個群集的情況這時名稱列表的內(nèi)容就是多個群集的名稱集合名稱列表可以用于以下一些對象屬性 QMgrREPOSNL QMgrSSLCRLNL QueueCLUSNL ChannelCLUSNL WebSphere MQ 中每個對象都有各自的屬性它們中的大多數(shù)是可以創(chuàng)建后修改的這里我們采用對象屬性的記號方式表示對象的屬性例 QueueCLUSNL 表示隊列的 CLUSNL 屬性以下同 16 分發(fā)列表 Distribution List 分發(fā)列表可以使 WebSphere MQ 應(yīng)用程序一次將一條消息同時發(fā)送到多個隊列上這里的一次發(fā)送指調(diào)用一次 MQPUT 或 MQPUT1 多個目標(biāo)隊列可以是本地隊列也可以遠(yuǎn)程隊列如果多個遠(yuǎn)程隊列的目標(biāo)隊列管理器相同則在網(wǎng)絡(luò)上只需要傳送一次即可節(jié)省了網(wǎng)絡(luò)開銷當(dāng)消息到達(dá)目標(biāo)隊列管理器后再自動分發(fā)到各個目標(biāo)隊列中當(dāng)然這要求源隊列管理器和目標(biāo)隊列管理器都支持分發(fā)列表功能 分發(fā)列表的操作是可以在一個交易中完成的也就是說多個隊列的發(fā)送是可以一起提交或回滾的 17 進程定義 Process 進程定義對象用于 WebSphere MQ 的觸發(fā)機制中用來描述觸發(fā)程序的對象這個程序可以是一個操作系統(tǒng)程序可以是一個 MQ 應(yīng)用也可以是一個 CICS 交易在進程定義的屬性中需要設(shè)定觸發(fā)程序的路徑名稱參數(shù)等等信息 在消息觸發(fā)環(huán)境中一旦觸發(fā)條件滿足即可引起觸發(fā)隊列管理器在生成觸發(fā)消息的時候會參考進程定義將定義中某些屬性被抄入觸發(fā)消息頭 MQTM 結(jié)構(gòu) 中形成觸發(fā)消息該觸發(fā)消息被觸發(fā)監(jiān)控器讀走并處理監(jiān)控器可以根據(jù) MQTM 觸發(fā)消息頭中的信息啟動相應(yīng)的進程 18 認(rèn)證信息 Auth Info 認(rèn)證信息 Authentication Information 定義了 SSL 認(rèn)證所需要的證書吊銷列表 CRLCertificate Revocation List 所在的 LDAP 服務(wù)器同時定義了連入該 LDAP 服務(wù)器所需的用戶名和口令 19 客戶端和服務(wù)器端 Client Server WebSphere MQ 分成客戶端和服務(wù)器端只有服務(wù)器端有對象的概念所以只有服務(wù)器端的應(yīng)用程序可以對本地對象進行直接操作客戶端通過 MQI 通道與服務(wù)器端相連接客戶端應(yīng)用程序發(fā)出的所有操作指令都通過該通道傳送 到服務(wù)器在服務(wù)器端執(zhí)行后結(jié)果返回客戶端通常情況下客戶端的應(yīng)用程序代碼與服務(wù)器端相同在程序編譯時連接的庫文件不同 110 操作界面 MQ Interface 應(yīng)用程序通過操作界面與 WebSphere MQ 打交道這里的操作界面就是消息隊列接口 Message Queue InterfaceMQI MQI 實際上是一套編程接口負(fù)責(zé)處理應(yīng)用程序向 WebSphere MQ 提交的各種操作請求應(yīng)用程序完全不需要關(guān)心 WebSphere MQ 的內(nèi)部結(jié)構(gòu)與具體實現(xiàn)如消息隊列傳輸隊列等等 當(dāng)應(yīng)用程 序通過 MQI 送出一條消息到遠(yuǎn)程隊列隊列管理器會在它的消息數(shù)據(jù)頭中加上路由信息消息被轉(zhuǎn)入傳輸隊列等待送出 MQI 的操作非常簡單直觀如MQOPENMQCLOSEMQGETMQPUT 等等 由于 MQ 的互連通信是通過存儲轉(zhuǎn)發(fā)機制完成的所以操作與傳輸是異步的這意味著應(yīng)用程序通過操作界面將消息發(fā)送出去時消息首先存儲在本地當(dāng)通信暢通時再被轉(zhuǎn)發(fā)應(yīng)用程序可以繼續(xù)處理自己的邏輯而不必等待消息傳達(dá)對方 111 應(yīng)用程序 MQ Application 應(yīng)用程序可以是商業(yè)的或用戶自行開發(fā)的含有對 WebSphere MQ操作的程序 MQI提供了支持的有平臺的通用編程接口應(yīng)用程序只要能夠調(diào)用相應(yīng)的庫函數(shù)它就可以操作WebSphere MQ 這里介紹了 WebSphere MQ 中的基本概念和對象其中最核心的部分是消息隊列隊列管理器和通道對于編程設(shè)計人員通常更關(guān)心消息和隊列對于維護管理人員通常會更關(guān)心隊列管理器和通道 二工作原理 WebSphere MQ 的工作原理的核心就是存儲轉(zhuǎn)發(fā)在單個隊列管理器的環(huán)境中隊列可以用于存儲應(yīng)用間傳遞的消息從而使應(yīng)用程序在各自環(huán)節(jié)上進行處理并通過隊列形成環(huán)環(huán)相扣的處理流程在多個 隊列管理器的環(huán)境中消息可以跨平臺進行流動從而使整個處理流程在分布式計算環(huán)境中完成 21 PUT和 GET WebSphere MQ的應(yīng)用程序可以通過 MQ界面 MQIMQ Interface 進行操作實際上 MQI 提供了有限的 API其中最本質(zhì)的兩個動作是 PUT和 GETPUT指應(yīng)用程序放一條消息放入到隊列中 GET則相反應(yīng)用程序?qū)⒁粭l消息從隊列中取出 WebSphere MQ通過隊列機制來完成消息排隊和傳遞的工作從而使應(yīng)用程序之間實現(xiàn)松耦合的聯(lián)系如圖 21所示應(yīng)用程序 A 產(chǎn)生消息通過 PUT 調(diào)用放入隊列中應(yīng)用程 序 B 將消息取出并進行相應(yīng)的處理消息的報文格式及內(nèi)容決定了應(yīng)用程序 B 處理的具體工作這樣就實現(xiàn)了應(yīng)用程序 A 到 B 之間的單向消息傳遞如果需要雙向傳遞消息則必須再類似地約定反向隊列 圖 21 應(yīng)用通過隊列傳遞消息 應(yīng)用程序設(shè)計的時候必須約定雙方的報文格式如果用通用格式 如 XML 則需考慮由此帶來的靈活性和信息冗余在兩者之間平衡選擇在運行環(huán)境中還需要考慮 PUT 和 GET 的頻率與速度以免消息有在隊列中堆積起來 WebSphere MQ 提供的遠(yuǎn)程隊列機制可以將目標(biāo)隊列設(shè)定到另外一個隊列管理器中這樣應(yīng)用程序 A和 B 就可以在兩臺機器上運行而不改動任何代碼應(yīng)用程序 A 仍然做著相同的PUT 操作將消息放入隊列中該消息會自動路由到另一個隊列管理器中的隊列中應(yīng)用程序 B從該隊列中 GET 消息與原先一樣地處理也就是說這種配置結(jié)構(gòu)上的改變對應(yīng)用程序是完全透明的 WebSphere MQ 的這種特性使得其應(yīng)用的擴展性極佳任何應(yīng)用在設(shè)計之初并不需要考慮太多的性能及擴展性問題在需要時可以很方便地將應(yīng)用中任何一部分拆到其它的機器上實現(xiàn)分布式計算 圖 22 應(yīng)用通過隊列跨網(wǎng)絡(luò)傳遞消息 22 協(xié)同工作 通常說來一個應(yīng)用系統(tǒng)會由多個應(yīng)用模塊組成一 個處理流程也會由多個處理步驟組成它們之間可能是串行的關(guān)系也可能是并行的關(guān)系在 WebSphere MQ 應(yīng)用設(shè)計中可以自然地將多個模塊或多個步驟設(shè)計成不同的應(yīng)用程序而它們之間的中間數(shù)據(jù)則通過消息的方式傳遞用隊列暫存如圖 23所示這樣一來應(yīng)用系統(tǒng)會有以下好處 1 結(jié)構(gòu)清晰容易并行開發(fā)和調(diào)試 2 擴展性極好能夠很容易地布署到跨平臺環(huán)境中 3 靈活性好一旦流程改變了可以較容易地進行修改 圖 23 協(xié)同工作 23 互連通信 消息通道 Message Channel WebSphere MQ 跨平臺的互連通信是依靠隊列管理器之間的消息通道實現(xiàn)的消息通道就是消息傳遞的管道架設(shè)在隊列管理器之間消息從一頭流入從另一頭流出消息的內(nèi)容和次序完全不變 配置通道時需要注意通道在兩個隊列管理器中同名且類型要配對 消息路由 Message Routing 首先拿現(xiàn)實生活中寄信做例子來類比 WebSphere MQ 中的一些基本概念從而理解WebSphere MQ 的工作原理現(xiàn)實生活中家家戶戶都可能有一個通信地址對應(yīng)著一個存放到達(dá)信件的信箱每一封寄出的信件總是先到本地郵局通過郵局之間的信件交換到達(dá)對方 所在的郵局最后到達(dá)對方的信箱里中間的郵路越復(fù)雜時間就越長這里的郵局相當(dāng)于 WebSphere MQ 中的隊列管理器信箱相當(dāng)于隊列信件相當(dāng)于