【導(dǎo)讀】交通銀行張江數(shù)據(jù)中心系統(tǒng)部。A–新增M–修改D–刪除。版本號(hào)日期修訂人審批人AMD概要描述V012020-11-15伍建焜。MQ隊(duì)列管理器控制20. MQ命令服務(wù)器控制22. MQ觸發(fā)監(jiān)控器控制24. 隊(duì)列管理器管理26. 隊(duì)列管理器日志36. 隊(duì)列與隊(duì)列管理器別名63. WebSphereMQ本質(zhì)上是一種消息中間件用于保證異構(gòu)應(yīng)用之間的消息傳遞應(yīng)用程序。WebSphereMQ運(yùn)行環(huán)境中有較多的概念其中有一部分是可以作為實(shí)體進(jìn)行的操作的。列隊(duì)列管理器通道是MQ中最重要的概念和對(duì)象。消息數(shù)據(jù)頭是對(duì)消息屬性的描述這段信息往往被隊(duì)列管理器用來確定對(duì)消息的處理消。就是在WebSphereMQ隊(duì)列管理器重啟動(dòng)后消息是否仍然能保持。一個(gè)隊(duì)列管理器下轄很多個(gè)消息隊(duì)列但每個(gè)隊(duì)列卻只能屬于一個(gè)隊(duì)列管理器隊(duì)列在它。隊(duì)列管理器目標(biāo)隊(duì)列是消息的目的地可以長期存放消息如果消息不能送達(dá)目標(biāo)隊(duì)列也不能。MQGET和MQPUT以收發(fā)消息這也是系統(tǒng)中用得最多的消息隊(duì)列通常在不致引起混淆的情。要送往遠(yuǎn)地的消息將放入傳輸隊(duì)列在適當(dāng)?shù)臅r(shí)候消息會(huì)被從傳輸隊(duì)列中取出并送往遠(yuǎn)地最。列以存放觸發(fā)消息這

　　

