创建和使用 Springboot+ActiveMQ 项目

1、 本项目使用 IDEA 工具搭建，项目可以直接导入到 eclipse 中，如果使用 eclipse 创建，请自行百度。
2、 首先新建项目。

3、 点击 next

填写自己想要的信息
4、 点击 next

选择箭头选择的

5、 点击 next

6、 点击 finish，等待程序初始化和加载包完成。

pom文件中添加了对activemq的支持

7、 先创建包，出现如下程序结构

8、 创建 ActiveMQ 配置类

package com.mbyte.easy.config;


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;

/**
 * @program: easy
 * @description: ActiveMQ配置类
 * @author: 王震
 * @create: 2019-05-05 11:26
 **/
@Configuration
@EnableJms
public class ActiveMQConfiguration {

    /**
     * 定义点对点队列
     * @return
     */
    @Bean
    public Queue queue() {
        return new ActiveMQQueue("sample.queue");
    }
    /**
     * 定义一个主题
     * @return
     */
    @Bean
    public Topic topic() {
        return new ActiveMQTopic("sample.topic");
    }

}

程序结构如下图所示

9、 创建生产者和消费者
定义生产者：

package com.mbyte.easy.mq;


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.scheduling.annotation.Scheduled;

import javax.jms.Queue;
import javax.jms.Topic;

/**
 * @program: easy
 * @description: 定义生产者
 * @author: 王震
 * @create: 2019-05-05 11:29
 **/
@Configuration
public class Producer {

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    @Autowired
    private Queue queue;

    @Autowired
    private Topic topic;

    /**
     * 每5S执行一次
     */
    @Scheduled(fixedRate = 5000, initialDelay = 3000)
    public void send() {
        //发送队列消息
        this.jmsMessagingTemplate.convertAndSend(this.queue, "生产者：http://www.byte.ac.cn");
        System.out.println("生产者：生产者：http://www.byte.ac.cn");
        //发送订阅消息
        this.jmsMessagingTemplate.convertAndSend(this.topic, "生产者生产的订阅/发布消息：生产者：http://www.byte.ac.cn");
        System.out.println("生产者：生产的订阅/发布消息：http://www.byte.ac.cn");
    }

}

定义消费者

package com.mbyte.easy.mq;


import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

/**
 * @program: easy
 * @description: 定义消费者
 * @author: 王震
 * @create: 2019-05-05 11:32
 **/
@Component
public class Consumer {

    @JmsListener(destination = "sample.queue")
    public void receiveQueue(String text) {
        System.out.println("消费者：来源于生产者的消息："+text);
    }

    @JmsListener(destination = "sample.topic")
    public void receiveSub1(String text) {
        System.out.println("消费者：Consumer1="+text);
    }
    @JmsListener(destination = "sample.topic")
    public void receiveSub2(String text) {
        System.out.println("消费者：Consumer2="+text);
    }

}

最终代码结构如下图所示：

10、 Springboot 需要开启调度，生产数据，在 Demo1Application 中添加 @EnableScheduling 注解

11、 现在开始运行程序

12、 程序正常运行

13、 Spring boot 默认 P2P 的模式，启用发布订阅模式，可以在 application.properties 中添加 spring.jms.pub-sub-domain=true

14、 再次运行程序

发布订阅模式已经启用
15、 将 ActiveMQ 配置成单独的服务，连接 ActiveMQ 服务，可以在可以在 application.properties 中添加

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

spring.activemq.user=admin
spring.activemq.password=admin

16、 重新启动程序

17、 程序正常运行，查看 ActiveMQ 管理后台

已经连接到 ActiveMQ 服务。
18、程序下载