【正文】 消息每一封信件都有信封和信瓤?jī)刹糠中欧馍厦嫱惺招湃送ㄐ诺刂泛桶l(fā)信人通信地址信瓤里是真正的內(nèi)容 如圖 24所示 WebSphere MQ 中的消息也一樣它分成消息頭和消息體兩部分消息頭是消息的屬性集合含有目標(biāo)隊(duì)列管理器名和目標(biāo)隊(duì)列名 WebSphere MQ 就是利用這段消息來(lái)找到目標(biāo)隊(duì)列的消息體是消息的內(nèi)容可以是任意的一段內(nèi)存信息 圖 24 信封和信瓤 WebSphere MQ 依靠每條消息頭上所含的路由信息將消息準(zhǔn)確地送達(dá)目的地路由信息中的遠(yuǎn)程隊(duì)列管理器名指的是遠(yuǎn)端系統(tǒng)的名字遠(yuǎn)程隊(duì)列名指的是遠(yuǎn)端系統(tǒng)中的目標(biāo)隊(duì)列名一個(gè)完整的隊(duì)列名應(yīng)該包含兩部分隊(duì)列管理器名和隊(duì)列名格式為queue_namequeue_manager_name兩部分名字的長(zhǎng)度上限都是 48字節(jié)這兩部分名字構(gòu)成了消息路由的最基本的信息算法其實(shí)很簡(jiǎn)單如果隊(duì)列管理器名未標(biāo)明則缺省加上本地隊(duì)列管理器的名字隊(duì)列名會(huì)缺省地匹配本地普通隊(duì)列而隊(duì)列管理器名會(huì)缺省地匹配本地隊(duì)列管理器名一般說(shuō)來(lái)建議傳輸隊(duì)列名與遠(yuǎn)程隊(duì)列管理器同名消 息傳送過(guò)程如下 1 應(yīng)用程序通過(guò) MQI發(fā)送消息 2 WebSphere MQ查看 queue_manager_name是否是本地隊(duì)列管理器 a 如果是的將消息放入本地的名為 queue_name的消息隊(duì)列中 b 如果不是將消息放入名為 queue_manager_name的傳輸隊(duì)列中 3 MCP會(huì)把傳輸隊(duì)列中的消息送達(dá)遠(yuǎn)端 4 遠(yuǎn)端將消息放入遠(yuǎn)端系統(tǒng)中名為 queue_name 的消息隊(duì)列中 5 遠(yuǎn)端的應(yīng)用程序從遠(yuǎn)端的本地隊(duì)列中取得消息 這種辦法提供了簡(jiǎn)單的路由功能但有一個(gè)明顯的缺點(diǎn)直接使用全名會(huì)要求應(yīng)用程序了解軟件的網(wǎng)絡(luò)結(jié)構(gòu)分布哪些隊(duì)列在哪里這有悖于 WebSphere MQ 對(duì)應(yīng)用程序隱藏網(wǎng)絡(luò)細(xì)節(jié)的設(shè)計(jì)初衷所以在跨隊(duì)列管理器的應(yīng)用中通常使用別名隊(duì)列和遠(yuǎn)程隊(duì)列來(lái)指定對(duì)方隊(duì)列的名字從而將隊(duì)列的分布信息保留在配置中 消息傳送 在實(shí)現(xiàn)消息的跨隊(duì)列管理器之間的傳送時(shí)通常會(huì)在本地隊(duì)列管理器上配置遠(yuǎn)程隊(duì)列和傳輸隊(duì)列在遠(yuǎn)端的隊(duì)列管理器上配置本地隊(duì)列并通過(guò)通道將兩者連接起來(lái)如圖 25所示這里的遠(yuǎn)程隊(duì)列只是一個(gè)定義并無(wú)隊(duì)列實(shí)體也就是說(shuō)遠(yuǎn)程隊(duì) 列不能存放消息應(yīng)用程序一旦將消息通過(guò) MQPUT送出則立刻放入傳輸隊(duì)列中傳輸隊(duì)列暫時(shí)存放待由通道發(fā)送的消息一旦通道連通且條件允許系統(tǒng)通信程序 MCA 會(huì)立即將消息送出消息到達(dá)對(duì)方目標(biāo)隊(duì)列管理器后由對(duì)方的通信程序 MCA 接收下來(lái)并放入相應(yīng)的目標(biāo)隊(duì)列這里的目標(biāo)隊(duì)列就是目標(biāo)隊(duì)列管理器上的本地隊(duì)列整個(gè)過(guò)程的效果就好像應(yīng)用程序直接將消息送入目標(biāo)隊(duì)列一樣 圖 25 消息傳送過(guò)程 遠(yuǎn)程隊(duì)列的定義實(shí)際上就是指定的目標(biāo)隊(duì)列的位置及傳輸路徑其中目標(biāo)隊(duì)列的位置通過(guò)設(shè)定目標(biāo)隊(duì)列名和目標(biāo)隊(duì)列管理器名來(lái)確定消息在路由過(guò)程中尋找該目標(biāo)地址傳輸路徑 就是傳輸隊(duì)列名消息會(huì)通過(guò)該傳輸隊(duì)列送出不同的遠(yuǎn)程隊(duì)列可以共用一個(gè)傳輸隊(duì)列 傳輸隊(duì)列本質(zhì)上是一個(gè)本地隊(duì)列只是由系統(tǒng)通信進(jìn)程 MCA 監(jiān)護(hù)應(yīng)用程序可以人為地通過(guò)MQPUT 放一條消息到傳輸隊(duì)列上但如果該消息沒(méi)有傳輸頭 MQXQH 則不會(huì)被發(fā)送消息按以下方式處理 1 如果隊(duì)列管理器設(shè)置了缺省死信隊(duì)列則消息放入該死信隊(duì)列死信消息原因碼為MQFB_XMIT_Q_MSG_ERROR 2 如果隊(duì)列管理器未設(shè)置缺省死信隊(duì)列則對(duì)于非持久性消息消息被仍掉對(duì)于持久性消息消息會(huì)留在傳輸隊(duì)列中無(wú)處可去這時(shí)有可能會(huì)堵住后繼的消息造成通道 無(wú)法發(fā)送消息在經(jīng)過(guò)遠(yuǎn)程隊(duì)列放入傳輸隊(duì)列時(shí)會(huì)由隊(duì)列管理器自動(dòng)添加一個(gè)傳輸頭 MQXQH 且傳輸頭中的內(nèi)容會(huì)根據(jù)遠(yuǎn)程隊(duì)列定義自動(dòng)填寫(xiě)如果說(shuō)原先的消息是 MQMD Body則放入傳輸隊(duì)列的消息為MQMD MQXQH Body 三控制與管理 WebSphere MQ中的控制針對(duì)的是 MQ部件通常使用命令方式完成管理針對(duì)的是 WebSphere MQ對(duì)象可以用 MQSC腳本命令或圖形界面工具完成在對(duì) WebSphere MQ的維護(hù)中兩者需要結(jié)合使用 31 MQ 控制命令 MQ 隊(duì)列管理器控制 隊(duì)列管理器是構(gòu)建 WebSphere MQ 運(yùn)行環(huán)境的基礎(chǔ)用戶需要首先創(chuàng)建并啟動(dòng)隊(duì)列管理器才能進(jìn)行以后的操作隊(duì)列管理器的控制命令可以創(chuàng)建刪除啟動(dòng)停止隊(duì)列管理器也可以顯示系統(tǒng)中所有的隊(duì)列管理器及其當(dāng)前運(yùn)行狀態(tài) 1創(chuàng)建隊(duì)列管理器 格式 crtmqm [選項(xiàng) ] QMgrName 功能 創(chuàng)建隊(duì)列管理器 說(shuō)明 QMgrName 指的是待建的隊(duì)列管理器名 crtmqm 顯示命令語(yǔ)法可以列出所有選項(xiàng)常用的選項(xiàng)有 [q][d DefXmitQ][u DeadQ]等它們可以組合使用選項(xiàng)如果取 q表示創(chuàng)建缺省隊(duì)列管理器一臺(tái)機(jī)器最多只能有一 個(gè)缺省隊(duì)列管理器如果取 d 表示指明隊(duì)列管理器的缺省傳輸隊(duì)列如果取 u表示指明隊(duì)列管理器的死信隊(duì)列 創(chuàng)建時(shí)的選項(xiàng)指定了隊(duì)列管理器的屬性這些屬性有些可以在創(chuàng)建后修改有些則不可以未用選項(xiàng)指明的的屬性就使用缺省值創(chuàng)建命令可以不帶選項(xiàng) 如 crtmqm QM 則所有屬性皆使用缺省值 舉例 crtmqm –q QM 2刪除隊(duì)列管理器 格式 dltmqm [z] QMgrName 功能 刪除隊(duì)列管理器 說(shuō)明 該命令執(zhí)行的前提是隊(duì)列管理器的相關(guān)進(jìn)程已經(jīng)全部停止了該命令只有一個(gè)選項(xiàng) z 表示抑制命令執(zhí)行時(shí)發(fā)出的信息 舉例 dltmqm –z QM 3啟動(dòng)隊(duì)列管理器 格式 strmqm [z c] QMgrName 功能 strmqm 用來(lái)啟動(dòng)隊(duì)列管理器也可以用來(lái)用缺省對(duì)象重建隊(duì)列管理器 說(shuō)明 如果在命令中沒(méi)有選項(xiàng)則簡(jiǎn)單地啟動(dòng)隊(duì)列管理器如果用 z 表示抑制命令執(zhí)行時(shí)發(fā)出的信息– c 選項(xiàng)比較特殊表示重置隊(duì)列管理器命令的執(zhí)行過(guò)程為先啟動(dòng)隊(duì)列管理器再覆蓋重建所有的缺省系統(tǒng)對(duì)象最后自動(dòng)停止該隊(duì)列管理器 如果上一次隊(duì)列管理器未能正常停止則啟動(dòng)后可能會(huì)回滾一些未完成的交易恢復(fù)一些消息和對(duì)象如果因?yàn)槟承┊惓２荒苤貑㈥?duì)列管理 器可以在出錯(cuò)日志 errors 目錄 中尋找原因 舉例 strmqm QM 4停止隊(duì)列管理器 格式 endmqm [z] [c w i p] QMgrName 功能 endmqm 用來(lái)停止隊(duì)列管理器 說(shuō)明 通過(guò)不同的選項(xiàng)可以設(shè)置不同的停止方式比如選項(xiàng)取 c 表示受控 Controlled 方式停止即等到連接在該隊(duì)列管理器上的所有應(yīng)用全部主動(dòng)斷開(kāi)連接后才停止隊(duì)列管理器不過(guò)該命令是立即返回的顯示命令已經(jīng)提交如果選項(xiàng)取 – w 則同樣是受控方式停止只是命令不是立即返回的在指定的時(shí)限 秒 內(nèi)等待 Wait 命令執(zhí)行完畢后或超時(shí)返回若選項(xiàng)取 i 即立即 Immediate 停止即使其它連接在該隊(duì)列管理器上的應(yīng)用的所有后繼 MQ API 全部失敗以督促它們退出命令在隊(duì)列管理器停止后返回若選項(xiàng)取 – p 即強(qiáng)行 Preemptive 停止不會(huì)等待其它應(yīng)用程序釋放資源或斷開(kāi)連接而直接將隊(duì)列管理器進(jìn)程退出有可能會(huì)造成異常 z 選項(xiàng)表示抑制命令執(zhí)行時(shí)發(fā)出的信息可以與其它選項(xiàng)組合使用 舉例 endmqm QM 5顯示隊(duì)列管理器 格式 dspmq [m QMgrName] 功能 dspmq 用來(lái)顯示 本地的隊(duì)列管理器的運(yùn)行狀態(tài) 說(shuō)明 如果用 – m 選項(xiàng)表示顯示某個(gè)具體的隊(duì)列管理器運(yùn)行狀態(tài)否則表示顯示所有的隊(duì)列管理器狀態(tài) 舉例 dspmq QMNAME QM STATUS正在運(yùn)行 QMNAME QM1 STATUS正常結(jié)束 QMNAME QM2 STATUS正常結(jié)束 MQ 命令服務(wù)器控制 WebSphere MQ 命令服務(wù)器是隊(duì)列管理器的一個(gè)組件用來(lái)對(duì)外來(lái)的命令消息進(jìn)行解釋和執(zhí)行在遠(yuǎn)程管理和編程管理的應(yīng)用中需要啟動(dòng)命令服務(wù)器一個(gè)隊(duì)列管理器最多只有一個(gè)命令服務(wù)器缺省情況下在創(chuàng)建隊(duì)列管理器時(shí)由系統(tǒng) 一并創(chuàng)建 1啟動(dòng)命令服務(wù)器 格式 strmqcsv [QMgrName] 功能 strmqcsv 用來(lái)啟動(dòng)命令服務(wù)器 說(shuō)明 QMgrName 指的是命令服務(wù)器所在的隊(duì)列管理器缺省為系統(tǒng)缺省隊(duì)列管理器命令服務(wù)器是隊(duì)列管理器的附加部件用來(lái)執(zhí)行管理命令 舉例 strmqcsv QM 2停止命令服務(wù)器 格式 endmqcsv [c i] QMgrName 功能 endmqcsv 用來(lái)停止命令服務(wù)器 說(shuō)明 通過(guò)不同的選項(xiàng)可以選擇不同的停止方式 c 表示受控方式 Controlled 停止允許已經(jīng)開(kāi)始的命令執(zhí)行完成 然后停止該命令服務(wù)器 i 表示立即 Immediately 停止中止正在執(zhí)行的命令并立即停止命令服務(wù)器 舉例 endmqcsv –c QM 3顯示命令服務(wù)器 格式 dspmqcsv [QMgrName] 功能 dspmqcsv 用來(lái)顯示命令服務(wù)器的狀態(tài) 說(shuō)明 這里 QMgrName指的是命令服務(wù)器所在的隊(duì)列管理器缺省為系統(tǒng)缺省隊(duì)列管理器 舉例 dspmqcsv QM MQ 監(jiān)聽(tīng)器控制 WebSphere MQ 中監(jiān)聽(tīng)器也是隊(duì)列管理器的一個(gè)組件用來(lái)監(jiān)聽(tīng)外來(lái)的連接請(qǐng)求并相 應(yīng)地做出反應(yīng)監(jiān)聽(tīng)器通常需要先配置然后才能運(yùn)行配置參數(shù)與監(jiān)聽(tīng)器選擇的通信協(xié)議有關(guān)當(dāng)然也可以在第一次啟動(dòng)監(jiān)聽(tīng)器時(shí)將配置參數(shù)傳入隱式地進(jìn)行配置一個(gè)隊(duì)列管理器可以有多個(gè)監(jiān)聽(tīng)器分別應(yīng)用于不同的通信協(xié)議或同一協(xié)議的不同參數(shù)比如 TCPIP的不同端口 1啟動(dòng)監(jiān)聽(tīng)器 格式 runmqlsr [m QMgrName] t TCP LU62 NETBIOS SPX [參數(shù) ] 功能 runmqlsr 用來(lái)啟動(dòng)監(jiān)聽(tīng)器 說(shuō)明 監(jiān)聽(tīng)器是通道連接的被動(dòng)方用來(lái)監(jiān)聽(tīng)網(wǎng)絡(luò)連接的程序命令格式中 QMgrName指的是命令服務(wù)器所在的 隊(duì)列管理器缺省為系統(tǒng)缺省隊(duì)列管理器 t 選項(xiàng)指定通信協(xié)議參數(shù)與監(jiān)聽(tīng)器選擇的通信協(xié)議有關(guān)具體參見(jiàn)附錄 WebSphere MQ 命令一覽表 舉例 runmqlsr t tcp p 1414 m QM 2停止監(jiān)聽(tīng)器 格式 endmqlsr [w] [m QMgrName] 功能 endmqlsr 用來(lái)停止監(jiān)聽(tīng)器實(shí)質(zhì)上就是停止網(wǎng)絡(luò)監(jiān)聽(tīng)程序 說(shuō)明 QMgrName 指的是命令服務(wù)器所在的隊(duì)列管理器缺省為系統(tǒng)缺省隊(duì)列管理器選項(xiàng)為 – w 時(shí)表示等待方式 Wait 停止命令執(zhí)行會(huì)等到監(jiān)聽(tīng)器停止完成后才返回否 則立即返回 舉例 endmqlsr –m QM 3配置 TCPIP 監(jiān)聽(tīng)器 TCPIP 協(xié)議是目前使用最廣泛的通信協(xié)議 WebSphere MQ隊(duì)列管理器的 TCPIP監(jiān)聽(tīng)器可以配置成三種形式即用帶參數(shù)的 runmqlsr 進(jìn)程進(jìn)行監(jiān)聽(tīng) UNIX 環(huán)境下可以用操作系統(tǒng) TCPIP Deamon進(jìn)程 id進(jìn)行監(jiān)聽(tīng) Windows 環(huán)境下也可以配置成 WebSphere MQ 服務(wù)的形式這里不做詳細(xì)介紹一個(gè)隊(duì)列管理器可以有多個(gè)監(jiān)聽(tīng)器分別監(jiān)聽(tīng)多個(gè)端口 配置 runmqlsr 這是配置 MQ監(jiān)聽(tīng)器的標(biāo)準(zhǔn)方式格式為 runmqlsr t tcp [m ] [p ]如果缺省 m選項(xiàng)表示使用缺省隊(duì)列管理器如果缺省 – p選項(xiàng)表示表示使用缺省端口 1414 在 UNIX下則可以用 runmqlsr t tcp [m ] [p ] 將命令放在后臺(tái)執(zhí)行 配置 id 在 UNIX 平臺(tái)中可以通過(guò)配置 id使 MQ 監(jiān)聽(tīng)器植入系統(tǒng)監(jiān)聽(tīng)服務(wù)中相當(dāng)于每次開(kāi)機(jī)監(jiān)聽(tīng)器就自動(dòng)啟動(dòng)了具體配置分三步 1 在 etcservices 中添加 MQSeries1 1414tcp MQSeries2 1415tcp 其中 MQSeries1 和 MQSeries2 分別是為監(jiān)聽(tīng)端口起的別名可以是任意字串 2 在 idconf 中添加 MQSeries1 stream tcp nowait mqm usrlppmqmbinamqcrsta amqcrsta [m QMgr1] MQSeries2 stream tcp nowait mqm usrlppmqmbinamqcrsta amqcrsta [m QMgr2] 其中 MQSeries1 和 MQSeries2 需要與 etcservices 文件中的定義配合起來(lái) 3 讓修改的配置生效 refresh s id AIX kill 1 其它 UNIX MQ觸發(fā)監(jiān)控器控制 觸發(fā)監(jiān)控器 Trigger Monitor 是 WebSphere MQ的組件之一用于監(jiān)控消息觸發(fā)初始化隊(duì)列并啟動(dòng)消息處理程序觸發(fā)監(jiān)控器根據(jù)其運(yùn)行的位置分為 MQ Client端觸發(fā)監(jiān)控器和 MQ Server 端觸發(fā)監(jiān)控器分別用于啟動(dòng)各自系統(tǒng)中的消息處理進(jìn)程 一個(gè)隊(duì)列管理器可以有多個(gè)觸發(fā)監(jiān)控器分別監(jiān)控不同的初始化隊(duì)列程序員