如何在Spring Boot中访问JMS统计信息？

Question

我知道JMS没有统计规范，所以没有标准的方式来读取诸如“处理的消息数”、“队列中的平均时间”等内容。

我在考虑两种方法：

1. 直接访问ActiveMQ统计信息
2. 维护JMS消息使用者中的统计信息

对于（1），我没有找到如何使用Spring Boot获取thos统计数据的示例。对于（2），我想知道消费者本身是否需要维护统计数据，或者是否有更好的方法。

有没有人有任何有效的例子？

Answer 1

如果您将JMS与Spring集成在一起，那么它的系统管理功能将提供统计信息，这些统计信息在Spring boot应用程序中注册为千分尺指标。

https://docs.spring.io/spring-integration/docs/5.1.7.RELEASE/reference/html/#system-管理章节

https://docs.spring.io/spring-boot/docs/2.1.7.RELEASE/reference/html/boot-features-integration.html

https://docs.spring.io/spring-boot/docs/2.1.7.RELEASE/reference/html/production-ready-metrics.html

Answer 2

作为记录，我最终实现了一个特定于代理的解决方案（这里是ActiveMQ）

import org.springframework.stereotype.Component
import javax.jms.*

typealias QueueName = String

@Component
class BrokerFacade(private val connectionFactory: ConnectionFactory) {
    private val statisticsBrokers = mutableMapOf<QueueName, StatisticsBrokerAccess>()

    @Throws(JMSException::class)
    fun getStatistics(queueName: QueueName): QueueStatistics? {
        val brokerAccess = statisticsBrokers.getOrPut(queueName, { StatisticsBrokerAccess(queueName) })
        return brokerAccess.getCurrentStatistics()?.let {
            QueueStatistics(
                queueName,
                it.getLong("size"),
                it.getLong("dequeueCount"),
                it.getDouble("minEnqueueTime"),
                it.getDouble("maxEnqueueTime"),
                it.getDouble("averageEnqueueTime"),
                it.getLong("memoryUsage"),
                it.getLong("memoryPercentUsage")
            )
        }
    }

    inner class StatisticsBrokerAccess(queueName: QueueName) {
        private val statisticsMessageConsumer: MessageConsumer;
        private val statisticsMessageProducer: MessageProducer;
        private val statisticsMessage: Message;

        init {
            val connection = connectionFactory.createConnection()
            connection.start()
            val session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
            val statisticsReplyQueue = session.createTemporaryQueue()
            statisticsMessageConsumer = session.createConsumer(statisticsReplyQueue)
            val statisticsQueue = session.createQueue("ActiveMQ.Statistics.Destination.$queueName")
            statisticsMessageProducer = session.createProducer(statisticsQueue)
            statisticsMessage = session.createMessage()
            statisticsMessage.setJMSReplyTo(statisticsReplyQueue)
        }

        fun getCurrentStatistics(): MapMessage? {
            statisticsMessageProducer.send(statisticsMessage)
            return statisticsMessageConsumer.receive(2000) as MapMessage?
        }
    }
}

队列统计是一个保存统计值的数据类。