【正文】 MQ運(yùn)維手冊(cè) 交通銀行 張江數(shù)據(jù)中心 系統(tǒng)部 11152020 A – 新增 M – 修改 D – 刪除 版本號(hào) 日期 修訂人 審批人 AMD 概 要 描 述 V01 20201115 伍建焜 A 全文創(chuàng)建 目 錄 一概念與對(duì)象 6 11 消息 Message 6 12 隊(duì)列 Queue 6 本地隊(duì)列 7 13 隊(duì)列管理器 Queue Manager 10 14 通道 Channel 11 通道類型 Channel Type 11 消息通道協(xié)議 MCP 13 消息通道代理 MCA 13 15 名稱列表 Name List 13 16 分發(fā)列表 Distribution List 14 17 進(jìn)程定義 Process 14 18 認(rèn)證信息 Auth Info 14 19 客戶端和服務(wù)器端 Client Server 15 110 操作界面 MQ Interface 15 111 應(yīng)用程序 MQ Application 15 二工作原理 16 21 PUT和 GET 16 22 協(xié)同工作 17 23 互連通信 17 消息通道 Message Channel 17 消息路由 Message Routing 18 消息傳送 19 三控制與管理 20 31 MQ 控制命令 20 MQ 隊(duì)列管理器控制 20 MQ 命令服務(wù)器控制 22 MQ 監(jiān)聽器控制 23 MQ觸發(fā)監(jiān)控器控制 24 32 MQ 對(duì)象管理 25 隊(duì)列管理器管理 26 隊(duì)列管理 26 通道管理 27 進(jìn)程定義管理 29 名稱列表管理 29 認(rèn)證信息管理 30 33 基本隊(duì)列操作 30 34 MQ 配置信息 31 UNIX 配置文件 31 35 MQ 管理方式 33 本地管理 33 遠(yuǎn)程管理 33 36 日志 Log 36 隊(duì)列管理器日志 36 檢查點(diǎn) Checkpoint 38 記錄和復(fù)原 Record Recover 39 備份和恢復(fù) Backup Restore 40 導(dǎo)出日志 Dump Log 41 四通信與配置 42 41 消息路由 42 消息路由過程 42 缺省傳輸隊(duì)列 43 隊(duì)列管理器別名 43 多級(jí)跳 43 傳輸中的消息 43 42 通道配置 45 Sender QM1 Receiver QM2 46 Server QM1 Receiver QM2 46 Server QM1 Requester QM2 47 Sender QM1 Requester QM2 48 通道啟動(dòng)命令 49 通道監(jiān)控程序 49 43 通道的屬性 50 通道會(huì)話 50 通道協(xié)議 53 44通道的狀態(tài) 54 公共狀態(tài) Common Status 54 當(dāng)前狀態(tài) CurrentOnly Status 55 通道狀態(tài)分析 56 45互連配置舉例 60 單向傳送 61 雙向傳送 62 隊(duì)列與隊(duì)列管理器別名 63 三級(jí)跳 Multihopping 64 四級(jí)跳 Multihopping 65 五群集 68 51相關(guān)概念 68 配置庫 Repository 68 配置庫隊(duì)列管理器 Repository Queue Manager 69 群集通道 Cluster Channel 69 群集隊(duì)列 Cluster Queue 69 群集傳輸隊(duì)列 Cluster transmission queue 70 52群集管理 70 對(duì)象屬性 70 管理命令 70 管理任務(wù)舉例 71 53群集配置舉例 72 例 172 例 274 例 376 例 479 例 581 例 683 六廣播通信 87 61 分發(fā)列表 Distribution List 87 概念 87 配置舉例 88 七客戶端 90 71 配置 90 Server 端配置 91 Client 端配置 91 72 用戶出口 96 用戶出口路徑 96 排錯(cuò) 97 一概念與對(duì)象 WebSphere MQ 本質(zhì)上是一種消息中間件用于保證異構(gòu)應(yīng)用之間的消息傳遞應(yīng)用程序通過 MQ 接口進(jìn)行互連通信可以不必關(guān)心網(wǎng)絡(luò)上的通信細(xì)節(jié)從而將更多的注意力集中于應(yīng)用本身 MQ 在所有的平臺(tái)上有統(tǒng)一的操作界面這使得應(yīng)用程序可以很方便地移植到各種操作系統(tǒng)中 WebSphere MQ 運(yùn)行環(huán)境中有較多的概念其中有一部分是可以作為實(shí)體進(jìn)行的操作的稱為 MQ 對(duì)象每一個(gè)對(duì)象都有各自的屬性不同的屬性決定了對(duì)象的特性和工作方式消息隊(duì)列隊(duì)列管理器通道是 MQ 中最重 要的概念和對(duì)象 11 消息 Message 消息是 WebSphere MQ 中最小的概念本質(zhì)上就是一段數(shù)據(jù)它能被一個(gè)或多個(gè)應(yīng)用程序所理解是應(yīng)用程序之間傳遞的信息載體消息可以大致分成兩部分 應(yīng)用數(shù)據(jù)體和消息數(shù)據(jù)頭 消息數(shù)據(jù)頭是對(duì)消息屬性的描述這段信息往往被隊(duì)列管理器用來確定對(duì)消息的處理消息數(shù)據(jù)頭可以由應(yīng)用程序或系統(tǒng)的消息服務(wù)程序共同產(chǎn)生它包含了消息在傳送中的必要信息如目標(biāo)隊(duì)列管理器的名字目標(biāo)隊(duì)列的名字以及消息的其它一些屬性 應(yīng)用數(shù)據(jù)體是應(yīng)用間傳送的實(shí)質(zhì)的數(shù)據(jù)消息它可以是字串?dāng)?shù)據(jù) 結(jié)構(gòu)甚至二進(jìn)制數(shù)據(jù)包含的內(nèi)容可以是文本文件聲音圖像等任何數(shù)據(jù)這些數(shù)據(jù)只對(duì)特定的應(yīng)用具有特定的含義所以應(yīng)用數(shù)據(jù)體的結(jié)構(gòu)和內(nèi)容由應(yīng)用程序定義通信雙方需要事先約定報(bào)文格式 消息可以分成持久 Persistent 消息和非持久 NonPersistent 消息所謂持久的意思就是在 WebSphere MQ 隊(duì)列管理器重啟動(dòng)后消息是否仍然能保持 12 隊(duì)列 Queue 可以簡(jiǎn)單地把隊(duì)列看成一個(gè)容器用于存放消息隊(duì)列按其定義可分成本地隊(duì)列遠(yuǎn)程隊(duì)列定義別名隊(duì)列定義模型隊(duì)列定義如圖 11 所示其中只有 本地隊(duì)列是真正意義上的隊(duì)列實(shí)體可以存放消息遠(yuǎn)程隊(duì)列定義和別名隊(duì)列定義只是一個(gè)隊(duì)列定義指向另一個(gè)隊(duì)列實(shí)體遠(yuǎn)程隊(duì)列定義指向的是其它隊(duì)列管理器中的隊(duì)列而別名隊(duì)列指向的是本地隊(duì)列管理器中的隊(duì)列模型隊(duì)列有一點(diǎn)特殊它本身只是一個(gè)隊(duì)列定義描述了模型的屬性但是當(dāng)打開模型隊(duì)列的時(shí)候隊(duì)列管理器會(huì)以這個(gè)定義為模型創(chuàng)建一個(gè)本地隊(duì)列被稱為動(dòng)態(tài)隊(duì)列 一個(gè)隊(duì)列管理器下轄很多個(gè)消息隊(duì)列但每個(gè)隊(duì)列卻只能屬于一個(gè)隊(duì)列管理器隊(duì)列在它所屬的管理器中只能有一個(gè)唯一的名字不能與同一個(gè)管理器的其它隊(duì)列重名當(dāng)消息被添加到隊(duì)列中它缺省將被加到最后 與之相反刪除消息缺省卻是從頭開始 圖 11 隊(duì)列的分類 本地隊(duì)列 本地隊(duì)列按功能又可分成初始化隊(duì)列傳輸隊(duì)列目標(biāo)隊(duì)列和死信隊(duì)列初始化隊(duì)列用做消息觸發(fā)功能傳輸隊(duì)列只是暫存待傳的消息在條件許可的情況下通過管道將消息傳送其它的隊(duì)列管理器目標(biāo)隊(duì)列是消息的目的地可以長(zhǎng)期存放消息如果消息不能送達(dá)目標(biāo)隊(duì)列也不能再路由出去則被自動(dòng)放入死信隊(duì)列保存 圖 12 各種隊(duì)列在消息傳送時(shí)的作用 1 普通隊(duì)列 能夠真正長(zhǎng)期存放消息的本地隊(duì)列我們稱之為普通隊(duì)列一般說來應(yīng)用程序只對(duì)其做簡(jiǎn)單的 MQGET 和 MQPUT 以 收發(fā)消息這也是系統(tǒng)中用得最多的消息隊(duì)列通常在不致引起混淆的情況下我們也將普通本地隊(duì)列簡(jiǎn)稱為本地隊(duì)列 2 傳輸隊(duì)列 要送往遠(yuǎn)地的消息將放入傳輸隊(duì)列在適當(dāng)?shù)臅r(shí)候消息會(huì)被從傳輸隊(duì)列中取出并送往遠(yuǎn)地最終放入遠(yuǎn)端的本地隊(duì)列所以從本地系統(tǒng)的立場(chǎng)來看傳輸隊(duì)列是用來暫時(shí)存放輸出消息的 傳輸隊(duì)列本身是一個(gè)本地隊(duì)列它與普通隊(duì)列的差別是傳輸隊(duì)列具有的屬性 USAGE XMITQ 3 初始化隊(duì)列 初始化隊(duì)列是配合消息觸發(fā)用的如果隊(duì)列上配置有消息觸發(fā)功能則需要指定另一個(gè)相關(guān)隊(duì)列以存放觸發(fā)消息這個(gè)隊(duì)列就是初始化隊(duì)列初始化 隊(duì)列本質(zhì)上就是一個(gè)普通本地隊(duì)列 4 目標(biāo)隊(duì)列 在消息通信的時(shí)候消息最終的目的地稱為目標(biāo)隊(duì)列如果消息是通過傳輸隊(duì)列轉(zhuǎn)發(fā)WebSphere MQ 會(huì)自動(dòng)為消息體添加一個(gè)傳輸消息頭其數(shù)據(jù)結(jié)構(gòu)為 MQXQH 其中的RemoteQName 和 RemoteQMgrName 兩個(gè)域指明了目標(biāo)隊(duì)列和目標(biāo)隊(duì)列管理器如果消息被放入死信隊(duì)列則 WebSphere MQ 會(huì)自動(dòng)為消息體添加一個(gè)死信消息頭其數(shù)據(jù)結(jié)構(gòu)為 MQDLH其中 DestQName 和 DestQMgrName 兩個(gè)域指明了原消息的目標(biāo)隊(duì)列和目標(biāo)隊(duì)列管理器 5 死信隊(duì)列 死信隊(duì)列本質(zhì)上是普通的本地隊(duì)列由于隊(duì)列管理器的 DEADQ 屬性指定的該隊(duì)列為死信隊(duì)列所以隊(duì)列管理器認(rèn)為無法投遞的消息都被自動(dòng)送去該隊(duì)列由于無法投遞的消息很像信件投遞中的死信故而得名 隊(duì)列管理器在將消息放入死信隊(duì)列的時(shí)候會(huì)自動(dòng)為消息體添加一個(gè)死信消息頭其數(shù)據(jù)結(jié)構(gòu)為 MQDLH其中 Reason 域指明了消息無法投遞的原因 6 應(yīng)答隊(duì)列 由于消息在發(fā)送后需要有對(duì)方的回應(yīng)這種回應(yīng)可以是系統(tǒng)自動(dòng)產(chǎn)生的報(bào)告消息也可以是對(duì)方應(yīng)用生成的應(yīng)答消息就應(yīng)用而言這些回應(yīng)消息的目標(biāo)隊(duì)列就是應(yīng)答隊(duì)列應(yīng)答隊(duì)列通常設(shè)置在消息 頭 MQMD 的 ReplyToQ 域中它也總是與消息頭中的另一個(gè)域 ReplyToQMgr 一起使用 7 命令隊(duì)列 指的是 WebSphere MQ 隊(duì)列管理器中預(yù)定義的 SYAND QUEUE任何 MQSC命令都可以送往該隊(duì)列并被隊(duì)列管理器的命令服務(wù)器 Command Server 接收處理 8 別名隊(duì)列 別名隊(duì)列只是一種隊(duì)列定義它自身只是隊(duì)列的邏輯名字并不是隊(duì)列實(shí)體本身別名隊(duì)列的TARGQ 屬性指明了其代表的目標(biāo)隊(duì)列名稱目標(biāo)隊(duì)列通常是本地隊(duì)列其實(shí)別名隊(duì)列只是提供了隊(duì)列名稱之間的映射關(guān)系可 以將別名隊(duì)列看作是指針指向其目標(biāo)隊(duì)列注意這里的目標(biāo)隊(duì)列自身又可以是一個(gè)別名隊(duì)列指向下一個(gè)目標(biāo)隊(duì)列然而在對(duì)別名隊(duì)列打開 MQOPEN 操作時(shí)只允許別名隊(duì)列指向的目標(biāo)隊(duì)列是一個(gè)本地普通隊(duì)列即一層映射關(guān)系如果存在上述的多層映射關(guān)系則報(bào)錯(cuò) MQRC_ALIAS_BASE_Q_TYPE_ERROR 通過別名定義 WebSphere MQ 也可以動(dòng)態(tài)改變消息流向比如某程序在代碼中指定消息寫入隊(duì)列 A但是您希望在不變動(dòng)代碼的情況下將消息寫入隊(duì)列 B這時(shí)只要定義別名 B使之指向A即可再如某隊(duì)列 C是可讀可寫的本地隊(duì)列管理員希望 它對(duì)于一類程序只可讀對(duì)另一類程序只可寫這時(shí)可以對(duì) C定義兩個(gè)別名 D和 ED只允許讀 E只允許寫也就是說本地隊(duì)列 C的屬性為 GET ENABLED 且 PUT ENABLED 將 D的屬性設(shè)置為 GET ENABLED 且 PUT DISABLED E的屬性為 GET DISABLED 且 PUT ENABLED 將 D和 E分別提供給上述兩類程序使用這樣可以完全避免應(yīng)用程序的誤操作 9 遠(yuǎn)程隊(duì)列 遠(yuǎn)程隊(duì)列與別名隊(duì)列類似也只是一個(gè)隊(duì)列定義用來指定遠(yuǎn)端隊(duì)列管理器中的隊(duì)列使用了遠(yuǎn)程隊(duì)列定義程序就不需要知道目標(biāo)隊(duì)列的位置 所在的隊(duì)列管理器 遠(yuǎn)程隊(duì)列定義包括目標(biāo)隊(duì)列管理器名和目標(biāo)隊(duì)列名而這種隊(duì)列定義對(duì)于訪問地的應(yīng)用程序是透明的這種技術(shù)不但使應(yīng)用程序只需要對(duì)一個(gè)簡(jiǎn)單的隊(duì)列名操作而且可以在線地通過修改遠(yuǎn)程隊(duì)列定義而動(dòng)態(tài)改變路由 10 模型隊(duì)列 模型隊(duì)列定義了一套本地隊(duì)列的屬性集合一旦打開模型隊(duì)列隊(duì)列管理器會(huì)按這些屬性動(dòng)態(tài)地創(chuàng)建出一個(gè)本地隊(duì)列模型隊(duì)列的 DEFTYPE 屬性可以取值 PERMDYN 和 TEMPDYN分別代表永久動(dòng)態(tài)隊(duì)列和臨時(shí)動(dòng)態(tài)隊(duì)列 1 永久動(dòng)態(tài)隊(duì)列 永久動(dòng)態(tài)隊(duì)列由模型隊(duì)列動(dòng)態(tài)創(chuàng)建并可以永久存在在調(diào)用 MQOPEN 時(shí)創(chuàng)建以后就和普通的本地隊(duì)列一樣工作在調(diào)用 MQCLOSE 時(shí)缺省情況下會(huì)保留消息和隊(duì)列當(dāng)然也可以通過設(shè)置關(guān)閉選項(xiàng) Close Option 的來清除消息甚至刪除永久動(dòng)態(tài)隊(duì)列 2 臨時(shí)動(dòng)態(tài)隊(duì)列 臨時(shí)動(dòng)態(tài)隊(duì)列也是由模型隊(duì)列動(dòng)態(tài)創(chuàng)建但只在會(huì)話 Session 中臨時(shí)存在在調(diào)用 MQOPEN 時(shí)創(chuàng)建在同一個(gè)線程中 MQCLOSE 時(shí)關(guān)閉并自動(dòng)刪除 MQCLOSE 時(shí)無所謂關(guān)閉選項(xiàng) Close Option 的取值 13 隊(duì)列管理器 Queue Manager 隊(duì)列管理器構(gòu)建了獨(dú)立的 WebSphere MQ 的運(yùn)行環(huán)境它是消息隊(duì)列的管理者用來維護(hù)和管理消息隊(duì)列一臺(tái)機(jī)器上可以創(chuàng)建一個(gè)或多個(gè)隊(duì)列管理器每個(gè)隊(duì)列管理器有各自的名字通常情況下它不能與網(wǎng)絡(luò)中的其它隊(duì)列管理器重名