spring整合activemq

整合spring和activemq需要搞清楚如下的东东

1、ConnectionFactory分：

     a、spring管理连接到activemq服务器的管理ConnectionFactory也即是所谓产生到jms服务器的链接

      b、真正产生到JMS服务器链接的ConnectionFactory还得是由JMS服务厂商提供，并且需要把它注入到Spring提  供的ConnectionFactory中

2、生产者  生产者负责产生消息并发送到JMS服务器，这通常对应的是我们的一个业务逻辑服务实现类，通常是 利用Spring为我们提供的JmsTemplate类来实现的

3、消费者 消息的接受者；一般包括[size=14px;]处理消息的[/size]MessageListener、消息监听容器MessageListenerContainer、发送消息到指定目的地Destination之类

4、消息类型：点对点、发布订阅

具体详情可以参考该地址：http://haohaoxuexi.iteye.com/blog/1893038

想实现代码如下：

一、业务服务接口


[code="java"]package com.jms.service;

import javax.jms.Destination;

public interface ProducerService {
public void sendMessage(Destination destination, final String message);
}

二、业务服务接口实现类



[code="java"]package com.jms.service;

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;


@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() {
        return jmsTemplate;
    }

    @Resource
    public void setJmsTemplate(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

}

三、消息处理接口

[code="java"]package com.jms.service;


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

public class ConsumerMessageListener implements MessageListener {

    public void onMessage(Message message) {
        //这里我们知道生产者发送的就是一个纯文本消息，所以这里可以直接进行强制转换
        TextMessage textMsg = (TextMessage) message;
        System.out.println("接收到一个纯文本消息。");
        try {
            System.out.println("消息内容是：" + textMsg.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }

}
四、测试单元



[code="java"]package com.jms.service;

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;


@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("/jms-messages.xml")
public class ProducerConsumerTest {
    @Autowired
    private ProducerService producerService;
    @Autowired
    @Qualifier("queueDestination")
    private Destination destination;
   
    @Test
    public void testSend() {
        for (int i=0; i
queue

六、需要下载activemq服务器并配置好，最终开启activemq服务器 http://activemq.apache.org/activemq-5111-release.html （如若未开启activemq服务可能会到导致只出现一对 消息发送 接收）

七、对应的项目jar详见附件，任意建一个web项目即可

如上基本实现spring 整合 jms （activemq）