IBMMQ使用指引

1、IBMMQ 使用指南IBMMQ使用指南随着计算机网络和分布式应用的不断发展，远程消息传递越来越成为应用系统中不可缺少的组成部分。商业消息中间件的出现保证了消息传输的可靠性，高效率和安全性，同时也减少了系统的开发周期。目前应用最多的消息中间件产品为旧 MMQSerieSo本文就针对 MQ 勺基本操作与配置进行详细的阐述，希望对读者有所帮助。一.MCS 本操作MQt 有几个很重要的组件：队列管理器（QueueManager、队列（QueuR 和通道（Channel）。其基本的操作方法如下：创建队列管理器crtmqm-qQMgrName-q 是指创建缺省的队列管理器删除队列管理器dltmqmQmgr

2、Name启动队列管理器strmqmQmgrName如果是启动默认的队列管理器，可以不带其名字停止队列管理器endmqmQmgrNamS 控停止endmqm-iQmgrName 立即停止endmqm-pQmgrName 强制停止显示队列管理器dspmq-mQmgrName运行 MQSeries 命令runmqscQmgrName如果是默认队列管理器,可以不带其名字往队列中放消息amqsputQNameQmgrName如果队列是默认队列管理器中的队列，可以不带其队列管理器的名字从队列中取出消息amqsgetQNameQmgrName如果队列是默认队列管理器中的队列，可以不带其队列管理器的名字启动通

