tomcat中使用websphere mq
第一次使用websphere mq,每次要使用IBM的破玩意就觉得蛋疼,可是这H公司的操蛋规定就是只能用商业的MQ,不允许使用ActiveMQ或RabbitMQ。。于是只好硬着头皮研究如何使用,经过一番折腾总算整了出来,中间遇到的几个问题记录一下。
第一部分:
当然还是要把wmq安装好,因为生产环境是Linux环境,所以也只好在Linux环境中安装。装完就一堆命令工具,额~~~
找了些资料应该先建一个Queue Manager
命令crtmqm -q QM1(QM1是Queue Manager的名称)
然后启动这个Queue Manager
strmqm QM1
最后还得启动队列的监听器,有点像启动Oracle的感觉
runmqlsr –t tcp –p 1414 –m QM1 & (注意这个&最好加上,要不然ctrl+C都退不出来。。。)
接下来要在wmq的交互命令行中创建具体的队列,囧~之前用ActiveMQ都是程序自己创建的
runmqsc QM1(如果当前只启动了QM1,后面这个参数是可选的)
然后使用创建队列的命令
define qlocal(Q1) 注意网上说只能建本地Queue,没说为什么,这里照办的。。(Q1是队列名)
接下来以为完了,结果还没完,这破玩意除了需要自己建具体的队列,还需要建channel,这是神马?我现在也还不清楚,不过这破东西很重要,第一次整完全部东西开始连接队列的时候总是报错就是因为这东西建错了,囧。。
刚开始直接找了个创建命令:DEFINE CHANNEL (C1) CHLTYPE(RCVR),结果马上出个莫名其妙的错。
com.ibm.mqservices.MQInternalException: MQJE001:发生 MQException:完成码 2,原因码 2009
MQJE016:连接期间,MQ 队列管理器立即关闭通道
关闭原因 = 2009
上网找了很多都都没找到真正的原因,多数说的是神马最大连接数配置不够导致,我勒个去,就我一个人连能不够。后来是看了一下,CHLTYPE,就是channel的type,其实有好几种,我需要的原来不是RCVR。。这种情况应该建成SVRCONN(叫服务器连接通道- -),后面终于能正常连上了。
说了这么多,总结一句,就是要执行命令:DEFINE CHANNEL(C1) CHLTYPE (SVRCONN) REPLACE
到此为止wmq的折腾就算完成了,接下来是Tomcat。
第二部分:
tomcat其实还好,网上有很多正确的配置
首先是需要JMS,JMX和JTA的api包以及wmq的相关包:
geronimo-j2ee-management_1.0_spec-1.1.1.jar
geronimo-jms_1.1_spec-1.1.1.jar
geronimo-jta_1.1_spec-1.1.1.jar
com.ibm.mq.jar ( /opt/mqm/java/lib/ )
com.ibm.mqjms.jar ( /opt/mqm/java/lib/ )
connector.jar ( /opt/mqm/java/lib/ )
dhbcore.jar ( /opt/mqm/java/lib/ )
接下来是修改context.xml文件,在里面添加
<!--连接工厂定义--><Resource name="jms/queueConnectionFactory" auth="Container"type="com.ibm.mq.jms.MQQueueConnectionFactory"factory="com.ibm.mq.jms.MQQueueConnectionFactoryFactory"HOST="<wmq host ip>"PORT="1414"CHAN="C1"TRAN="1"QMGR="QM1"/><!--队列定义--><Resource name="jms/mailQueue" auth="Container"type="com.ibm.mq.jms.MQQueue"factory="com.ibm.mq.jms.MQQueueFactory"description="JMS Queue for sending messages to app"QU="Q1"/>
<bean id="jmsQueueConnectionFactory"/> <property name="username" value="mqm" /> <property name="password" value="" /> </bean>
<bean id="mailQueue" name="code">instanceof MQQueue