- 浏览: 691649 次
- 性别:
- 来自: 北京
博客专栏
-
读金庸故事,品程序人生
浏览量:47234
文章分类
最新评论
-
hty881008:
LZ,你的json返回是怎么出来的,我的怎么是No messa ...
使用CXF暴露您的REST服务 -
jxFY:
赞
Apache的对象池化工具commons-pool -
wangyudong:
新版本的Wisdom RESTClient地址https:// ...
使用CXF暴露您的REST服务 -
wangyudong:
由CXF实现的微服务需要有比较好的工具去测试RESTful A ...
使用CXF暴露您的REST服务 -
spring_springdata:
可以参考最新的文档:如何在eclipse jee中检出项目并转 ...
Maven3实战笔记01环境配置与使用入门
1. 集成环境
Spring采用2.5.6版本,ActiveMQ使用的是5.4.2,从apache站点可以下载。本文是将Spring集成ActiveMQ来发送和接收JMS消息。
2. 集成步骤
将下载的ActiveMQ解压缩后文件夹如下
activemq-all-5.4.2.jar是activemq的所有的类jar包。lib下面是模块分解后的jar包。将lib下面的
/lib/activation-1.1.jar /lib/activemq-camel-5.4.2.jar /lib/activemq-console-5.4.2.jar /lib/activemq-core-5.4.2.jar /lib/activemq-jaas-5.4.2.jar /lib/activemq-pool-5.4.2.jar /lib/activemq-protobuf-1.1.jar /lib/activemq-spring-5.4.2.jar /lib/activemq-web-5.4.2.jar
文件全部拷贝到项目中。
而Spring项目所需要的jar包如下
/lib/spring-beans-2.5.6.jar /lib/spring-context-2.5.6.jar /lib/spring-context-support-2.5.6.jar /lib/spring-core-2.5.6.jar /lib/spring-jms-2.5.6.jar /lib/spring-tx.jar
当然还需要一些其他的jar文件
/lib/geronimo-j2ee-management_1.1_spec-1.0.1.jar /lib/jms-1.1.jar /lib/log4j-1.2.15.jar /lib/slf4j-api-1.6.1.jar /lib/slf4j-nop-1.6.1.jar
项目的依赖jar都准备好后就可以写配置文件了。
Spring配置文件
配置文件内容如下
<?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:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd" default-autowire="byName"> <!-- 配置connectionFactory --> <bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop"> <property name="connectionFactory"> <bean class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL"> <value>tcp://127.0.0.1:61616</value> </property> </bean> </property> <property name="maxConnections" value="100"></property> </bean> <!-- Spring JMS Template --> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory"> <ref local="jmsFactory" /> </property> <property name="defaultDestinationName" value="subject" /> <!-- 区别它采用的模式为false是p2p为true是订阅 --> <property name="pubSubDomain" value="true" /> </bean> <!-- 发送消息的目的地(一个队列) --> <bean id="destination" class="org.apache.activemq.command.ActiveMQTopic"> <!-- 设置消息队列的名字 --> <constructor-arg index="0" value="subject" /> </bean> <!-- 消息监听 --> <bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="concurrentConsumers" value="10" /> <property name="connectionFactory" ref="jmsFactory" /> <property name="destinationName" value="subject" /> <property name="messageListener" ref="messageReceiver" /> <property name="pubSubNoLocal" value="false"></property> </bean> <bean id="messageReceiver" class="com.liuyan.jms.consumer.ProxyJMSConsumer"> <property name="jmsTemplate" ref="jmsTemplate"></property> </bean> </beans>
编写代码
消息发送者:这里面消息生产者并没有在Spring配置文件中进行配置,这里仅仅使用了Spring中的JMS模板和消息目的而已。
public class HelloSender { /** * @param args */ public static void main(String[] args) { ApplicationContext applicationContext = new ClassPathXmlApplicationContext( new String[] { "classpath:/spring/applicationContext-jms.xml" }); JmsTemplate template = (JmsTemplate) applicationContext .getBean("jmsTemplate"); Destination destination = (Destination) applicationContext .getBean("destination"); template.send(destination, new MessageCreator() { public Message createMessage(Session session) throws JMSException { return session .createTextMessage("发送消息:Hello ActiveMQ Text Message!"); } }); System.out.println("成功发送了一条JMS消息"); } }
消息接收
/** * JMS消费者 * * * <p> * 消息题的内容定义 * <p> * 消息对象 接收消息对象后: 接收到的消息体* <p> */ public class ProxyJMSConsumer { public ProxyJMSConsumer() { } private JmsTemplate jmsTemplate; public JmsTemplate getJmsTemplate() { return jmsTemplate; } public void setJmsTemplate(JmsTemplate jmsTemplate) { this.jmsTemplate = jmsTemplate; } /** * 监听到消息目的有消息后自动调用onMessage(Message message)方法 */ public void recive() { ApplicationContext applicationContext = new ClassPathXmlApplicationContext( new String[] { "classpath:/spring/applicationContext-jms.xml" }); Destination destination = (Destination) applicationContext .getBean("destination"); while (true) { try { TextMessage txtmsg = (TextMessage) jmsTemplate .receive(destination); if (null != txtmsg) { System.out.println("[DB Proxy] " + txtmsg); System.out.println("[DB Proxy] 收到消息内容为: " + txtmsg.getText()); } else break; } catch (Exception e) { e.printStackTrace(); } } } }
这里边也是并不是直接使用Spring来初始化建立消息消费者实例,而是在此消费者注入了JMS模板而已。
写一个main入口,初始化消息消费者
public class JMSTest { /** * @param args */ public static void main(String[] args) { ApplicationContext applicationContext = new ClassPathXmlApplicationContext( new String[] { "classpath:/spring/applicationContext-jms.xml" }); ProxyJMSConsumer proxyJMSConsumer = (ProxyJMSConsumer) applicationContext .getBean("messageReceiver"); System.out.println("初始化消息消费者"); } }
使用的时候先开启ActiveMQ服务,默认是占用了61616端口。之后开启测试程序,开启2个消息消费者监听。之后再运行消息生产者的代码后,消息就可以被消息消费者接收到了。
评论
5 楼
luoww1
2013-10-15
自己弄不出来,能给个项目吗?谢谢
4 楼
ray258
2012-09-28
没弄明白呐
3 楼
csbliss
2012-09-21
“之后开启测试程序,开启2个消息消费者监听。之后再运行消息生产者的代码后”,请问这个怎么开启? 我建立的web应用
2 楼
xuehanxin
2011-08-22
有项目吗?lovelyxuehanxin@163.com发给到我邮箱,谢谢
1 楼
xuehanxin
2011-08-22
很好,很NB
发表评论
-
JavaEE5实战笔记05RedHat搭建JBoss、Oracle10g环境
2011-06-01 10:50 1517JavaEE5实战笔记在RedHat上搭建JBoss、Orac ... -
JavaEE5实战笔记02JPA持久层的一些问题
2011-05-30 14:48 15581. JPA关联实体的级联操作问题 在此次联系中 ... -
JavaEE5实战笔记01EJB环境搭建及异常解决
2011-05-30 14:43 49401. 说明 此实战笔记是为了之前的学习笔记做一个 ... -
JAVA的Mina框架传递对象——一劳永逸(转载)
2011-03-09 11:31 2612接触java的Mina框架已经有很多时间了,在网上也读过了很多 ... -
JavaEE5学习笔记12-JSF验证器使用总结
2011-03-09 00:01 19331. JSF验证器 说完转换器就该说说验证器了, ... -
JavaEE5学习笔记11-JSF转换器使用总结
2011-03-08 23:53 26741. JSF的转换器是在JSF生命周期的第2个阶段 ... -
JSF组件生命周期的讨论
2011-03-08 23:38 16941. JSF生命周期 下面我们来看看JSF组件的 ... -
JavaEE5学习笔记10-JSF基本UI控件使用
2011-03-08 23:34 35991. JSF也是JavaEE5的标准,感觉上sun ... -
JavaEE5学习笔记09-将EJB发布成WebService总结(2)
2011-02-28 09:21 1520以上例子只是简单调用了WebService,参数是简单的Str ... -
JavaEE5学习笔记09-将EJB发布成WebService总结(1)
2011-02-28 09:19 40721. 将EJB发布成,或者说暴露成Web服务(也许 ... -
JavaEE5学习笔记08-JPA与EJB集成总结(4)
2011-02-24 09:36 14621. 在JavaEE容器 ... -
JavaEE5学习笔记08-JPA与EJB集成总结(3)
2011-02-24 09:35 11651. 测试代码 部署成功后,在另一个项目中建立测 ... -
JavaEE5学习笔记08-JPA与EJB集成总结(2)
2011-02-24 09:33 1483下面来看针对此实体操作的sessionBean代码。 接口 ... -
JavaEE5学习笔记08-JPA与EJB集成总结(1)
2011-02-24 09:28 1718JPA是JavaEE5提出的一套标准接口,不同的应用服务器对其 ... -
JavaEE5学习笔记06-EJB之消息驱动Bean(MDB)总结----2
2011-02-21 15:56 1381除了activationConfig之外,如果使用其他Java ... -
JavaEE5学习笔记06-EJB之消息驱动Bean(MDB)总结----1
2011-02-21 15:55 19251. 功能介绍 在EJB的分类中还有一个就是消息驱 ... -
JavaEE5学习笔记05-EJB之会话Bean(sessionBean)总结-----7
2011-02-21 09:49 12931. EJB的容器式依 ... -
JavaEE5学习笔记05-EJB之会话Bean(sessionBean)总结-----6
2011-02-21 09:48 1462BMT就是Bean自己管理事务,这种方式就是以硬编码的方式在B ... -
JavaEE5学习笔记05-EJB之会话Bean(sessionBean)总结-----5
2011-02-21 09:46 18551. 有状态的会话Bean的本地、远程调用 其实这 ... -
JavaEE5学习笔记05-EJB之会话Bean(sessionBean)总结-----4
2011-02-21 09:43 1283以上好像还看不出什么,那么咱们开发一个web程序作为测试用例 ...
相关推荐
Spring集成ActiveMQ配置
spring集成ActiveMQ的配置过程
spring集成activeMQ框架 配置方式(内含三种常见的消息接受监听方式的配置)JMS 配置测试等等
ActiveMQ spring 配置方案详解。
ActiveMQ通过与Spring集成后,消息队列,消息监听都可以很灵活的配置
Windowss 下 Spring + ActiveMq + maven 集成配置分为两章,环境搭建之前参考了网上的博客以及同事的配置。
前几章我们分别利用spring rmi、httpinvoker、httpclient、webservice技术实现不同服务器间的远程...3) Spring整合activemq配置 4) 定义消息发布者(生产者) 5) 定义消息订阅者(消费者) 6) Spring mvc配置 7) 实例测试
SpringBoot集成ActiveMQ,ActiveMQ支持队列和主题两种消息发送方式,选择发送方式可以在SpringBoot的配置文件中通过参数spring.jms.pub-sub-domain来控制,值为false表示是队列,值为true表示是主题。
ActiveMQDemo:这是关于消息中间件ActiveMQ的WEB项目,将覆盖JMS,ActiveMQ的初始入门和API详细使用,两种经典的消息模式(PTP和PubSub),与Spring集成,ActiveMQ进行监控,监控与配置优化等。不多说,直接撸原始码...
ActiveMQ Spring Boot简介简化 ActiveMQ 多机房集群配置原因ActiveMQ 多机房容灾ActiveMQ 带有一个 。 其中的多台 ActiveMQ Broker 彼此应该使用桥接方式相连,否则可能会出现没有 Consumer 的问题。但在多机房 ...
弹簧整合车间 这是使用Spring Integration DSL而不是基于XML的配置的非常简单的示例。 我使用DSL为虚拟的网上商店构建了简单的集成流程。管道管道: 从订单队列中读取传入的消息(订单) 筛选订单-检查订单是否有效...
Spring支持,以便ActiveMQ可以轻松嵌入到Spring应用程序中,并使用Spring的XML配置机制进行配置。 专为高性能集群,客户端 - 服务器,基于对等的通信而设计。 CXF和Axis支持,以便ActiveMQ可以轻松地放入这些Web服务...
Spring支持,以便ActiveMQ可以轻松嵌入到Spring应用程序中,并使用Spring的XML配置机制进行配置 专为高性能集群,客户端 - 服务器,基于对等的通信而设计 CXF和Axis支持,以便ActiveMQ可以轻松地放入这些Web服务...
jun_spring 项目module组件功能列表【spring_helloworld】springboot 的一个 helloworld【spring_properties】springboot 读取配置文件中的内容TODO:1、整cs的login跟index的page,适配Nginx跟ssm_jwt;2、整ssm_...
MQJMS以及ActiveMQ的关系理解 主动式MQ ActiveMQ的环境搭建 深入了解topic队列与Queue队列比较点到点(X英尺) ...在Spring下集成ActiveMQ ActiveMQ中间件实现实时消息传递第13讲-使用ActiveMQ与Sping框架整合案例
004-p2p模式+pulish-subscribe发布订阅模式+与spring集成;005-集群部署1;006-集群部署2;007-集群部署3;activemq集群配置文档.pdf;ActiveMQ(中文)参考手册.doc;ActiveMQ集群:网络连接模式(network connector)...