spring监听与IBM MQ JMS整合
2014-02-20 16:06
796 查看
IBM MQ刚接触,今天就SPRING整合写了个DEMO,借助于《SPRING攻略》
spring xml 的配置:
文件名:applicationContext-biz-mq.xml
mqconnect.properties配置文件:
MessageTest.java测试文件,用来启动接收监听的配置文件:
MessageListener.java监听文件:
MessageConverter.java用来转换的类:
CallRecord.java实体类
JmsProducer.java发送消息:
所对应的发送方WMQ1QM的资源管理器:
所对应的通道:
接收方WMQ2QM的队列:
通道:
资源管理器即IBM MQ explorer是基于eclipse的进行的,在eclipse里面添加plug插件即可,其更新地址为:
http://public.dhe.ibm.com/software/integration/wmq/explorer/v75/updates/
如果出现以下问题:
pom.xml里面要引入connector.jar
IBM MQ刚接触,今天就SPRING整合写了个DEMO,借助于《SPRING攻略》
spring xml 的配置:
文件名:applicationContext-biz-mq.xml
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:jms="http://www.springframework.org/schema/jms" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd "> <description>MQ</description> <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations"> <list> <value>classpath:/mqconnect.properties</value> </list> </property> <property name="ignoreUnresolvablePlaceholders" value="true" /> </bean> <!-- 业务实现类 --> <bean id="callRecordBiz" class="com.zmcc.servicemanager.biz.impl.CallRecordBizImpl" autowire="byName"/> <!-- <bean id="mqMessageSend" class="com.zmcc.servicemanager.mq.MQMessageSend"> jie <property name="queueManagerName" value="${queue.manager.send}" /> <property name="host" value="${queue.manager.host.send}" /> <property name="destinationName" value="${queue.name.send}" /> </bean> <bean id="mqMessageReceiveListener" class="com.zmcc.servicemanager.mq.MQMessageReceiveListener" init-method="start"> 接收方队列管理器名 <property name="queueManagerName" value="${queue.manager.get}" /> <property name="host" value="${queue.manager.host.get}" /> <property name="destinationName" value="${queue.name.get}" /> </bean> --> <!-- WebSphere MQ Connection Factory --> <bean id="mqConnectionFactory" class="com.ibm.mq.jms.MQConnectionFactory"> <property name="hostName" value="${queue.manager.host.get}"/> <property name="queueManager" value="${queue.manager.get}"/> <property name="channel" value="${app.mq.channel}"/> <property name="port" value="${app.mq.port}"/> <property name="transportType" value="${app.mq.transportType}"/> </bean> <!-- JMS Queue Connection Factory --> <bean id="transactionManager" class="org.springframework.jms.connection.JmsTransactionManager"> <property name="connectionFactory" ref="mqConnectionFactory"/> </bean> <!-- JMS Destination Resolver --> <!-- <bean id="jmsDestinationResolver" class="org.springframework.jms.support.destination.DynamicDestinationResolver" /> --> <bean id="messageConverter" class="com.zmcc.servicemanager.mq.spring.MessageConverter" /> <!-- 定义接收者 --> <bean id="messageListener" class="com.zmcc.servicemanager.mq.spring.MessageListener" > <property name="callRecordBiz" ref="callRecordBiz" /> </bean> <!-- JMS listener --> <!-- <bean id="messageListenerAdapter" class="org.springframework.jms.listener.adapter.MessageListenerAdapter"> <property name="defaultListenerMethod" value="receviedMessage"/> <property name="messageConverter" ref="messageConverter"/> <property name="delegate" ref="messageListener"/> </bean> --> <!-- JMS listener listener:org.springframework.jms.listener.adapter.MessageListenerAdapter message-converter="messageConverter", --> <jms:listener-container connection-factory="mqConnectionFactory" transaction-manager="transactionManager" message-converter="messageConverter"> <jms:listener destination="${queue.name.get}" ref="messageListener" method="receviedMessage" /> </jms:listener-container> </beans>
mqconnect.properties配置文件:
#通道名 app.mq.channel=SYSTEM.DEF.SVRCONN #传输类型 app.mq.transportType=1 #端口号 app.mq.port=1414 #队列管理器名称-发送方 queue.manager.send=WMQ1QM #主机地址-发送方 queue.manager.host.send=10.70.175.81 #队列名称-发送方 queue.name.send=WMQ1OutputQ #队列管理器名称--接收方 queue.manager.get=WMQ2QM #主机地址--接收方 queue.manager.host.get=10.70.175.82 #队列名称--接收方 queue.name.get=WMQ2InputQ
MessageTest.java测试文件,用来启动接收监听的配置文件:
import org.springframework.context.support.ClassPathXmlApplicationContext; public class MessageTest { /** * @param args */ public static void main(String[] args) { new ClassPathXmlApplicationContext("classpath*:/applicationContext-biz-mq.xml"); } }
MessageListener.java监听文件:
import com.zmcc.servicemanager.biz.CallRecordBiz; import com.zmcc.servicemanager.domain.CallRecord; /** * 消息监听器 * @author ZouXia * */ public class MessageListener{ private CallRecordBiz callRecordBiz; /** * 接收消息 * @param callRecord */ public void receviedMessage(CallRecord callRecord) { System.out.println(callRecord.getRequestContent()); // callRecordBiz.saveEntity(callRecord); } public CallRecordBiz getCallRecordBiz() { return callRecordBiz; } public void setCallRecordBiz(CallRecordBiz callRecordBiz) { this.callRecordBiz = callRecordBiz; } }
MessageConverter.java用来转换的类:
import javax.jms.JMSException; import javax.jms.Message; import javax.jms.Session; import javax.jms.TextMessage; import org.springframework.jms.support.converter.MessageConversionException; import com.zmcc.servicemanager.domain.CallRecord; /** * 消息转换器 * @author ZouXia * */ public class MessageConverter implements org.springframework.jms.support.converter.MessageConverter { /** * 发送消息的转换 */ public Message toMessage(Object object, Session session) throws JMSException, MessageConversionException { return null; } /** * 接收消息的转换 */ public Object fromMessage(Message message) throws JMSException,MessageConversionException { // TODO TextMessage mapMessage = (TextMessage) message; CallRecord callRecord = new CallRecord(); callRecord.setEndTime(new Date()); callRecord.setRequestContent(mapMessage.getText()); return callRecord; } }
CallRecord.java实体类
public class CallRecord implements Serializable{ private static final long serialVersionUID = 1L; private String requestContent; private Date endTime; …… }
JmsProducer.java发送消息:
import javax.jms.Connection; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; import com.ibm.mq.jms.JMSC; import com.ibm.mq.jms.MQQueueConnectionFactory; /** * 点对点模式 * @author ZouXia * */ public class JmsProducer { /** * Main method * * @param args */ public static void main(String[] args) { // Variables Connection connection = null; Session session = null; Destination destination = null; MessageProducer producer = null; try { // Create a connection factory // objects MQQueueConnectionFactory factory = new MQQueueConnectionFactory(); factory.setQueueManager("WMQ1QM"); factory.setHostName("10.70.175.81"); factory.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP); factory.setPort(1414); factory.setChannel("SYSTEM.DEF.SVRCONN"); // Create JMS objects connection = factory.createConnection(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); destination = session.createQueue("WMQ1OutputQ"); producer = session.createProducer(destination); long uniqueNumber = System.currentTimeMillis() % 1000; TextMessage message = session .createTextMessage("JmsProducer: Your lucky number today is " + uniqueNumber); // Start the connection connection.start(); // And, send the message producer.send(message); System.out.println("Sent message:\n" + message); } catch (JMSException jmsex) { jmsex.fillInStackTrace(); } finally { try { producer.close(); session.close(); connection.close(); } catch (JMSException e) { e.printStackTrace(); } } } }
所对应的发送方WMQ1QM的资源管理器:
所对应的通道:
接收方WMQ2QM的队列:
通道:
资源管理器即IBM MQ explorer是基于eclipse的进行的,在eclipse里面添加plug插件即可,其更新地址为:
http://public.dhe.ibm.com/software/integration/wmq/explorer/v75/updates/
如果出现以下问题:
Exception in thread "main" java.lang.NoClassDefFoundError: javax/resource/ResourceException at com.ibm.mq.MQEnvironment.<clinit>(MQEnvironment.java:490) at com.ibm.mq.jms.services.ConfigEnvironment.<clinit>(ConfigEnvironment.java:190) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:247) at com.ibm.mq.jms.MQConnectionFactory$1.run(MQConnectionFactory.java:658) at java.security.AccessController.doPrivileged(Native Method) at com.ibm.mq.jms.MQConnectionFactory.<clinit>(MQConnectionFactory.java:651) at com.zmcc.servicemanager.mq.jms.JmsProducer.main(JmsProducer.java:36) Caused by: java.lang.ClassNotFoundException: javax.resource.ResourceException at java.net.URLClassLoader$1.run(URLClassLoader.java:200) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:188) at java.lang.ClassLoader.loadClass(ClassLoader.java:307) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) at java.lang.ClassLoader.loadClass(ClassLoader.java:252) at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:320) ... 8 more
pom.xml里面要引入connector.jar
<dependency> <groupId>javax.resource</groupId> <artifactId>connector</artifactId> <version>1.0</version> </dependency>
相关文章推荐
- spring监听与IBM MQ JMS整合
- Spring JMS ActiveMQ整合(转)
- Spring整合ActiveMQ:spring+JMS+ActiveMQ+Tomcat
- IBM Mq Spring JMS 的xml配置
- IBM MQ + WebSphere + Spring JMS配置方法
- JMS进阶篇--使用JMS规范连接MQ以及spring整合JMS
- Spring ActiveMQ整合+注解消息监听
- spring整合JMS之异步消息监听机制
- Spring ActiveMQ整合+注解消息监听
- 学习activemq(2)Spring boot整合activemq jms
- Spring ActiveMQ 整合: JMS 事务管理
- spring整合JMS(一)
- spring activeMQ 整合(一): 一个简单的demo,测试消息的发送与接收
- jms activeMQ与spring集成进阶篇
- Spring整合JMS(二)——三种消息监听器(转)
- JMS(三)--Spring和ActiveMQ整合的完整实例
- Spring整合Jms学习(一)_基于ActiveMQ实现
- JMeter学习(二十九)使用Jmeter创建ActiveMQ JMS POINT TO POINT请求,环境搭建、请求创建、插件安装、监听服务器资源等
- Spring + ActiveMQ实现jms发送消息
- 【JMS 4】spring 整合activemq