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
相关推荐
activeMQ DEMO show how to use it
JMS demo 及 资料 jms入门 JMS入门级的蹩脚篇.ppt
Spring对JMS提供了很好的支持,可以通过JmsTemplate来方便地实现消息服务。本例通过activeMQ服务器模拟了消息的发送与接收。需要注意的是,activeMQ的运行依赖jdk的环境,而且对jdk的版本也有要求,我用的是jdk1.6+...
数据传递 ,类似于webservice or jms
该属性值默认为false,这样JMS在进行消息监听的时候就会进行事务控制,当在接收消息时监听器执行失败时JMS就会对接收到的消息进行回滚, 对于SessionAwareMessageListener在接收到消息后发送一个返回消息时也处于...
Jms做的一些的demo,activeMq实现的,在项目的test目录下,这是一个maven项目额。
jms简单demo,activemq集成spring和不集成
JMS即Java消息服务(Java Message Service)应用程序接口,是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。Java消息服务是一个与具体平台无关的...
压缩包里有两个Demo。都是使用weblogic提供的JMS服务,进行消息的发送和接受消费的例子。
NULL 博文链接:https://antlove.iteye.com/blog/1756213
esper和jms做的小demo,模拟温度控制
春天-jms-demo 在制品
import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.JMSException; import javax.jms.MessageConsumer; import javax.jms.Queue; import javax.jms.Session; import javax....
自己写的一个JMS的demo,包含点对点,发布/订阅的例子,以及DeliverMode的测试,还有持久的订阅者,解决topic模式下消息接收者离线后接收不到离线时错过的消息的问题。
基于Spring+JMS+ActiveMQ+Tomcat,我使用的版本情况如下所示:Spring 3.2.0,ActiveMQ 5.4.3,Tomcat 6.0.43。本例通过详细的说明和注释,实现消息服务的基本功能:发送与接收。Spring对JMS提供了很好的支持,可以...
分布式HornetQ持久JTA演示一个具有单个发布者和订阅者的演示JMS实现,每个实现都通过JTA强制JMS操作和相应的JDBC操作之间的事务性。用户注册网站演示发布者网络应用。 通过将用户的个人资料信息保存到数据库来向系统...
SpringMVC+JMS(ActiveMQ)整合的Demo,程序可运行。但不排除有一些小问题,请批评指正。
activemq消息中间件的使用demo,以及spring集合jms实现消息发送和处理。
JMS消息队列机制及众多各种各样的案例,可供学习与参考。