JMS如何调用webshere MQ中间件收发消息

Question

问题描述：

有个应用原先是用ibm MQ插件包调用websphere MQ消息并发消息。最近需要进行转移，改用原生的JMS调用，小弟初学，不知道如何通过JMS配置项对应的队列管理器，通道和队列。是否用JMS调用，websphere MQ必须和应用部署在同一台服务器上呢？

这里高手如云，希望大侠们指点迷津。小弟万分感谢

 

Answer 1

这个你用到了spring框架吧，不过还是谢谢你了。

Answer 2

这个网上很多的，用jms发mq消息比ibm MQ插件包调用的时候 ，可以在网络断开的情况下自动重连。

先配置一个connectionFactory:

<bean id="jmsConnectionFactory1" class="com.ibm.mq.jms.MQQueueConnectionFactory">
		<property name="hostName" value="${jms.mq.server}" />
		<property name="port" value="${jms.mq.port}" />
		<property name="CCSID" value="${jms.mq.ccsid}" />
		<property name="queueManager" value="${jms.mq.queueManager}" />
	</bean>
	 
	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory" ref="jmsConnectionFactory1" />
		<property name="pubSubDomain" value="false" />
	</bean>

<bean id="messageService"
 class="XX.service.impl.MessageServiceImpl">
 <property name="jmsTemplate" ref="jmsTemplate" />
 <property name="destinationName" value="${jms.queue.announce}" />
 </bean>       

MessageServiceImpl里写发送jms消息的代码                              

jmsTemplate.send(destinationName, new MessageCreator() {
			public Message createMessage(Session session) throws JMSException {
				Message message = null;
				message = session.createTextMessage(xml);
				return message;
			}
		});

websphere MQ必须和应用部署在同一台服务器上呢？

这个问题问的，没有理由....答案是肯定不需要，但是可以在一台服务器上。