spring监听与IBM MQ JMS整合

spring xml 的配置：

文件名：applicationContext-biz-mq.xml

[html] view plain copy print?

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:tx="http://www.springframework.org/schema/tx"
  5. xmlns:jms="http://www.springframework.org/schema/jms"
  6. xmlns:aop="http://www.springframework.org/schema/aop"
  7. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
  8. http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
  9. http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
  10. http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd ">
  11. <description>MQ</description>
  12. <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
  13. <property name="locations">
  14. <list>
  15. <value>classpath:/mqconnect.properties</value>
  16. </list>
  17. </property>
  18. <property name="ignoreUnresolvablePlaceholders" value="true" />
  19. </bean>
  20. <!-- 业务实现类 -->
  21. <bean id="callRecordBiz" class="com.zmcc.servicemanager.biz.impl.CallRecordBizImpl" autowire="byName"/>
  22. <!-- <bean id="mqMessageSend" class="com.zmcc.servicemanager.mq.MQMessageSend">
  23. jie
  24. <property name="queueManagerName" value="${queue.manager.send}" />
  25. <property name="host" value="${queue.manager.host.send}" />
  26. <property name="destinationName" value="${queue.name.send}" />
  27. </bean>
  28. <bean id="mqMessageReceiveListener" class="com.zmcc.servicemanager.mq.MQMessageReceiveListener" init-method="start">
  29. 接收方队列管理器名
  30. <property name="queueManagerName" value="${queue.manager.get}" />
  31. <property name="host" value="${queue.manager.host.get}" />
  32. <property name="destinationName" value="${queue.name.get}" />
  33. </bean> -->
  34. <!-- WebSphere MQ Connection Factory -->
  35. <bean id="mqConnectionFactory" class="com.ibm.mq.jms.MQConnectionFactory">
  36. <property name="hostName" value="${queue.manager.host.get}"/>
  37. <property name="queueManager" value="${queue.manager.get}"/>
  38. <property name="channel" value="${app.mq.channel}"/>
  39. <property name="port" value="${app.mq.port}"/>
  40. <property name="transportType" value="${app.mq.transportType}"/>
  41. </bean>
  42. <!-- JMS Queue Connection Factory -->
  43. <bean id="transactionManager" class="org.springframework.jms.connection.JmsTransactionManager">
  44. <property name="connectionFactory" ref="mqConnectionFactory"/>
  45. </bean>
  46. <!-- JMS Destination Resolver -->
  47. <!-- <bean id="jmsDestinationResolver" class="org.springframework.jms.support.destination.DynamicDestinationResolver" /> -->
  48. <bean id="messageConverter" class="com.zmcc.servicemanager.mq.spring.MessageConverter" />
  49. <!-- 定义接收者 -->
  50. <bean  id="messageListener" class="com.zmcc.servicemanager.mq.spring.MessageListener" >
  51. <property name="callRecordBiz" ref="callRecordBiz" />
  52. </bean>
  53. <!-- JMS  listener -->
  54. <!-- <bean id="messageListenerAdapter" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
  55. <property name="defaultListenerMethod" value="receviedMessage"/>
  56. <property name="messageConverter" ref="messageConverter"/>
  57. <property name="delegate" ref="messageListener"/>
  58. </bean> -->
  59. <!--
  60. JMS listener
  61. listener:org.springframework.jms.listener.adapter.MessageListenerAdapter
  62. message-converter="messageConverter",
  63. -->
  64. <jms:listener-container connection-factory="mqConnectionFactory" transaction-manager="transactionManager"
  65. message-converter="messageConverter">
  66. <jms:listener destination="${queue.name.get}" ref="messageListener" method="receviedMessage" />
  67. </jms:listener-container>
  68. </beans>

mqconnect.properties配置文件：

[html] view plain copy print?

  1. #通道名
  2. app.mq.channel=SYSTEM.DEF.SVRCONN
  3. #传输类型
  4. app.mq.transportType=1
  5. #端口号
  6. app.mq.port=1414
  7. #队列管理器名称-发送方
  8. queue.manager.send=WMQ1QM
  9. #主机地址-发送方
  10. queue.manager.host.send=10.70.175.81
  11. #队列名称-发送方
  12. queue.name.send=WMQ1OutputQ
  13. #队列管理器名称--接收方
  14. queue.manager.get=WMQ2QM
  15. #主机地址--接收方
  16. queue.manager.host.get=10.70.175.82
  17. #队列名称--接收方
  18. queue.name.get=WMQ2InputQ

MessageTest.Java测试文件，用来启动接收监听的配置文件：

[java] view plain copy print?

  1. import org.springframework.context.support.ClassPathXmlApplicationContext;
  2. public class MessageTest {
  3. /**
  4. * @param args
  5. */
  6. public static void main(String[] args) {
  7. new ClassPathXmlApplicationContext("classpath*:/applicationContext-biz-mq.xml");
  8. }
  9. }

