兩個(gè)MQ隊(duì)列管理器之間互相放消

1、令CtiinaEtakServiM本地和遠(yuǎn)程隊(duì)列的單個(gè)隊(duì)列管理器實(shí)現(xiàn)過(guò)程-6月份技能提升內(nèi)容1、基礎(chǔ)環(huán)境硬件環(huán)境2臺(tái)LIUNX服務(wù)器操作系統(tǒng)版本AS4IP地址192.168.1.240192.168.1.242隊(duì)列管理器QM_LINUX240QM_LINUX242HOSTNAMEproduct240product2422、安裝 MQ在第一章中我們已經(jīng)學(xué)會(huì)了如何安裝MQ了，在這里就不在詳細(xì)闡述具體步驟了，我們需要是把兩臺(tái)服務(wù)器都安裝MQ安裝WebSphereMQ前，必須執(zhí)行./mqlicense.sh,以閱讀和接受許可證。安裝所需的MQ包及WebSphereMQJava和IBMJavaSDK包,

2、以便為WebSphereMQFF發(fā)Java客戶機(jī)：mqmproduct240nstall#rpm-ivhIBMJava2-SDK-1.4.2-0.0.i386.rpmmqmproduct240install#rpm-ivhMQSeriesRuntime-6.0.0-0.i386.rpmmqmproduct240nstall#rpm-ivhMQSeriesServer-6.0.0-0.i386.rpmmqmproduct240install#rpm-ivhMQSeriesJava-6.0.0-0.i386.rpmWebSphereMQ現(xiàn)在已經(jīng)完成安裝，并有用于進(jìn)行配置的名為mqm的用戶和組。缺省

3、情況下，WebSphereMC&裝在/opt/mqm中，隊(duì)列和其他配置信息位于用戶mqm的主目錄中。JavaSDK安裝在/opt/IBMJava2-142中，Java解釋程序位于/opt/舊MJava2-142/bin中。3、MQTCP 連接配置命令在配置之前有必要先了解一下WebSphereMQ語(yǔ)和定義1) WebSphereMQ語(yǔ)和定義隊(duì)列管理器-提供隊(duì)列服務(wù)和API及用于管理隊(duì)列的管理功能的系統(tǒng)管理程序。隊(duì)列-消息所發(fā)送到的命名目的地。本地隊(duì)列-位于隊(duì)列管理器本地的隊(duì)列。遠(yuǎn)程隊(duì)列-駐留在其他隊(duì)列管理器(可能位于其他主機(jī)上)的隊(duì)列。傳輸隊(duì)列-以遠(yuǎn)程隊(duì)列為目標(biāo)的臨時(shí)消息隊(duì)列。通道-隊(duì)

4、列管理器之間的通信路徑。偵聽(tīng)器-從客戶機(jī)或其他隊(duì)列管理器接受網(wǎng)絡(luò)請(qǐng)求。命令服務(wù)器-驗(yàn)證命令并將有效命令發(fā)送到命令處理器(后者隨后執(zhí)行命令)。2) MQTCR1接配置命令在product240機(jī)器上執(zhí)行如下操作創(chuàng)建隊(duì)列管理器mqmproduct240#crtmqmQM_LINUX240啟動(dòng)隊(duì)列管理器mqmproduct240#strmqmQM_LINUX240使用MQ空制臺(tái)命令RUNMQS置runmqscQM_LINUX240創(chuàng)建死信隊(duì)列：DEFINEQL(RE240.DEADQ)DEFPSIST(YES)更改隊(duì)列管理器屬性，設(shè)置死信隊(duì)列為NT.DEADQALTERQMGRDEADQ(RE240

