ActiveMQ Artemis队列消息超阈值邮件告警方案咨询

除了你提到的Advisory Queue，还有两个更优的原生方案可以实现需求，具体如下：

1. 自定义Broker Plugin #

这是最贴合Broker原生机制的方案，性能开销比Advisory Queue更小，计数也更准确：

• 实现org.apache.activemq.artemis.core.server.plugin.BrokerPlugin接口，可选择重写afterAddMessage做实时监控，或者在插件内启动定时任务定期检查
• 通过server.getQueue(queueName)获取队列实例，调用getMessageCount()直接拿到待处理消息数
• 当数值超过阈值时，调用JavaMail或邮件发送工具触发告警
• 最后在broker.xml的<broker-plugins>节点注册该插件，无需额外队列中转事件，避免Advisory Queue带来的消息堆积或性能损耗

核心逻辑示例：

public class QueueThresholdAlertPlugin implements BrokerPlugin {
    private String targetQueue;
    private int threshold;
    private String emailRecipient;

    @Override
    public void init(ActiveMQServer server) throws ActiveMQException {
        // 每30秒执行一次阈值检查
        ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
        scheduler.scheduleAtFixedRate(() -> {
            Queue queue = server.getQueue(targetQueue);
            if (queue != null && queue.getMessageCount() > threshold) {
                sendAlertEmail(emailRecipient, targetQueue, queue.getMessageCount());
            }
        }, 0, 30, TimeUnit.SECONDS);
    }

    // 省略邮件发送实现
    private void sendAlertEmail(String recipient, String queueName, long messageCount) {
        // 邮件发送逻辑
    }
}

2. 基于Management API的定时监控 #

这种方案无需修改Broker代码，适合运维侧快速落地：

• Artemis内置JMX和REST形式的Management API，可直接查询队列的messageCount指标
• 用定时任务工具（比如Quartz、Spring Schedule，甚至Shell脚本+cURL）定期调用API获取数值
• 对比阈值后触发邮件告警
• JMX方式可通过MBean路径org.apache.activemq.artemis:broker=<你的Broker名>,component=addresses,address=<队列地址>,subcomponent=queues,routing-type=ANYCAST,name=<队列名>获取messageCount属性；REST方式可调用Jolokia接口/jolokia/read/[MBean路径]/messageCount拿到数据

这种方式完全解耦Broker和监控逻辑，不用重启Broker就能调整阈值或告警规则，适合多Broker集群的统一监控场景。

方案对比 #

• Advisory Queue：依赖事件消息累加计数，易出现误差，高负载场景会增加Broker额外消息处理压力
• 自定义Broker Plugin：Broker内部直接获取准确计数，性能最优，但需要编写Java代码并修改Broker配置
• Management API监控：无需侵入Broker，灵活度高，运维落地成本低，性能开销最小

内容的提问来源于stack exchange，提问作者Sajawal