1.安装activeMq
修改service.properites
#jms jms.broker.url=tcp://130.233.1.210:61616?jms.optimizeAcknowledge=true&jms.blobTransferPolicy.defaultUploadUrl=http://130.233.1.210:8161/fileserver/ jms.queue.txnQueue=jifenOrderTxnQueue2?consumer.dispatchAsync=true&consumer.prefetchSize=1 jms.queue.txnReplyQueue=jifenOrderReplyQueue2 jms.revieve.timeout=5000 jms.minListener=1 jms.maxListener=10 jms.username=system jms.password=manager
配置文件里面的IP地址,指定请求队列名和应答队列名
2.测试类定义两个线程,互相把自己的请求队列当做对方的接收队列
com.huateng.jifen.test.Test类;
<?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:aop="http://www.springframework.org/schema/aop" xmlns:cache="http://www.springframework.org/schema/cache" xmlns:context="http://www.springframework.org/schema/context" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:oxm="http://www.springframework.org/schema/oxm" xmlns:p="http://www.springframework.org/schema/p" xmlns:util="http://www.springframework.org/schema/util" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.1.xsd"> <bean id="sendMessageUtils" class="com.jifen.order.common.SendMessageUtil"> <property name="template" ref="jmsTemplate" /> <property name="destination" ref="txnQueue" /> <property name="respDest" ref="txnReplyQueue" /> </bean> <bean id="sendMessageUtils1" class="com.jifen.order.common.SendMessageUtil"> <property name="template" ref="jmsTemplate" /> <property name="destination" ref="txnQueue1" /> <property name="respDest" ref="txnReplyQueue1" /> </bean> <!-- 配置JMS连接工厂 --> <!-- 采用TCP长连接方式, 避免每次建立短连接需要的额外工作时间 --> <bean id="connectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop"> <property name="connectionFactory"> <bean class="org.apache.activemq.spring.ActiveMQConnectionFactory"> <property name="brokerURL"> <value>${jms.broker.url}</value> </property> <property name="useCompression" value="true" /> <property name="useAsyncSend" value="true" /> <property name="userName" value="${jms.username}" /> <property name="password" value="${jms.password}" /> <property name="copyMessageOnSend" value="false" /> <property name="optimizeAcknowledge" value="true" /> <property name="alwaysSessionAsync" value="true" /> </bean> </property> </bean> <!-- 配置JMS模版 --> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory" ref="connectionFactory" /><!-- 建立连接 --> <property name="receiveTimeout" value="${jms.revieve.timeout}" /><!--同步应答超时 --> <property name="deliveryMode" value="1" /> <property name="explicitQosEnabled" value="true" /> </bean> <!-- queue start --> <bean id="txnQueue" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg index="0" value="${jms.queue.txnQueue}" /> </bean> <bean id="txnReplyQueue" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg index="0" value="${jms.queue.txnReplyQueue}" /> </bean> <bean id="txnQueue1" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg index="0" value="${jms.queue.txnReplyQueue}" /> </bean> <bean id="txnReplyQueue1" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg index="0" value="${jms.queue.txnQueue}" /> </bean> <!-- queue end --> </beans>
=======
配置了部分的基于springMVC的demo