ActiveMQ学习笔记二

spring整合activemq

1、pom.xml引入spring支持的jms包
有关spring所需的其他jar包可自行引入

	org.apache.activemq
	activemq-all
	5.15.9


	org.apache.xbean
	xbean-spring
	3.16


	org.springframework
	spring-jms
	4.3.23.RELEASE


	org.apache.activemq
	activemq-pool
	5.15.9


	com.fasterxml.jackson.core
	jackson-databind
	2.9.5

2、spring配置文件

3、写一个监听器 ：可以实现不启动消费者只启动生产者就可以接收到消息（可以监听队列或者topic，只需要在spring配置文件中配置监听队列还是topic就可以）

import org.springframework.stereotype.Component;

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


@Component
public class MyMessageListener implements MessageListener {

    @Override
    public void onMessage(Message message) {
        if (null != message && message instanceof TextMessage) {
            try {
                TextMessage textMessage = (TextMessage) message;
                System.out.println(textMessage.getText());
            } catch (JMSException e) {
                e.printStackTrace();
            }
        }
    }
}

5、生产者

import org.apache.xbean.spring.context.ClassPathXmlApplicationContext;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Service;

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


@Service
public class SpringProducer {

    @Autowired
    private JmsTemplate jmsTemplate;

    public static void main(String[] args) {
        ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext.xml");
        SpringProducer producer = (SpringProducer) ctx.getBean("springProducer");
        producer.jmsTemplate.send((session) -> {
            TextMessage textMessage = session.createTextMessage("***********spring和ActiveMQ整合的case for MyMessageListener333");
            return textMessage;
        });
        System.out.println("******send task over");
    }
}