只需三步:内嵌ActiveMQ到SpringBoot应用中-阿里云开发者社区

开发者社区> 开发与运维> 正文

只需三步:内嵌ActiveMQ到SpringBoot应用中

简介: 不知你是否有过这样的体验: 在调试带JMS组件的应用时, 需要额外启动一个JMS服务器来配合测试。 这样既操作繁琐,又不利于实现单元测试——不符合单元测试AIR原则(自动化,独立性,可重复,请参考《阿里巴巴Java开发手册》中的“单元测试”章节)。

不知你是否有过这样的体验:

在调试带JMS组件的应用时, 需要额外启动一个JMS服务器来配合测试。

这样既操作繁琐,又不利于实现单元测试——不符合单元测试AIR原则(自动化,独立性,可重复,请参考《阿里巴巴Java开发手册》中的“单元测试”章节)。

有时侯,我们需要一个随应用启动的JMS服务器,今天我们就来讲一下,如何在SpringBoot应用中内嵌一个ActiveMQ JMS Broker。

让我们开始吧

首先说明所有的文档来源,供各位深入研究。

本文所涉及的文档均来源于各组件的官方网站中。这里列举如下。
如何编写ActiveMQ Embedded broker
ActiveMQ XML配置指南
SpringBoot官方文档

示例代码则请参考我的github目录EmbbededActiveMQ

第一步:准备配置文件activemq.xml

activemq.xml是ActiveMQ的主要配置文件,可以通过其指定ActiveMQ的行为。

可以在ActiveMQ安装目录下的conf文件夹下找到默认的activemq.xml文件。在其基础上修改。

这里我们采用最小配置。

   <broker xmlns="http://activemq.apache.org/schema/core" brokerName="mybroker" useJmx="true">
        <persistenceAdapter>
            <kahaDB directory="./kahadb"/>
        </persistenceAdapter>

        <transportConnectors>
            <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
        </transportConnectors>
    </broker>

更多具体的配置项请参考ActiveMQ XML配置指南

第二步:添加依赖

编写maven项目的pom文件。添加一些必要的依赖。

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-spring</artifactId>
            <version>5.12.3</version>
        </dependency>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-kahadb-store</artifactId>
            <version>5.12.3</version>
        </dependency>
    </dependencies>

spring-boot-starter-activemq:由SpringBoot官方提供,这里要用来编写收发消息的代码。
activemq-spring :为ActiveMQ嵌入Spring应用提供支持。
activemq-kahadb-store :为ActiveMQ中配置队列持久化提供必要的依赖。

如果在activemq.xml中配置了其它功能,可能需要额外的依赖。可以根据应用启动时的 ClassNotFoundException 报错提示信息自行添加。

第三步:编写测试代码

添加ActiveMQ加载的代码。

    @Bean
    public BrokerFactoryBean activemq() throws Exception {
        BrokerFactoryBean broker = new BrokerFactoryBean();
        broker.setConfig(new ClassPathResource("activemq.xml"));
        broker.setStart(true);
        return broker;
    }

添加一个生产者和两个消费者。

    // 生产者,启动应用后自动发送10条消息
    @Bean
    public CommandLineRunner testSend() {
        return new CommandLineRunner() {
            @Override
            public void run(String... args) throws Exception {
                for (int i = 0; i < 10; ++i) {
                    jmsTemplate.convertAndSend("test", "message");
                }
            }
        };
    }

   // 消费者1
   @JmsListener(destination = "test")
    public void receive1(String message) {
        System.out.println("One Receive: " + message);
    }
    // 消费者2
    @JmsListener(destination = "test")
    public void receive2(String message) {
        System.out.println("Two Receive: " + message);
    }

再添加上SpringBoot应用的application.yml配置。

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

第四步: 运行并查看结果

启动应用,查看日志。


img_a52d3db4a8f05b3ab8138c15de4e69b1.png
应用启动日志

可见两个消费者各收到一半的消息,说明收发消息功能己经成功。

由于打开了JMX功能,使用JvisualVM连上应用,可以从MBean中找到自己定义的broker,并观察其执行状态。

img_49ee38a5405e27edb75e1e4f45a30472.png
JMX查看队列装态

可以看到test队列共入队并出队10条消息。

小功告成。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
开发与运维
使用钉钉扫一扫加入圈子
+ 订阅

集结各类场景实战经验,助你开发运维畅行无忧

其他文章