Spring整合JMS(一)——基于ActiveMQ实现

<!-- 真正能够产生Connection的ConnectionFactory。由相应的 JMS服务厂商提供-->  
<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">  
    <property name="brokerURL" value="tcp://localhost:61616"/>  
</bean>  
  
<!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->  
<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">  
    <!-- 目标ConnectionFactory相应真实的能够产生JMS Connection的ConnectionFactory -->  
    <property name="targetConnectionFactory" ref="targetConnectionFactory"/>  
</bean>  

<!--这个是队列目的地，点对点的-->  
<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">  
    <constructor-arg>  
        <value>queue</value>  
    </constructor-arg>  
</bean>  
<!--这个是主题目的地。一对多的-->  
<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">  
    <constructor-arg value="topic"/>  
</bean>  

package com.somnus.jms.service.impl;   
    
import javax.annotation.Resource;   
import javax.jms.Destination;   
import javax.jms.JMSException;   
import javax.jms.Message;   
import javax.jms.Session;   
    
import org.springframework.jms.core.JmsTemplate;   
import org.springframework.jms.core.MessageCreator;   
import org.springframework.stereotype.Component;   
    
import com.somnus.jms.service.ProducerService;   
    
@Component  
public class ProducerServiceImpl implements ProducerService {   
    
    private JmsTemplate jmsTemplate;   
       
    public void sendMessage(Destination destination, final String message) {   
        System.out.println("---------------生产者发送消息-----------------");   
        System.out.println("---------------生产者发了一个消息：" + message);   
        jmsTemplate.send(destination, new MessageCreator() {   
            public Message createMessage(Session session) throws JMSException {   
                return session.createTextMessage(message);   
            }   
        });   
    }    
  
    public JmsTemplate getJmsTemplate() {   
        returnjmsTemplate;   
    }    
  
    @Resource  
    public void setJmsTemplate(JmsTemplate jmsTemplate) {   
        this.jmsTemplate = jmsTemplate;   
    }   
    
}  

<?
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"  
    xmlns:jms="http://www.springframework.org/schema/jms"  
    xsi:schemaLocation="http://www.springframework.org/schema/beans   
     http://www.springframework.org/schema/beans/spring-beans-3.0.xsd   
     http://www.springframework.org/schema/context   
     http://www.springframework.org/schema/context/spring-context-3.0.xsd   
    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd   
    http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd">  
    
    <context:component-scan base-package="com.somnus" />  
    
    <!-- Spring提供的JMS工具类，它能够进行消息发送、接收等 -->  
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">  
        <!-- 这个connectionFactory相应的是我们定义的Spring提供的那个ConnectionFactory对象 -->  
        <property name="connectionFactory" ref="connectionFactory"/>  
    </bean>  
       
    <!-- 真正能够产生Connection的ConnectionFactory，由相应的 JMS服务厂商提供-->  
    <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">  
        <property name="brokerURL" value="tcp://localhost:61616"/>  
    </bean>  
       
    <!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->  
    <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">  
        <!-- 目标ConnectionFactory相应真实的能够产生JMS Connection的ConnectionFactory -->  
        <property name="targetConnectionFactory" ref="targetConnectionFactory"/>  
    </bean>  
       
    <!--这个是队列目的地-->  
    <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">  
        <constructor-arg>  
            <value>queue</value>  
        </constructor-arg>  
    </bean>  
    <!-- 消息监听器 -->  
    <bean id="consumerMessageListener" class="com.somnus.jms.listener.ConsumerMessageListener"/>  
    <!-- 消息监听容器 -->  
    <bean id="jmsContainer"  
        class="org.springframework.jms.listener.DefaultMessageListenerContainer">  
        <property name="connectionFactory" ref="connectionFactory" />  
        <property name="destination" ref="queueDestination" />  
        <property name="messageListener" ref="consumerMessageListener" />  
    </bean>  
</beans>  

package com.somnus.jms.test;   
    
import javax.jms.Destination;   
    
import org.junit.Test;   
import org.junit.runner.RunWith;   
import org.springframework.beans.factory.annotation.Autowired;   
import org.springframework.beans.factory.annotation.Qualifier;   
import org.springframework.test.context.ContextConfiguration;   
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;   
import com.somnus.jms.service.ProducerService;   
    
@RunWith(SpringJUnit4ClassRunner.class)   
@ContextConfiguration("/applicationContext.xml")   
public class ProducerConsumerTest {   
    
    @Autowired  
    private ProducerService producerService;   
    @Autowired  
    @Qualifier("queueDestination")   
    private Destination destination;   
       
    @Test  
    public void testSend() {   
        for (int i=0; i<2; i++) {   
            producerService.sendMessage(destination, "你好，生产者！这是消息：" + (i+1));   
        }   
    }   
       
}