5、.DEADQ)創(chuàng)建本地傳輸隊(duì)列RE242DEFINEQLOCAL(RE242)+DEFPSIST(YES)創(chuàng)建遠(yuǎn)程隊(duì)列TO.RE242,對(duì)應(yīng)于RE242上的本地隊(duì)列FROM.RE240,傳輸隊(duì)列為RE242DEFINEQREMOTE(TO.RE242)+RNAME(FROM.RE240)+RQMNAME(QM_LINUX242)+XMITQ(RE242)創(chuàng)建發(fā)送通道RE240.TO.RE242,使用TCPIP協(xié)議，遠(yuǎn)程主機(jī)地址為192.168.1.242port為1414,傳輸隊(duì)列為RE242DEFINECHANNEL(RE240.TO.RE242)+CHLTYPE(SDR)+CONNAME(

6、192.168.1.242(1414)+XMITQ(RE242)創(chuàng)建本地監(jiān)聽(tīng)DEFINELISTENER(LN240)+TRPTYPE(TCP)+PORT(1414)+IPADDR(192.168.1.240)+CONTROL(QMGR)在product242機(jī)器上執(zhí)行如下操作創(chuàng)建隊(duì)列管理器mqmproduct242#crtmqmQM_LINUX242啟動(dòng)隊(duì)列管理器mqmproduct242#strmqmQM_LINUX242使用MQ空制臺(tái)命令RUNMQS置runmqscQM_LINUX242創(chuàng)建死信隊(duì)列：DEFINEQL(RE242.DEADQ)DEFPSIST(YES)更改隊(duì)列管理器屬性，

7、設(shè)置死信隊(duì)列為NT.DEADQALTERQMGRDEADQ(RE242.DEADQ)創(chuàng)建本地隊(duì)列FROM.RE240:DEFINEQLOCAL(FROM.RE240)DEFPSIST(YES)創(chuàng)建接收通道RE240.TO.RE242,使用TCPIP協(xié)議，傳輸隊(duì)列為RE240DEFINECHANNEL(RE240.TO.RE242)CHLTYPE(RCVR)創(chuàng)建本地監(jiān)聽(tīng)DEFINELISTENER(LN242)+TRPTYPE(TCP)+PORT(1414)+IPADDR(192.168.1.242)+CONTROL(QMGR)3）分別啟動(dòng)兩節(jié)點(diǎn)監(jiān)聽(tīng)xj鍛造掇練IT服符助推用戶事業(yè)發(fā)展Perfe

8、ctingITand后而gclients,5uec青狗CJh訪iEtekServico”runmqlsr-tTCPp1414mQM_LINUX240&runmqlsr-tTCPp1414mQM_LINUX242&4)啟動(dòng)通道runmqchl-mQM_LINUX240-cRE240.TO.RE242&或者到MQ空制臺(tái)里面執(zhí)行如下命令啟動(dòng)RunmqscQM_LINUX240startCHANNEL(RE240.TO.RE242)5)MQTCP1接驗(yàn)證RE240向RE242發(fā)送消息，RE240端運(yùn)行：$cd/opt/mqm/samp/bin./amqsputTO.RE242Q

9、M_LINUX240roduct240binS./aBqsputTO.KE242Q1_LIITUX240SampleAIQSPUTOstarttar&etqueueisTO.RE242thisistestcherry,yang2232198211093S21SampleAIQSPDTOendaqadproduct240binS在提示下輸入字符，每條消息以回車鍵作結(jié)束。若不輸任何字符，擊回車鍵時(shí)將退出該程序。RE24洲在/usr/lpp/mqm/samp/bin下，運(yùn)行：$cd/opt/mqm/samp/bin./amqsgetFROM.RE240QM_LINUX242qoduct242

10、bin$./aMqsgetFROI.RE240QK_LIHUX242SampleAIQSGETOstartAessageMessageessagenoaoremessagesSupleAAQSGETOend1 q rQduQUAKE(VBQI242)使用MQ空制臺(tái)命令RUNMQ眥置runmqscWMQM242創(chuàng)建死信隊(duì)列：DEFINEQL(WMQM240.DEADQ)DEFPSIST(YES)更改隊(duì)列管理器屬性，設(shè)置死信隊(duì)列為NT.DEADQALTERQMGRDEADWMQM240.DEADQ)創(chuàng)建本地傳輸隊(duì)列WMQM240:DEFINEQLOCALWMQM240)+DEFPSIST(YES)

11、STATUS(Running)STATUS(Kuiming)創(chuàng)建遠(yuǎn)程隊(duì)列TO.WMQM240,對(duì)應(yīng)于WMQM24(t的本地隊(duì)列FROM.WMQM24求輸隊(duì)列為WMQM240DEFINEQREMOTE(TO.WMQM240)+RNAME(FROM.WMQM242)+RQMNAME(WMQM240)+隊(duì)列管理器的名字XMITQ(WMQM240)創(chuàng)建發(fā)送通道WMQM242.TO.WMQM240用TCPIP協(xié)議，遠(yuǎn)程主機(jī)地址為192.168.1.240port為1415,傳輸隊(duì)列為WMQM240DEFINECHANNEL(WMQM242.TO.WMQM240)+CHLTYPE(SDR)+CONNAME

12、(192.168.1.240(1415)+XMITQ(WMQM240)創(chuàng)建本地監(jiān)聽(tīng)DEFINELISTENER(LN242)+TRPTYPE(TCP)+PORT(1415)+IPADDR(192.168.1.242)+CONTROL(QMGR)說(shuō)明：上面的監(jiān)聽(tīng)其實(shí)可以不用創(chuàng)建了，因?yàn)樵诘谌碌臅r(shí)候已經(jīng)創(chuàng)建完成了在product240機(jī)器上執(zhí)行如下操作創(chuàng)建隊(duì)列管理器mqmproduct240#crtmqmWMQM240啟動(dòng)隊(duì)列管理器mqmproduct240#strmqmWMQM240查看隊(duì)列管理器狀態(tài)aqsdproduct240$dspqQ1NA1E(Ql_LTNUX240)jINAXE( (

13、nQI240) )使用MQ空制臺(tái)命令RUNMQ眥置runmqscWMQM240創(chuàng)建死信隊(duì)列：DEFINEQL(WMQM240.DEADQ)DEFPSIST(YES)更改隊(duì)列管理器屬性，設(shè)置死信隊(duì)列為WMQM240.DEADQALTERQMGRDEADQ(WMQM240.DEADQ)創(chuàng)建本地隊(duì)列FROM.WMQM242:DEFINEQLOCAL(FROM.WMQM242)DEFPSIST(YES)創(chuàng)建接收通道WMQM242.TO.WMQM240用TCPIP協(xié)議，傳輸隊(duì)列為WMQM242DEFINECHANNEL(WMQM242.TO.WMQM240)CHLTYPE(RCVR)創(chuàng)建本地監(jiān)聽(tīng)DEFI