【正文】 Server 的地址與端口且設(shè)定了用戶名與密碼 ALTER AUTHINFO AI CONNAME 1 5000 LDAPUSER user LDAPPWD pwd 刪除認(rèn)證信息定義 AI DELETE AUTHINFO AI 33 基本隊(duì)列操作 WebSphere MQ提供了一些缺省的基本隊(duì)列操作命令如表 31所示通過它們可以對(duì)隊(duì)列進(jìn)行最基本的讀寫操作這些命令實(shí)際上都是 WebSphere MQ 應(yīng)用程序在安裝目錄中可以找到它們的源代碼 表 31 MQ 基本隊(duì)列操作命令 這些基本隊(duì)列操作命令分成兩類一類在 MQ Server 端運(yùn)行它們是amqsputamqsgetamqsbcg另一類在 MQ Client端 運(yùn)行它們是 amqsputcamqsgetcamqsbcgc命令執(zhí)行的語法都類似以 amqsput為例格式為 amqsput QueueName [QueueManagerName]其中QueueName 為隊(duì)列名 QueueManagerName為隊(duì)列管理器如果不指明則為缺省隊(duì)列管理器 amqsput 和 amqsputc可以將消息放入隊(duì)列中程序把之后的每一行標(biāo)準(zhǔn)輸入作為一條獨(dú)立的消息讀到 EOF或空行時(shí)退出注意 UNIX上的 EOF為 CtrlDWindows上的 EOF為 CtrlZ可以將標(biāo)準(zhǔn)輸入重定向到文件隊(duì)列中 每放入一條消息隊(duì)列深度增加一 amqsget和 amqsgetc可以將消息從隊(duì)列中全部讀出并顯示讀空后再等待 15 秒在這段時(shí)間內(nèi)如果有新的消息到達(dá)會(huì)一并讀出如果強(qiáng)行中斷該程序比如用 CtrlC 強(qiáng)行退出這時(shí)等待著的 MQGET讀操作尚未完成用 MQSC命令 DISPLAY QSTATUS Q TYPE HANDLE OPENTYPE OUTPUT ALL 也可以觀察到 MQGET 讀操作會(huì)在一段時(shí)間后自動(dòng)撤消在這段時(shí)間內(nèi)如果有新的消息到達(dá)則第一條消息會(huì)被隱式地讀走而丟失 amqsget 和 amqsgetc執(zhí)行 后隊(duì)列應(yīng)該為空即隊(duì)列深度為零 amqsbcg和 amqsbcgc可以將詳細(xì)查閱隊(duì)列中現(xiàn)有的消息屬性及內(nèi)容而不將其取出它與amqsget和 amqsgetc唯一的差別就是查閱后消息仍然保留在隊(duì)列中隊(duì)列深度不變 34 MQ 配置信息 WebSphere MQ的配置信息反映了當(dāng)前 MQ運(yùn)行環(huán)境的設(shè)置在 UNIX中這些信息記錄在配置文件中在 Windows中記錄在系統(tǒng)注冊(cè)表中通常情況下 MQ提供了管理命令或工具來修改這些設(shè)置建議用戶不要輕易地進(jìn)行手工修改 UNIX 配置文件 UNIX平臺(tái)上的 WebSphere MQ配置文件有兩種一種為 mqsini它是針對(duì)整個(gè) MQ運(yùn)行環(huán)境的一臺(tái)機(jī)器只有一個(gè)這樣的文件另一種為 mqini 它是針對(duì)某個(gè)隊(duì)列管理器配置的每個(gè)隊(duì)列管理器有一個(gè)這樣的文件管理員可以編輯這些文件以修改配置 配置文件是分段的每一段 stanza 有一個(gè)標(biāo)題以冒號(hào) 結(jié)尾每一段中有多條屬性設(shè)置 Entry 它們都是屬性名 屬性值 Name Value 的格式這里缺省情況下配置文件中的段和設(shè)置都是比較精簡(jiǎn)的不需要的部分可以不出現(xiàn)在實(shí)際運(yùn)行環(huán)境下段和設(shè)置都是可以根據(jù)需要增減的配置文件中共可以有哪 些段各段中可以有哪些設(shè)置在 WebSphere MQ 中都有規(guī)定段不分先后次序段中的設(shè)置也不分先后次序 下面以 WebSphere MQ for AIX為例看一看缺省的 mqsini 和 qmini 隊(duì)列管理器名為 QM 1 mqsini AllQueueManagers DefaultPrefix varmqm ClientExitPath ExitsDefaultPath varmqmexits LogDefaults LogPrimaryFiles 3 LogSecondaryFiles 2 LogFilePages 1024 LogType CIRCULAR LogBufferPages 0 LogDefaultPath varmqmlog QueueManager Name QM Prefix varmqm Directory QM 在 mqsini配置文件中規(guī)定了整個(gè) WebSphere MQ的工作目錄為 varmqm隊(duì)列管理器缺省有 3個(gè)主 Log文件 2個(gè)備用 Log文件每個(gè) Log文件大小為 1024頁 一頁為 4KB Log文件缺省采用環(huán)形模式組織且在 varmqmlog目錄下 當(dāng)前有一個(gè)隊(duì)列管理器名為 QM它的工作目錄為 varmqm下的 QM即 varmqmQM目錄 2 qmini ExitPath ExitsDefaultPath varmqmexits Log LogPrimaryFiles 3 LogSecondaryFiles 2 LogFilePages 1024 LogType CIRCULAR LogBufferPages 0 LogPath varmqmlogQM LogWriteIntegrity TripleWrite 在 qmini配置文件中中規(guī)定了隊(duì)列管理器 QM 的一些參數(shù)它有 3個(gè)主 Log文件 2個(gè)備用Log 文件每個(gè) Log 文件大小為 1024 頁 一頁為 4KB Log 文件缺省采用環(huán)形模式組織且在 varmqmlogQM目錄下 Log用 TripleWrite 方式保持日志完整性注意 qmini 中可能有一些參數(shù)名與 mqsini相同但設(shè)置值不同則對(duì)于該隊(duì)列管理器而言以 qmini為準(zhǔn) 35 MQ 管理方式 WebSphere MQ 的管理方式可以分成本地管理和遠(yuǎn)程管理器兩種無論是是哪一種方式都可以通過命令行或圖形界面工具來完成本地管理指通 過管理工具對(duì)本地的隊(duì)列管理器實(shí)施管理即管理工具與被管理的隊(duì)列管理器在同一臺(tái)機(jī)器上遠(yuǎn)程管理則是通過一定的設(shè)置用相同的管理工具管理另一臺(tái)機(jī)器上的隊(duì)列管理器 本地管理 1 用 RUNMQSC 實(shí)現(xiàn)本地管理 RUNMQSC是一個(gè)通用的 MQ對(duì)象管理工具使用 MQSC命令集可以對(duì) MQ對(duì)象進(jìn)行全方位的管理也是各種管理方式最直接最全面的一種 在隊(duì)列管理器所有機(jī)器的命令行中執(zhí)行 RUNMQSC 即可進(jìn)入 RUNMQSC 的交互界面其中 是本地的隊(duì)列管理器名 2 用 PCF 編程實(shí)現(xiàn)本地管理 WebSphere MQ資源管理器實(shí)際上把管理指令以 PCF消息的格式放入被管理的隊(duì)列管理器的 SYANDQUEUE 中由該隊(duì)列管理器上的命令服務(wù)器執(zhí)行并返回結(jié)果再在圖形界面上表現(xiàn)出來 WebSphere MQ遠(yuǎn)程管理實(shí)際上也是這個(gè)原理 PCF消息遵循一定的格式如果通過編程人為地構(gòu)造一條 PCF消息并用 MQPUT放入 SYAND QUEUE中就可以編程向隊(duì)列管理器發(fā)送一條管理指令了消息中設(shè)置 ReplyToQ 指定結(jié)果的返回隊(duì)列命令服務(wù)器在執(zhí)行完畢后會(huì)返回一條結(jié)果消息該消息也遵循同樣的格式也是一條 PCF 消息基于 這個(gè)原理可以通過 PCF編程在程序中隨心所欲控制并管理隊(duì)列管理器如果管理指令來自遠(yuǎn)端則可以很方便地實(shí)現(xiàn)遠(yuǎn)程管理 遠(yuǎn)程管理 WebSphere MQ的遠(yuǎn)程管理的原理是將管理命令包裝成 PCF消息并傳送到遠(yuǎn)程隊(duì)列管理器的命令隊(duì)列 SYANDQUEUE 中命令服務(wù)器將管理消息讀走并執(zhí)行再將執(zhí)行結(jié)果也包裝成 PCF格式的消息并返回如圖 31所示返回隊(duì)列由管理消息的 ReplyToQ域指定另外要實(shí)現(xiàn)遠(yuǎn)程管理被管理的隊(duì)列管理器的命令服務(wù)器必須首先啟動(dòng) 圖 31 MQ遠(yuǎn)程管理的原理 1 用 RUNQMSC 實(shí)現(xiàn) 遠(yuǎn)程管理 可以用通用的 RUNMQSC 命令行管理工具對(duì)遠(yuǎn)程隊(duì)列管理器實(shí)施管理這里假定 QM1 為本地缺省隊(duì)列管理器 QM2為受管理的遠(yuǎn)程隊(duì)列管理器步驟如下 1 確認(rèn)隊(duì)列管理器上有 SYANDQUEUE 隊(duì)列并啟動(dòng)遠(yuǎn)程的隊(duì)列管理器的命令服務(wù)器進(jìn)程 strmqcsv QM2 2 在本地建立缺省隊(duì)列管理器并與遠(yuǎn)程隊(duì)列管理器建立雙向通道 QM1 DEFINE CHANNEL C_QM1QM2 CHLTYPE SDR TRPTYPE TCP CONNAME 21 1416 XMITQ QM2 REPLACE DEFINE CHANNEL C_QM2QM1 CHLTYPE RCVR TRPTYPE TCP REPLACE DEFINE QLOCAL QM2 USAGE XMITQ REPLACE QM2 DEFINE CHANNEL C_QM1QM2 CHLTYPE RCVR TRPTYPE TCP REPLACE DEFINE CHANNEL C_QM2QM1 CHLTYPE SDR TRPTYPE TCP CONNAME 11 1415 XMITQ QM1 REPLACE DEFINE QLOCAL QM1 USAGE XMITQ REPLACE 3 本地和遠(yuǎn)程隊(duì)列管理器都要有相應(yīng)的 TCPIP Listener runmqlsr –m QM1 –t tcp –p 1415 runmqlsr m QM2 t tcp p 1416 4 通過 RUNMQSC進(jìn)行管理這時(shí) RUNMQSC工具首先連接本地缺省隊(duì)列管理器再通過 事先配置并連接好的通道把命令發(fā)往指定的隊(duì)列管理器命令執(zhí)行結(jié)果原路返回由于涉及隊(duì)列管理器之間的通信可以用 w 選項(xiàng)設(shè)定超時(shí)時(shí)間 秒 如果在規(guī)定的時(shí)間內(nèi)命令結(jié)果沒有返回則執(zhí)行失敗 runmqsc w 100 QM2 resultout 2 用 MQ 資源管理器實(shí)現(xiàn)遠(yuǎn)程管理 可以用 Windows下的 WebSphere MQ資源管理器進(jìn)行遠(yuǎn)程監(jiān)控從而利用該管理工具友好的圖形界面進(jìn)行遠(yuǎn)程管理步驟如下 1 確認(rèn)隊(duì)列管理器上有 SYANDQUEUE 隊(duì)列并啟動(dòng)遠(yuǎn)程的隊(duì)列管理器的 命令服務(wù)器進(jìn)程 strmqcsv 2 遠(yuǎn)程的隊(duì)列管理器至少有一個(gè) TCPIP Listener 可以是 runmqlsr也可以是 id runmqlsr m t tcp p 3 在遠(yuǎn)程的隊(duì)列管理器上配置名為 SYONN的 ServerConnection通道 DEFINE CHANNEL SYONN CHLTYPE SVRCONN TRPTYPE TCP MCAUSER mqm REPLACE 4 在 Windows平臺(tái)上的 WebSphere MQ資源管理器中點(diǎn)擊隊(duì)列管理器右鍵選擇顯示隊(duì)列管理器在彈出菜單中選中顯示遠(yuǎn)程隊(duì)列管理器給出隊(duì)列管理器名稱和連接名稱其中連接名稱要與通道的 CONNAME 屬性相符需要含有遠(yuǎn)程隊(duì)列管理器的地址和監(jiān)聽端口可以是 IP Port 格式如圖 32所示版本不同略有差別但所需信息一致 圖 32 用 WebSphere MQ資源管理器遠(yuǎn)程管理 36 日志 Log WebSphere MQ中日志為系統(tǒng)的穩(wěn)定運(yùn)行和消息的可靠傳遞提供了保障在 WebSphere MQ 中扮演著不可缺 少的角色基本上 MQ 的對(duì)象操作及對(duì)持久消息的操作都會(huì)記入日志中在系統(tǒng)故障時(shí)日志可以幫助 MQ 隊(duì)列管理器在重啟動(dòng)后恢復(fù)到原來的狀態(tài)所有的持久消息仍然保留不丟失日志也可以用來將整個(gè) MQ 對(duì)象整體記錄以便日后進(jìn)行對(duì)象整體恢復(fù)因?yàn)槿罩緲O其重要所以對(duì)日志文件的定期備份就顯得十分必要 隊(duì)列管理器日志 隊(duì)列管理器的日志是隨著隊(duì)列管理器一起創(chuàng)建的在創(chuàng)建隊(duì)列管理器時(shí)可以指定日志屬性其中一部分屬性也可以在隊(duì)列管理器創(chuàng)建后再修改調(diào)整對(duì)于創(chuàng)建時(shí)未指定的參數(shù)WebSphere MQ使用缺省參數(shù)值 日志中記錄了隊(duì)列 管理器的各種活動(dòng)包括創(chuàng)建和刪除對(duì)象 除通道外 持久性消息交易狀態(tài)對(duì)象狀態(tài)的更改通道的活動(dòng)等等所以在 WebSphere MQ 系統(tǒng)出了以下問題的時(shí)候日志可以用來做恢復(fù) 重啟恢復(fù) Restart Recovery 在重新啟動(dòng) WebSphere MQ后保證所有的持久性消息都還在所有的交易回滾到發(fā)生前的狀態(tài)刪除未提交的消息由于非持久消息是不記錄日志的所以恢復(fù)只針對(duì)持久消息 損壞恢復(fù) Crash Recovery WebSphere MQ由于內(nèi)部錯(cuò)誤非正常停止重啟動(dòng)后恢復(fù)到檢查點(diǎn)CheckPoint即隊(duì)列管理器與 日志一致點(diǎn) 介質(zhì)恢復(fù) Media Recovery 在介質(zhì)損毀修復(fù)后根據(jù)日志修復(fù)出對(duì)象 1 日志文件 WebSphere MQ日志分成兩部分多個(gè)日志數(shù)據(jù)文件和一個(gè)日志控制文件在 UNIX中缺省在 varmqmlogQmNameactive目錄下每個(gè)文件缺省大小 4MB生產(chǎn)環(huán)境根據(jù)規(guī)范指定數(shù)據(jù)文件有主數(shù)據(jù)