spring监听与IBM MQ JMS整合

spring xml 的配置：

 文件名：applicationContext-biz-mq.xml

[html]  view plain copy print? <?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配置文件：

[html]  view plain copy print? #通道名  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测试文件，用来启动接收监听的配置文件：

[java]  view plain copy print? 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监听文件：

[java]  view plain copy print? 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用来转换的类：

[java]  view plain copy print? 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实体类

[java]  view plain copy print? public class CallRecord implements Serializable{           private static final long serialVersionUID = 1L;     private String requestContent;     private Date endTime;    ……         }  

JmsProducer.java发送消息：

[java]  view plain copy print? 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/

 

如果出现以下问题： [java]  view plain copy print? 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 [html]  view plain copy print? <dependency>              <groupId>javax.resource</groupId>              <artifactId>connector</artifactId>              <version>1.0</version>          </dependency>  

转载于:https://www.cnblogs.com/yanduanduan/p/7156447.html

相关资源：JAVA上百实例源码以及开源项目