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: truepersistent: falsequeues: order-queue # 自动创建队列

独立模式配置

spring:artemis:broker-url: tcp://localhost:61616user: adminpassword: 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 {@Autowiredprivate 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;}
}