14、NELISTENER(LN240)+TRPTYPE(TCP)+PORT(1415)+STATUS(Running)STATUS(Running)IPADDR(192,168.1.240)+CONTROL(QMGR)3)分別啟動(dòng)兩節(jié)點(diǎn)監(jiān)聽(tīng)runmqlsr-tTCP-p1415-mWMQM240&runmqlsr-tTCP-p1415-mWMQM242&4)在發(fā)送端啟動(dòng)通道runmqchl-mWMQM242-cWMQM242.TO.WMQM240&或者到MQ空制臺(tái)里面執(zhí)行如下命令啟動(dòng)RunmqscWMQM242startCHANNEL(WMQM242.TO.WMQM240)

15、21:dischs(V1Q 242.T0.VIQ，24( (DASQ8417:DisplayChannelStatusdetailsCHANNEL( (nQ1242.TO-nQI240)COOAE(192.168.1.240(1415)RQflNAflE( (nQA24D)SnBSTATE(KQGET)在接收端查看6:dischs(YIQ1242.TO.V1Q1240)A1Q8417:Disp1ayChannelStatusdetails.CHAHNEL(TIQ1242.TO-I1Q1240)CONNAIE(192.168.1.242)RQUTABE(V1QI242)SUBSTATE(RECE

16、IVE)5) MQTCP1接驗(yàn)證WMQM242WMQM24發(fā)送消息，WMQM24端運(yùn)行:$cd/opt/mqm/samp/bin./amqsputTO.WMQM240WMQM242*qBdproduct242bin$./aBQsputTO.HQI240HQV242SampleAIQSPUTDstarttargetqueueisTO.HQ1240thisisatestynaeischerry,yanglabilehengfenzhenghaotp:/vw_ce-service_COK_CILSampleAIQSPUTOend q

17、-roduct242binj$,CHLTYPE(SDR)CURRENTSTATUS(RUNNING)X1ITQ(RQI240)CHLTTPE(RCVR)CURRENTSTATUS(RUKHING)XIITQC)在提示下輸入字符，每條消息以回車鍵作結(jié)束。若不輸任何字符，擊回車鍵時(shí)將退出該程序。WMQM2端在/usr/lpp/mqm/samp/bin下，運(yùn)行：$cd/opt/mqm/samp/bin./amqsgetFROM.WMQM242WMQM240MQBproduct240bin$,/aqsgetFR0I.nQI242nQff240SapleAIQSGETOstartessaeemessag

18、enaeischerry.yantessagemessageshengfenzhenghaoessage6）總結(jié)：至此實(shí)現(xiàn)了兩個(gè)MCR列管理器之前相互放消息的目的。不過(guò)在搭建該實(shí)驗(yàn)也出現(xiàn)了一些問(wèn)題概況如下：1.監(jiān)聽(tīng)端口:不能重復(fù)。當(dāng)實(shí)現(xiàn)IP242到IP240發(fā)生消息時(shí)候由于我當(dāng)時(shí)設(shè)置的和1414一樣導(dǎo)致發(fā)送的消息到了第個(gè)隊(duì)列管理器。2.正確配置傳輸隊(duì)列的名字。創(chuàng)建發(fā)送通道WMQM242.TO.WMQM240用TCPIP協(xié)議，遠(yuǎn)程主機(jī)地址為192.168.1.240port為1415,傳輸隊(duì)列為WMQM240且是我在創(chuàng)建的時(shí)候?qū)懗闪薟MQM242果在監(jiān)聽(tīng)正常、通道都正常的情況下導(dǎo)致發(fā)送消息報(bào)錯(cuò)如下圖：QT1-QL2消息被放入到遠(yuǎn)程隊(duì)列中，遠(yuǎn)程隊(duì)列通過(guò)傳輸隊(duì)列傳輸，最后傳輸?shù)絈M好的本地隊(duì)列。還是不能不能放消息怎么辦？(1)不能放入消息。一般這種情況應(yīng)該大部分是遠(yuǎn)程隊(duì)列中的傳輸隊(duì)列那個(gè)參數(shù)配置的不正確。還有可能是隊(duì)列的允許放入這個(gè)參數(shù)設(shè)置成了禁止?；旧暇瓦@兩種情況。(2)發(fā)送通道和接收通道的狀態(tài)不是running首先說(shuō)明，如果長(zhǎng)時(shí)間沒(méi)有消息傳輸，通道的狀態(tài)會(huì)變成不活動(dòng)狀態(tài)，這是正?，F(xiàn)象。如果