3、道runmqchl-cChlName-mQmgrName启动侦听runmqlsr-tTYPE-pPORT-mQMgrName停止侦听endmqlsr-mQmgrNameMQSeries 命令定义死信队列DEFINEQLOCALQNAMI)EDEFPSIST(YESREPLACE设定队列管理器的死信队列ALTERQMGRDEADQNAME定义本地队列DEFINEQL(QNAMEREPLACE定义别名队列DEFINEQALIAS(QALIASNAME)TARGQ(QNAME)远程队列定义DEFINEQREMO 烟 RNAME+RNAMEAAARQMNAMEQMGRNAME-XMITQ(QTNAME

4、定义模型队列DEFINEQMODELQNAM)EDEFTYPE(TEMPDYN定义本地传输队列DEFINEQLOCAL(QTNAME)USAGE(XMITQ)DEFPSIST(YES)+INITQ(SYSTEM.CHANNEL.INITOPROCESS(PROCESSNAME)REPLACE创建进程定义DEFINEPROCESSPRONAME+DESCRSTRING)+APPLTYPEWINDOWSN+APPLICIDCrunmqchl-cSDR_TEST-mQM_TEST)其中 APPLTYP 的值可以是：CICSUNIXWINDOWSWINDOWSNT创建发送方通道DEFINECHANNE

5、LSDRNAMECHLTYPE(SDR+CONNAME15(1418)XMITQ(QTNAMEREPLACE其中 CHLTYP 国以是：SDRSVRRCVRRQSTRCLNTCONNSVRCONNCLUSSDR 和CLUSRCVR创建接收方通道DEFINECHANNELSDR_TESTCHLTYPE(RCVRREPLACE创建服务器连接通道DEFINECHANNELSVRCONNNAMCHLTYPE(SVRCONNREPLACE显示队列的所有属性DISPLAYQUEUEQNAMI)EALL显示队列的所选属性DISPLAYQUEUEQNAMI)EDESCRGETPUTD

6、ISPLAYQUEUEQNAMI)EMAXDEPTHCURDEPTH显示队列管理器的所有属性DISPLAYQMGRALL显示进程定义DISPLAYPROCESSDRONAIME更改属性ALTERQMGRDESCRNEWDESCRIPTIONALTERQLOCALQNAMEPUT(DISABLEDALTERQALIASQNAMETARGQ(TARGQNAME删除队列DELETEQLOCALQNAM)EDELETEQREMOTQRNAME清除队列中的所有消息CLEARQLOCALQNAME 二.配置一个能够通信的远程连接以上讲述了 MQ 勺基本命令操作，但只知道这些是没有实际意义的。MQ 勺最终目

7、的是实现远程通信，所以下面就以一个具体的例子来说明如何实现远程连接。这个例子的目的是建立可以实现消息传递的一对 MQK 务器，它们分别基于 NT和 UNIX 平台。首先在 NT 端建一队列管理器crtmqm-qQM_NT启动队列管理器一strmqmQM_NT运行 MQ 空制台命令runmqscQM_NT创建死信队列DEFINEQL(NT.DEADQ)DEFPSIST(YES)REPLACE更改队列管理器属性，设置其死信队列ALTERQMGRDEADQT.DEADQ创建进程定义DEFINEPROCESS_NT+APPLTYPEWINDOWSN+APPLICIDCrunmqchl-cSDR_NT-

8、mQM_NT)创建本地传输队列DEFINEQL(QT_NT)USAGE(XMITQ)DEFPSIST(YES)+INITQ(SYSTEM.CHANNEL.INITOPROCESS(P_NT)REPLACE创建远程队列定义，对应于 UNIX 机器上的本地队列 Q_UNIX 传输队列为 QT_NTDEFINEQREMO 烟 R_NT+RNAMEQ_UNIXRQMNAMEQM_UNIX+XMITQ(QT_NT创建发送方疝道，其传输队列为 QT_NT 远程主机地址为 ，侦听端口为 1414DEFINECHANNELSDR_NTCHLTYPE(SDR+CONNAME10.10.10.

9、2(1414)XMITQ(QT_NTREPLACE创建服务器连接通道DEFINECHANNELS_NTCHLTYPE(SVRCONNREPLACE在 UNIX 端创建队列管理器crtmqm-qQM_UNIX启动队列管理器strmqmQM_UNIX添加侦听程序修改/etc/services 文件，加入一行：MQSeries1414/tcp#MQSerieschannellistener修改/etc/inetd.conf 文件，加入一行(启动侦听程序)MQSeriesstreamtcpnowaitmqm/usr/lpp/mqm/bin/amqcrstaamqcrsta-mQM_UNIX运行以下命令

10、，以使修改起作用refresh-sinetd运行 MQ 空制台命令runmqscQM_UNIX创建死信队歹限DEFINEQL(UNIX.DEADQ)DEFPSIST(YES)REPLACE更改队列管理器属性，设置其死信队列ALTERQMGRDEADQNIX.DEADQ创建接收方通道，其名字必须与远程发送方相同DEFINECHANNELSDR_NTCHLTYPE(RCVRREPLACE创建本地队列DEFINEQL(Q_UNIXDEFPSIST(YES)REPLACE创建服务器连接通道DEFINECHANNELS_UNIXCHLTYPE(SVRCONNREPLACE经过以上操作之后，远程连接的配置

11、工作完成。接下来需要验证配置是否正确。在 NT 端启动发送方通道runmqchlcSDR_NTmQM_NTstartchl(SDR_NT)从 NT 端发送消息到 UNIX 端amqsputQR_NTQM_NT在 UNIX 端血攵消息/usr/mqm/samp/bin/amqsgetQ_UNIXQM_UNIX若能收到消息，说明配置成功。另，在 NTT 一般情况下在建立队列管理器时会自动建立侦听器，启动队列管理器时则会自动启动侦听程序。当然也可以手动配置侦听程序。修改winntsystem32driversetcservices 文件，在文件中加入一行：MQSeries1414/tcp#MQSer

12、ieschannellistener启动侦听程序runmqlsr-ttcp-p1414mQM_NT以上说明了怎样建立简单的单向传输网络。消息从 NT 端传送到 UNIX 端。建立从 UNIX 端到 NT 端的远程连接和以上相仿，要建立双向的传输网络也是同样的道理。三.酉己置 JNDI用 JMS 实现消息的发送和接收时，经常会用到 JNDI。因为 JNDI 这种方式比较灵活，对于编程也比较简单。在安装了 MQSeriesClientforJava 之后，在javabin 目录下找到JMSAdmin.config 文件。该文件主要用来说明 Context 的存储方式及存储地址，对应于文件中的两个参

13、数 INITIAL_CONTEXT_FACTORYPROVIDER_UR 哄型的JMSAdmin.config 文件内容如下：#INITIAL_CONTEXT_FACTORY=com.sun.jndi.ldap.LdapCtxFactoryINITIAL_CONTEXT_FACTORY=com.sun.jndi.fscontext.RefFSContextFactory#INITIAL_CONTEXT_FACTORY=com.ibm.ejs.ns.jndi.CNInitialContextFactory#PROVIDER_URL=ldap:polaris/o=ibm,c=usPROVIDER_

14、URL=file:/d:/temp#PROVIDER_URL=iiop:localhost/#SECURITY_AUTHENTICATION=noneINITIAL_CONTEXT_FACTORYvJMSAdmirTool 使用的服务提供商。 当前有三种受支持的值。 com.sun.jndi.ldap.LdapCtxFactory用于LDAP如果使用它就必须安装一个LDAP务器。com.sun.jndi.fscontext.RefFSContextFactory 用于文件系统上下文，它只需要使用者提供存放上下文的文件路径。com.ibm.ejs.ns.jndi.CNInitialContext

15、Factory 是专门为 websphere 提供的，它需要和websphere 的 CosNaming 资源库一起使用。PROVIDER_URL 示会话初始上下文的 URL 由 JMSAdmintool 实现的所有 JNDI 操作的根。它和 INITIAL_CONTEXT_FACTORY寸应。ldap:hostname/contextname 用于 LDAPfile:drive:/pathname 用于文件系统上下文iiop:/hostname:port/?TargetContext=ctx用于访问 websphereCosNamin 尚称空间最后还有一个参数 SECURITY_AUTHEN

16、TICATJON 于说明 JNDI 是否把安全性凭证传递给了您使用的服务供应商。只有当使用了 LDAP 服务供应商时，才使用此参数。此参数有三个值，none（匿名认证）、simple（简单认证）和 CRAM-MD5 认证机制。如果没有提供有效值，缺省值为 none。确认配置文件之后，可以在javabin 目录下启动 JMSAdmirt 空制台。也可以在任何目录下用下面的命令来启动控制台：JMSAdmincfgMQ_JAVA_INSTALL_PATHjavabinJMSAdmin.config 其中MQ_JAVA_INSTALL_PATHMQSeriesClientforJava 安装的根目录。

17、若启动失败，则返好检查一下您的环境变量是否设置正确。根据我个人的经验，除了把com.ibm.mq.jar 和 com.ibm.mqjms.jar 加入到环境变量外，还要把 fscontext.jar 和providerutil.jar 加入到环境变量。进入 JMSAdminf 空制台后，您可以自由定义 subcontext0对于子上下文的操作，主要有一下命令：displayctxdefinectx（ctxname）changectx(ctxname)changectx(=up)changectx(=init)deletectx(ctxname)当然，在这里的主要任务并非是用来定义 subcon

18、text,而是用来定义以下几个对象：MQQueueConnectionFactoryMQTopicConnectionFactoryMQQueueMQTopic(还有其它的一些对象，如 MQXAQueueConnectionFactory 等，不常用到，在此不作说明。)可以使用很多动词来操纵目录名称空间中的受管理对象。ALTERDEFINEDISPLAYDELETECOPYffiMOVE它们的用法都算比较简单，这里只列举一二以作说明。例一：定义一 QueueConnectionFactory,连接主机 8,端口1414DEFINEQCF(EXAMPLEQCF)+DESC(E

19、xampleQueueConnectionFactory)+TRAN(CLIENT)+HOST(8)+QMGR(QM_EXAMPLE)+CHAN(S_EXAMPLE)+PORT(1414)+CCSID(1381)例二：定义一 Queue 其对应于 MCfr 的 Q_EXAMPLEDEFINEQ(EXAMPLEQL)+DESC(Localqueue)+QMGR(QM_EXAMPLE)+QUEUE(Q_EXAMPLE)+CCSID(1381)四.用 JM 对现 MQ程上面我们说明了怎样用 JMSAdminTool 定义 MQ 寸象的上下文。 我们的最终目的是要用JMS 来实现

20、MQ程，以实现在程序中对 MCR 列进行收、发消息。所以，下面我们将重点讨论一下 MQ 勺 JMS 实现。如果您对 JM 例程很熟悉，那么您也就会用 JMS 来实现 MC程，因为用 JMS 来编写MQ序与编写一般的 JMS 程序没有太大的差别。举个例子，当我们想发送一条消息到MQ 勺队列中，再从该队列中取回消息时，我们编程时主要有四个步骤。首先我们要初始化在程序中要用到的对象，然后才可以发送消息到队列中去，再就是收取消息了，最后要消除那些永久对象。这些都和普通的 JMS序相当。程序的源代码如下：importjava.util.Hashtable;importjavax.jms.*;import

21、javax.naming.*;importjavax.naming.directory.*;publicclasssampleprotectedQueueConnectionFactoryfactory=null;protectedQueueConnectionconnection;protectedQueueSessionqueueSession;protectedTextMessageoutMessage;protectedQueueSenderqueueSender;protectedQueueReceiverqueueReceiver;publicstaticfinalStringqc

22、fLookup=EXAMPLEQCF;publicstaticfinalStringqLookup=EXAMPLEQL;publicstaticfinalStringicf=com.sun.jndi.fscontext.RefFSContextFactory;publicStringurl=file:/d:/temp;publicvoidsampleInit()throwsExceptionHashtableenvironment=newHashtable();environment.put(Context.INITIAL_CONTEXT_FACTORY,icf);environment.pu

23、t(Context.PROVIDER_URL,url);environment.put(Context.REFERRAL,throw);Contextctx=newInitialDirContext(environment);factory=(QueueConnectionFactory)ctx.lookup(qcfLookup);Queueq1=null;q1=(Queue)ctx.lookup(qLookup);connection=factory.createQueueConnection();queueSession=connection.createQueueSession(fals

24、e,Session.AUTO_ACKNOWLEDGE);queueSender=queueSession.createSender(q1);queueSender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);outMessage=queueSession.createTextMessage();queueReceiver=queueSession.createReceiver(q1);connection.start();publicvoidsendMessageOut(Stringmessage)throwsJMSExceptionoutMess

25、age.setText(message);queueSender.send(outMessage);publicStringreceiveMessage()throwsExceptionreturn(TextMessage)queueReceiver.receive().getText();)publicvoidsampleClose()throwsJMSExceptionqueueSession.close();connection.close();)publicstaticvoidmain(Stringargs)Stringrec;samplesp=newsample();trysp.sa

26、mpleInit();sp.sendMessageOut(HelloWorld!);java.lang.Thread.sleep(4000);rec=sp.receiveMessage();System.out.println(Receivetextis:+rec);sp.sampleClose();catch(Exceptione)e.printStackTrace();五.远程管理MQftWINDOWS 台下具有图形化管理界面，但在 UNIX 平台下却只能通过命令行来进行操作。这样就给使用者带来很大的不便。我们都希望能通过图形界面来进行管理配置。为了实现我们的想法，我们就必须建立远程管理。实现远程管理有以下几个步骤：1 .被管理队列管理器上的命令队列 SYSTEM.ADMIN.COMMAND.QUEUE 可用。对于MQ2 版本应执行 amqscoma.tst 脚本来创建。2 .使用 strmqcsv 命令来启动被管理队列管理器上的命令服务器。3 .确定被管理队列管理器上的服务器连接通道 SYSTEM.ADMIN.