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

На этой странице:

• Сбор метрик ActiveMQ
  • Конфигурация ActiveMQ
  • Конфигурация ProtoOBP агента
    • Если агент запускается в виде службы на хосте
    • Если агент запускается в виде Docker контейнера
  • Проверка
  • Собираемые метрики
    • Лейблы
      • Общие (на всех метриках)
      • Специфичные для ActiveMQ Classic
      • Специфичные для ActiveMQ Artemis
    • Метрики ActiveMQ Classic
      • Уровень брокера
      • Уровень очереди / топика
    • Метрики ActiveMQ Artemis
      • Уровень брокера
      • Уровень адреса
      • Уровень очереди
  • Ключевые метрики для дашбордов и алертов
• Сбор логов ActiveMQ
  • Конфигурация ProtoOBP агента
    • Если агент запускается в виде службы на хосте
    • Если агент запускается в виде Docker контейнера
  • Проверка

Сбор метрик 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 — сколько сообщения ждали консьюмера.

Сбор логов ActiveMQ

Логи брокера собираются ProtoOBP агентом и отправляются в бэкенд ProtoOBP. Здесь — только специфичные для ActiveMQ настройки. Включение логов на стороне агента (logs_enabled, logs_pobp_url) описано в Получение данных логов.

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

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

Дополните уже существующий /etc/protoobp-agent/conf.d/activemq.d/conf.yaml (тот же файл, в котором лежит instances: для JMX) блоком logs:.

ActiveMQ Classic:

logs:
  - type: file
    path: <ACTIVEMQ_BASEDIR>/data/activemq.log
    source: activemq
    service: activemq
    log_processing_rules:
      - type: multi_line
        name: log_start_with_date
        pattern: \d{4}-\d{2}-\d{2}
  - type: file
    path: <ACTIVEMQ_BASEDIR>/data/audit.log
    source: activemq
    service: activemq

<ACTIVEMQ_BASEDIR> — корень установки брокера (для Classic обычно /opt/apache-activemq). audit.log создаётся, только если в conf/log4j2.properties явно включён аудит-логгер; без него этот пункт можно убрать.

ActiveMQ Artemis:

logs:
  - type: file
    path: <BROKER_INSTANCE>/log/artemis.log
    source: artemis
    service: artemis
    log_processing_rules:
      - type: multi_line
        name: log_start_with_date
        pattern: \d{4}-\d{2}-\d{2}

<BROKER_INSTANCE> — каталог инстанса Artemis, созданный командой artemis create.

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

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

Шаг 1 — включите сбор логов в самом агенте через переменные окружения и смонтируйте директорию JSON-логов docker-демона:

services:
  protoobp-agent:
    environment:
      POBP_LOGS_ENABLED: "true"
      POBP_LOGS_CONFIG_USE_HTTP: "true"
      POBP_LOGS_CONFIG_LOGS_POBP_URL: <protoobp-backend>:<port>
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock:ro
      # Прямое чтение JSON-лог файлов docker-демона быстрее,
      # чем тянуть их через Docker socket API.
      - /var/lib/docker/containers:/var/lib/docker/containers:ro

Шаг 2 — добавьте лейбл com.protoobp.ad.logs к контейнеру брокера. Агент подхватит stdout/stderr контейнера и пометит записи указанными source и service.

ActiveMQ Classic:

services:
  activemq:
    labels:
      com.protoobp.ad.logs: '[{"source": "activemq", "service": "activemq", "log_processing_rules": [{"type": "multi_line", "name": "log_start_with_date", "pattern": "\\d{4}-\\d{2}-\\d{2}"}]}]'

ActiveMQ Artemis:

services:
  artemis:
    labels:
      com.protoobp.ad.logs: '[{"source": "artemis", "service": "artemis", "log_processing_rules": [{"type": "multi_line", "name": "log_start_with_date", "pattern": "\\d{4}-\\d{2}-\\d{2}"}]}]'

Проверка

В выводе agent status должен быть раздел Logs Agent со статусом running и хотя бы один источник activemq (или artemis) с ненулевым BytesRead:

docker exec protoobp-agent agent status \
  | sed -n '/^==== Logs Agent ====/,/^====/p'