MessageListener.java监听文件：

[java] view plain copy print?

  1. import com.zmcc.servicemanager.biz.CallRecordBiz;
  2. import com.zmcc.servicemanager.domain.CallRecord;
  3. /**
  4. * 消息监听器
  5. * @author ZouXia
  6. *
  7. */
  8. public class MessageListener{
  9. private CallRecordBiz callRecordBiz;
  10. /**
  11. * 接收消息
  12. * @param callRecord
  13. */
  14. public void receviedMessage(CallRecord callRecord) {
  15. System.out.println(callRecord.getRequestContent());
  16. //      callRecordBiz.saveEntity(callRecord);
  17. }
  18. public CallRecordBiz getCallRecordBiz() {
  19. return callRecordBiz;
  20. }
  21. public void setCallRecordBiz(CallRecordBiz callRecordBiz) {
  22. this.callRecordBiz = callRecordBiz;
  23. }
  24. }

MessageConverter.java用来转换的类：

[java] view plain copy print?

  1. import javax.jms.JMSException;
  2. import javax.jms.Message;
  3. import javax.jms.Session;
  4. import javax.jms.TextMessage;
  5. import org.springframework.jms.support.converter.MessageConversionException;
  6. import com.zmcc.servicemanager.domain.CallRecord;
  7. /**
  8. * 消息转换器
  9. * @author ZouXia
  10. *
  11. */
  12. public class MessageConverter implements org.springframework.jms.support.converter.MessageConverter {
  13. /**
  14. * 发送消息的转换
  15. */
  16. public Message toMessage(Object object, Session session) throws JMSException, MessageConversionException {
  17. return null;
  18. }
  19. /**
  20. * 接收消息的转换
  21. */
  22. public Object fromMessage(Message message) throws JMSException,MessageConversionException {
  23. // TODO
  24. TextMessage mapMessage = (TextMessage) message;
  25. CallRecord callRecord = new CallRecord();
  26. callRecord.setEndTime(new Date());
  27. callRecord.setRequestContent(mapMessage.getText());
  28. return callRecord;
  29. }
  30. }

CallRecord.java实体类

[java] view plain copy print?

  1. public class CallRecord implements Serializable{
  2. private static final long serialVersionUID = 1L;
  3. private String requestContent;
  4. private Date endTime;
  5. ……
  6. }

JmsProducer.java发送消息：

[java] view plain copy print?

  1. import javax.jms.Connection;
  2. import javax.jms.Destination;
  3. import javax.jms.JMSException;
  4. import javax.jms.MessageProducer;
  5. import javax.jms.Session;
  6. import javax.jms.TextMessage;
  7. import com.ibm.mq.jms.JMSC;
  8. import com.ibm.mq.jms.MQQueueConnectionFactory;
  9. /**
  10. * 点对点模式
  11. * @author ZouXia
  12. *
  13. */
  14. public class JmsProducer {
  15. /**
  16. * Main method
  17. *
  18. * @param args
  19. */
  20. public static void main(String[] args) {
  21. // Variables
  22. Connection connection = null;
  23. Session session = null;
  24. Destination destination = null;
  25. MessageProducer producer = null;
  26. try {
  27. // Create a connection factory
  28. // objects
  29. MQQueueConnectionFactory factory = new MQQueueConnectionFactory();
  30. factory.setQueueManager("WMQ1QM");
  31. factory.setHostName("10.70.175.81");
  32. factory.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);
  33. factory.setPort(1414);
  34. factory.setChannel("SYSTEM.DEF.SVRCONN");
  35. // Create JMS objects
  36. connection = factory.createConnection();
  37. session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  38. destination = session.createQueue("WMQ1OutputQ");
  39. producer = session.createProducer(destination);
  40. long uniqueNumber = System.currentTimeMillis() % 1000;
  41. TextMessage message = session
  42. .createTextMessage("JmsProducer: Your lucky number today is " + uniqueNumber);
  43. // Start the connection
  44. connection.start();
  45. // And, send the message
  46. producer.send(message);
  47. System.out.println("Sent message:\n" + message);
  48. } catch (JMSException jmsex) {
  49. jmsex.fillInStackTrace();
  50. } finally {
  51. try {
  52. producer.close();
  53. session.close();
  54. connection.close();
  55. } catch (JMSException e) {
  56. e.printStackTrace();
  57. }
  58. }
  59. }
  60. }

所对应的发送方WMQ1QM的资源管理器：

所对应的通道：

接收方WMQ2QM的队列：

通道：

资源管理器即IBM MQ explorer是基于eclipse的进行的，在eclipse里面添加plug插件即可，其更新地址为：

http://public.dhe.ibm.com/software/integration/wmq/explorer/v75/updates/

如果出现以下问题：

