Мониторинг ActiveMQ с помощью Proto Observability

Сбор метрик ActiveMQ

Интеграция activemq собирает метрики через JMX и обслуживает оба варианта брокера:

• Apache ActiveMQ Classic (5.x и 6.x) — namespace MBean’ов org.apache.activemq:*.
• Apache ActiveMQ Artemis (2.x) — namespace MBean’ов org.apache.activemq.artemis:*.

Отдельная интеграция для Artemis не нужна — проверка опрашивает оба namespace в рамках одного instance.

Конфигурация ActiveMQ

JMX Remote должен быть включён и доступен с хоста, на котором работает агент. Настройка зависит от варианта ActiveMQ.

• Вариант ActiveMQ:
• ActiveMQ Classic
• ActiveMQ Artemis

ACTIVEMQ_SUNJMX_START="-Dcom.sun.management.jmxremote=true \
  -Dcom.sun.management.jmxremote.port=1099 \
  -Dcom.sun.management.jmxremote.rmi.port=1099 \
  -Dcom.sun.management.jmxremote.authenticate=false \
  -Dcom.sun.management.jmxremote.ssl=false \
  -Dcom.sun.management.jmxremote.local.only=false \
  -Djava.rmi.server.hostname=<имя_хоста_или_контейнера>"

services:
  activemq:
    image: apache/activemq-classic:6.1.4
    environment:
      ACTIVEMQ_SUNJMX_START: >-
        -Dcom.sun.management.jmxremote=true
        -Dcom.sun.management.jmxremote.port=1099
        -Dcom.sun.management.jmxremote.rmi.port=1099
        -Dcom.sun.management.jmxremote.authenticate=false
        -Dcom.sun.management.jmxremote.ssl=false
        -Dcom.sun.management.jmxremote.local.only=false
        -Djava.rmi.server.hostname=activemq    # имя сервиса в docker network        
    ports:
      - "1099:1099"

services:
  artemis:
    image: apache/activemq-artemis:2.31.2
    environment:
      ARTEMIS_USER: artemis
      ARTEMIS_PASSWORD: artemis
      JAVA_ARGS_APPEND: >-
        -Dcom.sun.management.jmxremote=true
        -Dcom.sun.management.jmxremote.port=11099
        -Dcom.sun.management.jmxremote.rmi.port=11099
        -Dcom.sun.management.jmxremote.authenticate=false
        -Dcom.sun.management.jmxremote.ssl=false
        -Dcom.sun.management.jmxremote.local.only=false
        -Djava.rmi.server.hostname=artemis        
    ports:
      - "11099:11099"

Конфигурация ProtoOBP агента

Если агент запускается в виде службы на хосте

1. Создайте файл /etc/protoobp-agent/conf.d/activemq.d/conf.yaml:

   init_config:
     is_jmx: true
     collect_default_metrics: true
   
   instances:
     - host: localhost
       port: 1099            # 11099 для Artemis в схеме выше
       # user: username      # если на JMX включена аутентификация
       # password: password
       name: activemq_instance
   

2. Перезапустите агента: systemctl restart protoobp-agent.

Если агент запускается в виде Docker контейнера

Добавьте autodiscovery-лейблы к контейнеру брокера. В docker-compose.yaml:

labels:
  com.protoobp.ad.check_names: '["activemq"]'
  com.protoobp.ad.init_configs: '[{"is_jmx": true, "collect_default_metrics": true}]'
  com.protoobp.ad.instances: '[{"host": "%%host%%", "port": "1099", "name": "activemq_instance"}]'

Для Artemis — тот же набор лейблов, но port соответствует порту JMX RMI server’а:

labels:
  com.protoobp.ad.check_names: '["activemq"]'
  com.protoobp.ad.init_configs: '[{"is_jmx": true, "collect_default_metrics": true}]'
  com.protoobp.ad.instances: '[{"host": "%%host%%", "port": "11099", "name": "artemis_instance"}]'

Проверка

Убедитесь, что чек запустился и собирает метрики:

docker exec protoobp-agent agent status | grep -A 8 "^    activemq$"

Ожидаемый вывод — status : OK и metric_count > 0 для каждого instance:

activemq
  instance_name : activemq_instance
  message       : <no value>
  metric_count  : 46
  status        : OK

Полный список найденных JMX-атрибутов:

docker exec protoobp-agent agent jmx list collected

Собираемые метрики

Все метрики собираются по JMX и имеют тип gauge — содержат мгновенное значение на момент сбора. Метрики, имена которых заканчиваются на _count, не являются кумулятивными счётчиками: интеграция конвертирует их в rate в секунду на стороне агента.

Лейблы

Общие (на всех метриках)

Добавляются агентом и ProtoOBP backend’ом:

Специфичные для ActiveMQ Classic

Специфичные для ActiveMQ Artemis

Метрики ActiveMQ Classic

Уровень брокера

Несут лейблы brokerName, type. Значения в процентах (0–100).

Уровень очереди / топика

Несут лейблы brokerName, destinationName, destinationType, type.

Метрики ActiveMQ Artemis

Уровень брокера

Несут лейбл broker.

Уровень адреса

Несут лейблы broker, address, component=addresses.

Уровень очереди

Несут лейблы broker, address, queue, routing_type, component=addresses, subcomponent=queues.

Ключевые метрики для дашбордов и алертов

Доступность брокера

• Отсутствие свежих серий по instance — алерт: брокер недоступен или JMX отвалился (агент не получает метрики).
• Artemis: activemq_artemis_connection_count == 0 при ожидаемом трафике — клиенты отвалились.

Накопление сообщений (backlog)

• Classic: activemq_queue_size per destinationName — основной SLI. Алерт по абсолютному порогу или производной (рост быстрее N в минуту).
• Artemis: activemq_artemis_queue_message_count per address/queue.
• activemq_queue_consumer_count == 0 при ненулевом activemq_queue_enqueue_count = некому потреблять.

Поток сообщений

• Classic: activemq_queue_enqueue_count (in) vs activemq_queue_dequeue_count (out) — рассинхрон → backlog растёт.
• Artemis: activemq_artemis_queue_messages_added vs activemq_artemis_queue_messages_acknowledged.
• activemq_artemis_address_unrouted_messages > 0 — алерт: потери при маршрутизации (нет подходящей очереди для адреса).

Качество доставки

• activemq_queue_expired_count / activemq_artemis_queue_messages_expired — сообщения теряются по TTL.
• activemq_queue_in_flight_count стабильно высокий = консьюмеры медленно подтверждают.
• activemq_artemis_queue_messages_killed > 0 — попадание в DLQ или превышение лимита очереди.

Ресурсы брокера

• Classic: activemq_broker_memory_pct, activemq_broker_store_pct, activemq_broker_temp_pct — алерт при > 80–90 % (флоу-контроль брокера).
• Artemis: activemq_artemis_address_memory_usage_pct, activemq_artemis_disk_store_usage_pct — приближение к max-disk-usage блокирует приём сообщений.
• activemq_artemis_address_pages_count — рост = paging активен (память под адрес исчерпана, ушли на диск).

Время в очереди (latency)

• Classic: activemq_queue_avg_enqueue_time, activemq_queue_max_enqueue_time — сколько сообщения ждали консьюмера.