<?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:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xmlns:mvc="http://www.springframework.org/schema/mvc"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
   <context:component-scan base-package="edu.hpu"></context:component-scan>       
    <!-- 真正可以产生Connection的ConnectionFactory，由对应的 JMS服务厂商提供--> 
    <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
        <property name="brokerURL" value="tcp://127.0.0.1:61616"/> 
    </bean>         
     
    <!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory --> 
    <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"> 
     
    <!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory --> 
        <property name="targetConnectionFactory" ref="targetConnectionFactory"/> 
    </bean>        
     
    <!-- Spring提供的JMS工具类，它可以进行消息发送、接收等 --> 
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> 
        <!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 --> 
        <property name="connectionFactory" ref="connectionFactory"/> 
    </bean>     
     
    <!--这个是队列目的地, ActiveMQQueue 就表示队列模式。 如果要用主题模式就改成 ActiveMQTopic就行了 --> 
    <bean id="textDestination" class="org.apache.activemq.command.ActiveMQQueue"> 
        <constructor-arg value="queue_style"/> 
    </bean> 
        
    <!-- 我的监听类 -->
    <bean id="myMessageListener" class="edu.hpu.MyMessageListener"></bean>
     
    <!-- 消息监听容器，会伴随spring的启动 -->
    <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destination" ref="textDestination" />
        <property name="messageListener" ref="myMessageListener" />
    </bean>          
 
</beans>

生产者类

Producter:

package edu.hpu;

import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Component;

@Component
public class Producter {
	@Autowired
	private JmsTemplate jmsTemplate;
	
	 @Autowired
	 private Destination textDestination;
	
	public void sendTextMessage(final String text) {
		jmsTemplate.send(textDestination,new MessageCreator() {
			
			public Message createMessage(Session session) throws JMSException {
				// TODO Auto-generated method stub
				return session.createTextMessage(text);
			}
		});
	}

}

package edu.hpu.test;

import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cglib.core.SpringNamingPolicy;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import edu.hpu.Producter;
import edu.hpu.util.ActiveMQUtil;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:spring_jms.xml")
public class TestProducter {
   @Autowired
   private Producter producter;
   
   @Before
   public void checkServer() {
       ActiveMQUtil.checkServer();
   }
   
   @Test
   public void testSend() {
	   for (int i = 0; i < 100; i++) {
           producter.sendTextMessage("消息 " + i);
       }
   }
   
}

package edu.hpu;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import cn.hutool.core.util.RandomUtil;

public class MyMessageListener implements MessageListener{
	String name = "consumer-"+ RandomUtil.randomString(5);
    public  MyMessageListener() {
        System.out.println(name + " started");
    }
     
    public void onMessage(Message message) {
        TextMessage textMessage=(TextMessage)message;       
        try {
            System.out.println(name+" 接收到消息："+textMessage.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

System.in.read();

package edu.hpu.test;

import java.io.IOException;

import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import edu.hpu.util.ActiveMQUtil;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:spring_jms.xml")
public class TestConsumer {
	@Before
    public void checkServer() {
        ActiveMQUtil.checkServer();
    }
     
    @Test
    public void test(){
        try {
            //写这个是为了不让当前测试退出。  因为 spring的配置， MyMessageListener 会自动启动
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }       
    }   
}

    <!--这个是队列目的地, ActiveMQQueue 就表示队列模式。 如果要用主题模式就改成 ActiveMQTopic就行了 --> 
    <bean id="textDestination" class="org.apache.activemq.command.ActiveMQQueue"> 
        <constructor-arg value="queue_style"/> 
    </bean>