SpringBoot3.4.0整合ActiveMQ6.1.4

itbeien2025年3月3日大约 4 分钟

SpringBoot3.4.0整合ActiveMQ6.1.4

前几篇文章整合了RocketMQ、RabbitMQ和Kafka、Apache Pulsar消息中间件。今天基于SpringBoot3.4.0整合ActiveMQ消息中间件，ActiveMQ是一个完全基于JMS规范实现的消息中间件产品。今天基于ActiveMQ6.1.4实现消息的生产和订阅

完整代码在文章最后，如果觉得本篇文章对你有用，记得点赞、关注、收藏哦。你的支持是我持续更新的动力!

SpringBoot3专栏软件环境

JDK17.0.12
SpringBoot3.4.0
ActiveMQ6.1.4
IDEA2024.2.0.2

我们先看本篇文章对应的项目结构，请看下图

1 安装ActiveMQ

1.1 ActiveMQ下载地址

https://www.apache.org/dyn/closer.cgi?filename=/activemq/6.1.4/apache-activemq-6.1.4-bin.zip&action=download

1.2 启动ActiveMQ

运行apache-activemq-6.1.4\bin\win64\activemq.bat

管理后台http://localhost:8161/ 默认登录用户名及密码admin/admin

2 项目搭建

2.1 pom.xml依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>cn.itbeien</groupId>
        <artifactId>springboot3-labs-master</artifactId>
        <version>1.0-SNAPSHOT</version>
    </parent>

    <artifactId>springboot-activemq</artifactId>

    <properties>
        <maven.compiler.source>17</maven.compiler.source>
        <maven.compiler.target>17</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>
    </dependencies>
</project>

2.2 项目配置信息

server.port=9999
spring.activemq.broker-url=tcp://localhost:61616
#spring.activemq.user=admin
#spring.activemq.password=admin

2.3 生产者代码

package cn.itbeien.activemq.service;

import lombok.extern.slf4j.Slf4j;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;

/**
 * @author itbeien
 * 项目网站：https://www.itbeien.cn
 * 公众号：贝恩聊架构
 * 全网同名，欢迎小伙伴们关注
 * Copyright© 2024 itbeien
 */
@Service
@Slf4j
public class ProducerService {
    private final JmsTemplate jmsTemplate;

    public ProducerService(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

    public void sendMsg(String msg){
        this.jmsTemplate.convertAndSend("itbeienTopic",msg);
        log.info("生产者生产消息...");
    }
}

2.4 消费者代码

package cn.itbeien.activemq.service;

import lombok.extern.slf4j.Slf4j;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Service;

/**
 * @author itbeien
 * 项目网站：https://www.itbeien.cn
 * 公众号：贝恩聊架构
 * 全网同名，欢迎小伙伴们关注
 * Copyright© 2024 itbeien
 */
@Service
@Slf4j
public class ConsumerService {

    @JmsListener(destination = "itbeienTopic")
    public void processMessage(String content) {
        log.info("消费者消费消息:{}",content);
    }
}

2.5 单元测试代码

package cn.itbeien.activemq.test;


import cn.itbeien.activemq.service.ProducerService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.test.context.SpringBootTest;

/**
 * @author itbeien
 * 项目网站：https://www.itbeien.cn
 * 公众号：贝恩聊架构
 * 全网同名，欢迎小伙伴们关注
 * Copyright© 2024 itbeien
 */
@SpringBootTest
public class ActiveMQApp {
  @Autowired
  private ProducerService producerService;

    @Test
    public void test(){
        this.producerService.sendMsg("hello itbeien!");
    }
}