[java] view plain copy print?

  1. Exception in thread "main" java.lang.NoClassDefFoundError: javax/resource/ResourceException
  2. at com.ibm.mq.MQEnvironment.<clinit>(MQEnvironment.java:490)
  3. at com.ibm.mq.jms.services.ConfigEnvironment.<clinit>(ConfigEnvironment.java:190)
  4. at java.lang.Class.forName0(Native Method)
  5. at java.lang.Class.forName(Class.java:247)
  6. at com.ibm.mq.jms.MQConnectionFactory$1.run(MQConnectionFactory.java:658)
  7. at java.security.AccessController.doPrivileged(Native Method)
  8. at com.ibm.mq.jms.MQConnectionFactory.<clinit>(MQConnectionFactory.java:651)
  9. at com.zmcc.servicemanager.mq.jms.JmsProducer.main(JmsProducer.java:36)
  10. Caused by: java.lang.ClassNotFoundException: javax.resource.ResourceException
  11. at java.net.URLClassLoader$1.run(URLClassLoader.java:200)
  12. at java.security.AccessController.doPrivileged(Native Method)
  13. at java.net.URLClassLoader.findClass(URLClassLoader.java:188)
  14. at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
  15. at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
  16. at java.lang.ClassLoader.loadClass(ClassLoader.java:252)
  17. at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:320)
  18. ... 8 more

pom.xml里面要引入connector.jar

[html] view plain copy print?

  1. <dependency>
  2. <groupId>javax.resource</groupId>
  3. <artifactId>connector</artifactId>
  4. <version>1.0</version>
  5. </dependency>
时间： 2024-10-07 05:02:39

spring监听与IBM MQ JMS整合的相关文章

spring中配置监听队列的MQ

一.spring中配置监听队列的MQ相关信息注:${}是读取propertites文件的常量,这里忽略.绿色部分配置在接收和发送端都要配置. <bean id="axx" class="com.ibm.mq.jms.MQQueueConnectionFactory"> <property name="hostName" value="${}" />  <property name="po

Spring 监听

Spring 中的事件监听的实现 这里我们不讨论事件监听的机制的原理,我们只讨论如何在项目中实现时间监听. spring的事件监听是基于观察者模式.设计开发中.如下类与接口是我们必须要使用的. ApplicationContext 首先我们了解一下ApplicationContext,还记得 ApplicationContext ac=new ClassPathXmlApplicationContext("beans.xml"); 1 1 ApplicationContext相当于Sp

Spring 监听session 失效方法

public class SessionCounter implements HttpSessionListener { private static int activeSessions =0;   /* Session创建事件 */   public void sessionCreated(HttpSessionEvent event) { //创建session }   /* Session失效事件 */   public void  sessionDestroyed(HttpSessio

Spring监听，ApplicationListener

import java.util.HashMap; import java.util.Map; import org.apache.commons.lang3.StringUtils; import org.apache.log4j.Logger; importorg.springframework.beans.factory.annotation.Autowired; importorg.springframework.beans.factory.annotation.Qualifier; i

IBM Mq Spring JMS 的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:p="http://www.springframework.org/schema/

Spring架构揭秘－事件监听机制

一.事件监听机制概述 二.事件监听机制结构 三.Spring监听机制架构 Spring的Application拥有发布事件并且注册事件监听器的能力,拥有一套完整的事件发布和监听机制.在Java中,通过java.util. EventObject来描述事件,通过java.util. EventListener来描述事件监听器,在众多的框架和组件中,建立一套事件机制通常是基于这两个接口来进行扩展. 在一个事件体系中,有以下几个重要的概念. 1.事件源:事件对象的产生者,任何一个EventObject

IBM MQ 集成CXF 发送JMS 消息

1.修改wsdl 协议类型为 jms 替换 <soap:binding style="document" transport="http://schemas.xmlsoap.org/soap/http"/> 为 <soap:binding style="document" transport="http://cxf.apache.org/transports/jms"/> 2.根据wsdl生成服务端代码

Spring整合ActiveMQ及多个Queue消息监听的配置

消息队列(MQ)越来越火,在java开发的项目也属于比较常见的技术,MQ的相关使用也成java开发人员必备的技能.笔者公司采用的MQ是ActiveMQ,且消息都是用的点对点的模式.本文记录了实现Spring整合ActivateMQ的全过程及如何使用MQ,便于后续查阅. 一.项目的搭建 采用maven构建项目,免去了copy jar包的麻烦.因此,我们创建了一个java类型的Maven Project (1)项目结构图 先把项目结构图看一下,便于对项目的理解. (2)pom.xml 我们需要加入以

04.ActiveMQ与Spring JMS整合

SpringJMS使用参考:http://docs.spring.io/spring/docs/current/spring-framework-reference/html/jms.html 1.SpringJMS核心接口介绍 1.JmsTemplate JmsTemplate: 是Spring自身提供,只需向Spring容器内注册这个类即可,就可以使用JmsTemplate类对象方便的操作JMS,下面介绍他常用的方法. 注意:JmsTemplate类是线程安全的,可以在整个应用范围使用.但并