Spring Boot + ActiveMQ Artemis：快速实现高效消息队列处理功能

在现代微服务架构中，消息队列是实现异步通信、解耦系统的重要手段。而通过 Spring Boot 和 ActiveMQ Artemis，您可以快速搭建一个高效、可靠的消息队列处理系统，轻松应对订单处理、日志分析等场景。本文将带您从零开始，逐步实现一个完整的消息队列处理功能。

一、为什么选择 ActiveMQ Artemis？

ActiveMQ Artemis 是 Apache ActiveMQ 的高性能消息代理，具备以下优势：

轻量级：支持嵌入式模式，无需单独部署服务。
高性能：消息吞吐量高，延迟低。
兼容性强：支持多种协议（AMQP、STOMP、MQTT 等）以及与 Spring Boot 的无缝集成。
易用性：提供管理控制台和丰富的监控接口。

无论是嵌入式模式还是独立部署模式，ActiveMQ Artemis 都能满足不同规模的应用需求。

二、Spring Boot 快速搭建消息队列

1. 引入依赖

在 pom.xml 中添加以下依赖：

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-artemis</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>RELEASE</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>artemis-jakarta-server</artifactId>
            <version>2.37.0</version>
        </dependency>

2. 配置消息队列

在 application.yml 中配置消息队列：

嵌入式模式配置

spring:
  artemis:
    embedded:
      enabled: true
      persistent: false
      queues: order-queue # 自动创建队列

独立模式配置

spring:
  artemis:
    broker-url: tcp://localhost:61616
    user: admin
    password: admin

根据实际需求选择一种模式。如果您需要快速试验，可以使用嵌入式模式；如果应用需在生产环境运行，推荐使用独立模式。

三、消息生产者

消息生产者负责向队列发送消息。以下是实现代码：

import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;

@Service
public class OrderMessageProducer {

    private final JmsTemplate jmsTemplate;

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

    public void sendOrderMessage(String order) {
        jmsTemplate.convertAndSend("order-queue", order);
        System.out.println("Sent order: " + order);
    }
}

调用 sendOrderMessage 方法即可发送订单信息到队列 order-queue。

四、消息消费者

消费者监听队列中的消息并进行处理。通过 @JmsListener 注解可以轻松实现：

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

@Service
public class OrderMessageConsumer {

    @JmsListener(destination = "order-queue")
    public void processOrder(String order) {
        System.out.println("Processing order: " + order);
        // 模拟处理逻辑
    }
}

当消息到达队列时，processOrder 方法会自动触发，输出消息内容。

五、队列监控功能

1. 监控队列状态

为确保系统稳定性，需要实时监控队列积压情况。以下是一个监控服务的实现：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;

@Service
public class QueueMonitorService {

    @Autowired
    private JmsTemplate jmsTemplate;

    public long getQueueSize(String queueName) {
        return jmsTemplate.browse(queueName, (session, browser) -> {
            int count = 0;
            while (browser.getEnumeration().hasMoreElements()) {
                count++;
                browser.getEnumeration().nextElement();
            }
            return (long) count;
        });
    }
}

使用此服务可以查询任意队列的积压消息数量。

2. 暴露 REST 接口

通过 Spring Boot 的 REST 接口，可以更直观地获取监控数据

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

@RestController
@RequestMapping("/monitor")
public class QueueMonitorController {

    private final QueueMonitorService monitorService;

    public QueueMonitorController(QueueMonitorService monitorService) {
        this.monitorService = monitorService;
    }

    @GetMapping("/queue/{name}/size")
    public String getQueueSize(@PathVariable String name) {
        long size = monitorService.getQueueSize(name);
        return "Queue " + name + " size: " + size;
    }
}