ActiveMQ 是Apache出品，最流行的，能力强劲的开源消息总线。由于ActiveMQ是一个独立的JMS?provider，很容易被用于多种结构设计中，也不需要第三方服务器的支持，这样我们的应用可以部署在各种J2EE服务器或servlet服务器中，也可以独立运行。
?
本文介绍如何在spring中集成activemq，然后演示下如何发送和接收消息。
?
在spring中设置ActiveMQ的connectionFactory，需要导入activemq-client.jar，可以到activemq官网或者通过maven repository下载。
|
<!-- 真正可以产生Connection的ConnectionFactory，由对应的JMS服务厂商提供-->? <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> ??????? <property name="brokerURL" value="tcp://localhost:61616" /> </bean> |
?
|
<!--这个是队列目的地，点对点的--> <bean id="notifyQueue" class="org.apache.activemq.command.ActiveMQQueue"> ??? ?<constructor-arg> ??? ???? <value>notifyQueue</value> ??? ?</constructor-arg> </bean> |
?
使用Spring提供的JmsTemplate封装JMS的细节，简化代码开发，JmsTemplate支持发送和接收。
|
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> ??? <property name="connectionFactory" ref="connectionFactory"/> ??? <property name="receiveTimeout" value="2000" /> </bean> |
?
JmsTemplate每次发送都会创建新的connect，新的session，新的MessageProducter，这样效率较低。Spring提供了一个org.springframework.jms.connection.SingleConnectionFactory，每次都返回同一个connection，它会忽略close，所以connection会一直保持着。Spring还提供了一个org.springframework.jms.connection.CachingConnectionFactory，
增加了对session的缓存功能，可以通过sessionCacheSize设置，但因为它继承自SingleConnectionFactory，所以同样是一直使用同一connection，我觉得主要是用于测试环境。
?
ActiveMQ也提供了一个对connection,session, MessageProducer实现池化功能的org.apache.activemq.pool.PooledConnectionFactory。这个可以在生产环节使用。不过他和atomikos的分布式事务目前测试配合不了，使用atomikos分布式事务时由其他方法，下回再说。
编写消息生产者，把消息发送至队列notifyQueue
|
@Component publicclass JmsProducerService { ??? ??? @Resource ??? private JmsTemplate jmsTemplate; ??? ??? @Qualifier("notifyQueue") ??? @Autowired ??? private Destination destination; ??? ??? publicvoid sendMessage(final String message) {? ??????? System.out.println("---------------生产者-----------------"); ??????? System.out.println("发了一个消息：" + message);? ??????? jmsTemplate.send(destination, new MessageCreator() { ??????????? ??????????? @Override ??????????? public Message createMessage(Session session) throws JMSException { ??????????????? returnsession.createTextMessage(message);? ??????????? }? ??????? }); ?????? ??? } } |
?
配置一个Spring监听容器，引用上面配置好的connectionFactory
|
<!-- 配置一个通用的JMS监听容器 --> <bean id="jmsListenerContainerFactory" ?class="org.springframework.jms.config.DefaultJmsListenerContainerFactory"> ??? ?<property name="connectionFactory" ref="connectionFactory"/> </bean> |
?
使用@Jmslistener直接在代码中定义监听器，减少配置文件编写，需要添加下面配置以支持@Jmslistener
|
<!-- 支持@JmsListener自动启动监听器 --> <jms:annotation-driven/> |
?
PS：<jms:annotation-driven>默认是使用jmsListenerContainerFactory，所以配置中可以不用指定
?
使用@JmsListener定义一个监听器，监听消息队列notifyQueue
|
@Component publicclass AnConsumerListener { ? ??? @JmsListener(destination="notifyQueue") ??? public void receiveMessage(String message){ ?????? System.out.println("---------------消费者监听-----------------"); ?????? System.out.println("接收到一个纯文本消息：" + message); ?????? ??? } } |
?
?
执行activemq/bin/activemq.bat start
?
|
JmsProducerService jms = (JmsProducerService)SpringContextManager.getBean("jmsProducerService"); jms.sendMessage("Hello world!"); ? |
?
?
原文：http://hzy0769.iteye.com/blog/2294639