【正文】 信協(xié)議，這樣就使得編程接口與通 信協(xié)議無(wú)關(guān)。隊(duì)列管理器之間的通信是通過(guò)配置通道來(lái)實(shí)現(xiàn)的，通道兩側(cè)的隊(duì)列管理器對(duì)這個(gè)通道的相關(guān)參數(shù)應(yīng)該能對(duì)應(yīng)起來(lái)，一個(gè)通道只能用一種通信協(xié)議，但不同的通道可以有不同的通信協(xié)議。 通道類型 (Channel Type) WebSphere MQ 用通道類型屬性 (CHLTYPE)約定了通信雙方在連接握手協(xié)議中的主動(dòng)方和被動(dòng)方以及應(yīng)用消息的流向。握手協(xié)議的主動(dòng)方，消息 的發(fā)送方 ?? SVRCONN Server Connection: 在 ClientServer連接時(shí)，定義服務(wù)器端連接時(shí)使用。握手協(xié)議的主動(dòng)方，消息的發(fā)送方 ?? CLUSRCVR Cluster Receiver。握手協(xié)議的被動(dòng)方，消息的接收方 通信雙方的通道類型配對(duì)并不是可以隨意排列組合的，共有六種 ,如圖 。消息在所有的通道上都是單向傳送的。 Sender是通道主動(dòng)方，也是消息發(fā)送方。 Requester是通道主動(dòng)方，但通道連接后，它作為消息接收方， Server是消息發(fā)送方。與 Sender 定義類似， Server定義中必須指定 CONNAME參數(shù)。 Sender 進(jìn)行反向連接，消息也是反向傳送的。 ?? Sender Connection/Receiver Connection 與 Sender/Receiver 方式相同。 ?? Cluster Sender/Clueter Receiver 與 Sender/Receiver 方式相同。 由于 Sender/Receiver、 Server/Receiver 的連接主動(dòng)方和消息發(fā)送方相同，所以可以在發(fā)送端設(shè)定通道觸發(fā) (Channel Trigger)。 由于 Sender/Requester 有反向建立連接的功能，所以常常用于雙向安全認(rèn)證。 MCP(Message Channel Protocol) 可使用多種底層通信協(xié)議傳遞消息（ , DECNet ...）。目前 MCP 支持的通信協(xié)議有、 DECNet 和 TCP/IP。通道可以以進(jìn)程的方式工作，即獨(dú)立的 MCA 進(jìn)程。對(duì)于前者，根據(jù)不同的 MCP，發(fā)送端進(jìn)程和接收端進(jìn)程的 MCA 名通常是不同的。其內(nèi)容由多個(gè)字串組成，中間用逗號(hào)隔開，每個(gè)字串就是一個(gè)對(duì)象名稱。定義名稱列表只是定義了一個(gè)集合，往往是為了方便應(yīng)用訪問(wèn)多個(gè)對(duì)象。名稱列表使管理人員可以在不修改應(yīng)用的前提下，通過(guò)動(dòng)態(tài)地增減名稱列表中的內(nèi)容來(lái)進(jìn)行管理。名稱列表可以用于以下一些對(duì)象屬性： ?? ?? ?? ?? WebSphere MQ 中每個(gè)對(duì)象都有各自的屬性，它們中的大多數(shù)是可以創(chuàng)建后修改的。以下同。這里的一次發(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ò)開銷。 分發(fā)列表的操作是可以在一個(gè)交易中完成的，也就是說(shuō)，多個(gè)隊(duì)列的發(fā)送是可以一起提交或回滾的。這個(gè)程序可以是一個(gè)操作系統(tǒng)程序，可以是一個(gè) MQ 應(yīng)用，也可以是一個(gè) CICS 交易，在進(jìn)程定義的屬性中需要設(shè)定觸發(fā)程序的路徑、名稱、參數(shù)等等信息。該觸發(fā)消息被觸發(fā)監(jiān)控器讀走并處理，監(jiān)控器可以根據(jù) MQTM 觸發(fā)消息頭中的信息啟動(dòng)相應(yīng)的進(jìn)程。 MQ 運(yùn)維手冊(cè) 客戶端和服務(wù)器端 (Client amp。客戶端通過(guò) MQI 通道與服務(wù)器端相連接，客戶端應(yīng)用程序發(fā)出的所有操作指令都通過(guò)該通道傳送到服務(wù)器，在服務(wù)器端執(zhí) 行后結(jié)果返回客戶端。 操作界面 (MQ Interface) 應(yīng)用程序通過(guò)操作界面與 WebSphere MQ 打交道，這里的操作界面就是消息隊(duì)列接口 (Message Queue Interface， MQI)。 當(dāng) 應(yīng)用程序通過(guò) MQI 送出一條消息到遠(yuǎn)程隊(duì)列，隊(duì)列管理器會(huì)在它的消息數(shù)據(jù)頭中加上路由信息，消息被轉(zhuǎn)入傳輸隊(duì)列，等待送出。 由于 MQ 的互連通信是通過(guò)存儲(chǔ)轉(zhuǎn)發(fā)機(jī)制完成的，所以操作與傳輸是異步的。應(yīng)用程序可以繼續(xù)處理自己的邏輯，而不必等待消息傳達(dá)對(duì)方。MQI提供了支持的有平臺(tái)的通用編程接口。 這里介紹了 WebSphere MQ中的基本概念和對(duì)象，其中最核心的部分是消息、隊(duì)列、隊(duì)列管理器和通道。 MQ 運(yùn)維手冊(cè) 二、工作原理 WebSphere MQ 的工作原理的核心就是存儲(chǔ)轉(zhuǎn)發(fā)。在多個(gè)隊(duì)列管理器的環(huán)境中，消息可以跨平臺(tái)進(jìn)行流動(dòng)，從而使整個(gè)處理流程在分布式計(jì)算環(huán)境中完成。實(shí)際上， MQI 提供了有限的 API，其中最本質(zhì)的兩個(gè)動(dòng)作是 PUT和 GET。WebSphere MQ通過(guò)隊(duì)列機(jī)制來(lái)完 成消息排隊(duì)和傳遞 的工作，從而使應(yīng)用程序之間實(shí)現(xiàn)松耦合的聯(lián)系。這樣就實(shí)現(xiàn)了應(yīng)用程序 A到 B之間的單向消息傳遞，如果需要雙向傳遞消息則必須再類似地約定反向隊(duì)列。在運(yùn)行環(huán)境中，還需要考慮 PUT和 GET的頻率與速 度，以免消息有在隊(duì)列中堆積起來(lái)。也就是說(shuō)，這種配置結(jié)構(gòu)上的改變對(duì)應(yīng) 用程序是完全透明的。 MQ 運(yùn)維手冊(cè) 圖 應(yīng)用通過(guò)隊(duì)列跨網(wǎng)絡(luò)傳遞消息 協(xié)同工作 通常說(shuō)來(lái)，一個(gè)應(yīng)用系統(tǒng)會(huì)由多個(gè)應(yīng)用模塊組成，一個(gè)處理流程也會(huì)由多個(gè)處理步驟組成。在 WebSphere MQ應(yīng)用設(shè)計(jì)中，可以自然地將多個(gè)模塊或多個(gè)步驟設(shè)計(jì)成不同的應(yīng)用程序，而它們之間的中間數(shù)據(jù)則通過(guò)消息的方式傳遞，用隊(duì)列暫存。 2. 擴(kuò)展性極好，能夠很容易地布署到跨平臺(tái)環(huán)境中。 圖 協(xié)同工作 互連通信 消息通道 (Message Channel) WebSphere MQ跨平臺(tái)的互連通信是依靠隊(duì)列管理器之間的消息通道實(shí)現(xiàn)的，消息通道就是消息傳遞的管道，架設(shè)在隊(duì)列管理器之間，消息從一頭流入從另一頭流出，消息的內(nèi)容和次序完全不變。 MQ 運(yùn)維手冊(cè) 消息路由 (Message Routing) 首先拿現(xiàn)實(shí)生活中寄信做例子來(lái)類比 WebSphere MQ中的一些基本概念，從而理解 WebSphere MQ的工作原理。每一封寄出的信件總是先到本地郵局，通過(guò)郵局之間的信件交換，到達(dá)對(duì)方所在的郵局，最后到達(dá)對(duì)方的信箱里。這里的郵局相當(dāng)于 WebSphere MQ中的隊(duì)列管理器，信箱相當(dāng)于隊(duì)列，信件相當(dāng)于消息。 WebSphere MQ中的消息也一樣，它分成消息頭和消息體兩部分。消息體是消息的內(nèi)容，可以是任意的一段內(nèi)存信息。路由信息中的遠(yuǎn)程隊(duì)列管理器名指的是遠(yuǎn)端系統(tǒng)的名字，遠(yuǎn)程隊(duì)列名指的是遠(yuǎn)端系統(tǒng)中的目標(biāo)隊(duì)列名。兩部分名字的長(zhǎng)度上限都是 48字節(jié)，這兩部分名字構(gòu)成了消息路由的最基本的信息，算法其實(shí)很簡(jiǎn)單：如果隊(duì)列管理器名未標(biāo)明，則缺省加上本地隊(duì)列管理器的名字。一般說(shuō)來(lái)，建議傳輸隊(duì)列名與遠(yuǎn)程隊(duì)列管理器同名。這有悖于 WebSphere MQ對(duì)應(yīng) 用程序隱藏網(wǎng)絡(luò)細(xì)節(jié)的設(shè)計(jì)初衷。 MQ 運(yùn)維手冊(cè) 消息傳送 在實(shí)現(xiàn)消息的跨隊(duì)列管理器之間的傳送時(shí)，通常會(huì)在本地隊(duì)列管理器上配置遠(yuǎn)程隊(duì)列和傳輸隊(duì)列，在遠(yuǎn)端的隊(duì)列管理器上配置本地隊(duì)列，并通過(guò)通道將兩者連接起來(lái)。應(yīng)用程序一旦將消息通過(guò) MQPUT送出，則立刻放入傳輸隊(duì)列中。消息到達(dá)對(duì)方目標(biāo)隊(duì)列管理器后，由對(duì)方的通信程序 MCA接收下來(lái)并放入相應(yīng)的目標(biāo)隊(duì)列。整個(gè)過(guò)程的效果就好像應(yīng)用程序直接將消息送入目標(biāo)隊(duì)列一樣。其中，目標(biāo)隊(duì)列的位置通過(guò)設(shè)定目標(biāo)隊(duì)列名和目標(biāo)隊(duì)列管理器名來(lái)確定，消息在路由過(guò)程中尋找該目標(biāo)地址。不同的遠(yuǎn)程隊(duì)列可以共用一個(gè)傳輸隊(duì)列。應(yīng)用程序可以人為地通過(guò) MQPUT 放一條消息到傳輸隊(duì)列上，但如果該消息沒(méi)有傳輸頭 (MQXQH)，則不會(huì)被發(fā)送，消息按以下方式處理： 1. 如果隊(duì)列管理器設(shè)置了缺省死信隊(duì)列，則消息放入該死信隊(duì)列，死信消息原因碼為 MQFB_XMIT_Q_MSG_ERROR。對(duì)于持久性消息，消息會(huì)留在傳輸隊(duì)列中無(wú)處可去，這時(shí)有可能會(huì)堵住后繼的消息，造成通道無(wú)法發(fā)送。如果說(shuō)，原先的消息是 MQMD + Body，則放入傳輸隊(duì)列的消息為 MQMD + MQXQH + Body。管理針對(duì)的是 WebSphere MQ對(duì)象，可以用 MQSC腳本命令或圖形界面工具完成。 MQ 控制命令 MQ 隊(duì)列管理器控制 隊(duì)列管理器是構(gòu)建 WebSphere MQ運(yùn)行環(huán)境的基礎(chǔ)，用戶需要首先創(chuàng)建并啟動(dòng)隊(duì)列管理器才能進(jìn)行以后的操作。 （ 1）創(chuàng)建隊(duì)列管理器 ?? 格式 crtmqm [選項(xiàng) ] QMgrName ?? 功能 創(chuàng)建隊(duì)列管理器 ?? 說(shuō)明 QMgrName 指的是待建的隊(duì)列管理器名。常用的選項(xiàng)有 [q]、 [d DefXmitQ]、 [u DeadQ]等，它們可以組合使用。如果取 d，表示指明隊(duì)列管理器的缺省傳輸隊(duì)列。 創(chuàng)建時(shí)的選項(xiàng)指定了隊(duì)列管理器的屬性，這些屬性有些可以在創(chuàng)建后修改，有些則不可以。 ?? 舉例 crtmqm –q QM? （ 2） 刪除隊(duì)列管理器 ?? 格式 dltmqm [z] QMgrName ?? 功能 刪除隊(duì)列管理器 ?? 說(shuō)明 ? MQ 運(yùn)維手冊(cè) 該命令執(zhí)行的前提是隊(duì)列管 理器的相關(guān)進(jìn)程已經(jīng)全部停止了。 ?? 舉例 dltmqm –z QM? （ 3）啟動(dòng)隊(duì)列管理器 ?? 格式 strmqm [z | c] QMgrName ?? 功能 strmqm 用來(lái)啟動(dòng)隊(duì)列管理器，也可以用來(lái)用缺省對(duì)象重建隊(duì)列管理器。如果用 z，表示抑制命令執(zhí)行時(shí)發(fā)出的信息。命令的執(zhí)行過(guò)程為：先啟動(dòng)隊(duì)列管理器，再覆蓋重建所有的缺省系統(tǒng)對(duì)象，最后自動(dòng)停止 該隊(duì)列管理器。如果因?yàn)槟承┊惓２荒苤貑㈥?duì)列管理器，可以在出錯(cuò)日志 (errors 目錄 ) 中尋找原因。 ?? 說(shuō)明 通過(guò)不同的選項(xiàng)，可以設(shè)置不同的停止方式。不過(guò)，該命令是立即返回的，顯示命令已經(jīng)提交。若選項(xiàng)取 i，即立即 (Immediate) 停止，即使其它連接在該隊(duì)列管理器上的應(yīng)用的所有后繼 MQ API 全部失敗，以督促它們退出。若選項(xiàng)取 –p，即強(qiáng)行 (Preemptive) 停止。 z 選項(xiàng)表示抑制命令執(zhí)行時(shí)發(fā)出的信息，可以與其它選項(xiàng)組合使用。 ?? 說(shuō)明 如果用 –m 選項(xiàng)，表示顯示某個(gè)具體的隊(duì)列管理器運(yùn)行狀態(tài)，否則，表示顯示 MQ 運(yùn)維手冊(cè) 所有的隊(duì)列管理器狀態(tài)。在遠(yuǎn)程管理和編程管理的應(yīng)用中，需要啟動(dòng)命令服務(wù)器。 （ 1）啟動(dòng)命令服務(wù)器 ?? 格式 strmqcsv [QMgrName] ?? 功能 strmqcsv 用來(lái)啟動(dòng)命令服務(wù)器。命令服務(wù)器 是隊(duì)列管理器的附加部件，用來(lái)執(zhí)行管理命令。 c表示受控方式 (Controlled)停止，允許已經(jīng)開始的命令執(zhí)行完成，然后停止該命令服務(wù)器。 ?? 舉例 endmqcsv –c QM?（ 3）顯示命令服務(wù)器 ?? ?? 格式 dspmqcsv [QMgrName] ?? ?? 功能 dspmqcsv 用來(lái)顯示命令服務(wù)器的狀態(tài) ?? ?? 說(shuō)明 這里 QMgrName指的是命令服務(wù)器所在的隊(duì)列管理器，缺省為系統(tǒng)缺省隊(duì)列管 MQ 運(yùn)維手冊(cè) 理器。監(jiān)聽器通常需要先配置，然后才能運(yùn)行，配置參數(shù)與監(jiān)聽器選擇的通信協(xié)議有關(guān)。 一個(gè)隊(duì)列管理器可以有多個(gè)監(jiān)聽器，分別應(yīng)用于不同的通信協(xié)議或同一協(xié)議的不同參數(shù)。 （ 1）啟動(dòng)監(jiān)聽器 ?? 格式 runmqlsr [m QMgrName] t (TCP | LU62 | NETBIOS | SPX) [參數(shù) ] ?? 功能 runmqlsr 用來(lái)啟動(dòng)監(jiān)聽器 ?? 說(shuō)明 監(jiān)聽器是通道連接的被動(dòng)方用來(lái)監(jiān)聽網(wǎng)絡(luò)連接的程序。 t 選項(xiàng)指定通信協(xié)議，參數(shù)與監(jiān) 聽器選擇的通信協(xié)議有關(guān)，具體參見“附錄 WebSphere MQ 命令一覽表”。 ?? 說(shuō)明 QMgrName 指的是命令服務(wù)器所在的隊(duì)列管理器，缺省為系統(tǒng)缺省隊(duì)列管理器。 ??? 舉例 endmqlsr –m QM?（ 3）配置 TCP/IP 監(jiān)聽器 TCP/IP 協(xié)議是目前使用最廣泛的通信協(xié)議。一個(gè)隊(duì)列管理器可以有多個(gè)監(jiān)聽器，分別監(jiān)聽多個(gè)端口。如果缺省 m選項(xiàng)，表示使用缺省隊(duì)列管理器，如果缺省 –p選項(xiàng)，表示表示使用缺省端口 1414。 將命令放在后臺(tái)執(zhí)行。具體配置分三步： 1. 在 /etc/services 中添加： MQSeries1 1414/tcp MQSeries2 1415/tcp 其中， MQSeries1 和 MQSeries2 分別是為監(jiān)聽端口起的別名，可以是任意字串。 3. 讓修改的配置生效： refresh s id // AIX kill 1 id daemon 進(jìn)程的 pid // 其它 UNIX? MQ 觸發(fā)監(jiān)控器控制 觸發(fā)監(jiān)控器 (Trigger Monitor)是 WebSphere MQ的組件之一，用于監(jiān)控消息觸發(fā)初始化隊(duì)列并啟動(dòng)消息處理程序。 一個(gè)隊(duì)列管理器可以有多個(gè)觸發(fā)監(jiān)控器，分別監(jiān)控不同的初始化隊(duì)列。 （ 1）啟動(dòng) Client 端觸發(fā)監(jiān)控器 ?? 格式 runmqtmc [m QMgrName] [q InitiationQName] ?? 功能 runmqtmc用來(lái)啟動(dòng) Client端觸發(fā)監(jiān)控器 ?? 說(shuō)明 QMgrName指的是命令服務(wù)器所在的隊(duì)列管理器，缺省為系統(tǒng)缺省隊(duì)