<!-- activeMQ -->

<dependency>

    <groupId>org.springframework.boot</groupId>

    <artifactId>spring-boot-starter-activemq</artifactId>

</dependency>

<!-- activeMQ的连接池 -->

<dependency>

    <groupId>org.apache.activemq</groupId>

    <artifactId>activemq-pool</artifactId>

</dependency>

spring.activemq.broker-url=tcp://localhost:61616

spring.activemq.user=admin

spring.activemq.password=admin

#queue和topic不能同时使用（我不会同时使用），使用topic的时候，把下面这行解除注释

#spring.jms.pub-sub-domain=true

spring.activemq.pool.enabled=false

spring.activemq.pool.max-connections=

import javax.jms.Destination;

import javax.jms.Queue;

import javax.jms.Topic;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.jms.core.JmsMessagingTemplate;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

@RestController

public class ProducerController {

    @Autowired

    private JmsMessagingTemplate jmsMessagingTemplate;

    @Autowired

    private Queue queue;

    @Autowired

    private Topic topic;

    /*

     * 消息生产者

     */

    @RequestMapping("/sendQueueMsg")

    public void sendQueueMsg(String msg) {

        this.jmsMessagingTemplate.convertAndSend(this.queue, msg);

    }

    @RequestMapping("/sendTopicMsg")

    public void sendTopicMsg(String msg) {

        // 指定消息发送的目的地及内容

        System.out.println("@@@@@@@@@@@@@@" + msg);

        this.jmsMessagingTemplate.convertAndSend(this.topic, msg);

    }

}

import org.springframework.jms.annotation.JmsListener;

import org.springframework.web.bind.annotation.RestController;

@RestController

public class ConsumerController {

    /**

     * 监听和读取queue消息

     * @param message

     */

    @JmsListener(destination="active.queue")

    public void readActiveQueue(String message) {

        System.out.println("接受到：" + message);

        //TODO something

    }

    /**

     * 监听和读取topic消息

     * @param message

     */

    @JmsListener(destination="active.topic")

    public void readActiveTopic(String message) {

        System.out.println("接受到：" + message);

        //TODO something

    }

}

import javax.jms.Queue;

import javax.jms.Topic;

import org.apache.activemq.command.ActiveMQQueue;

import org.apache.activemq.command.ActiveMQTopic;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.jms.annotation.EnableJms;

@Configuration

@EnableJms

public class JmsConfig {

    private static final String QUEUE_NAME = "active.queue";

    private static final String TOPIC_NAME = "active.topic";

    @Bean

    public Queue queue(){

        return new ActiveMQQueue(QUEUE_NAME);

    }

    @Bean

    public Topic topic(){

        return new ActiveMQTopic(TOPIC_NAME);

    }

}