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