alenkacz/marathon-rabbitmq-autoscale

marathon-rabbitmq-autoscale

![Build Status]([***]

镜像概述

本镜像为运行在Marathon中的应用提供自动扩缩容能力，适用于消费RabbitMQ消息的应用。当实例数无法应对队列堆积消息时自动增加实例，队列无消息时可自动减少实例，同时支持冷却期防止频繁调整（默认5分钟）。

核心功能

• 根据RabbitMQ队列消息数量动态调整Marathon应用实例数
• 支持设置最大/最小实例数限制
• 可配置扩缩容时的实例增减数量
• 支持多RabbitMQ服务器
• 提供冷却期机制避免频繁扩缩容

使用场景

• 微服务架构中消息驱动的应用（如订单处理、日志采集）
• 需要根据消息量动态分配资源的场景
• 希望自动平衡资源利用率与消息处理速度的系统

配置说明

运行autoscaler

autoscaler依赖Marathon，建议部署在Marathon中，通过环境变量JAVA_OPTS配置参数。示例配置：

json
{
  "id": "/autoscaler",
  "cpus": 1,
  "mem": 256,
  "disk": 0,
  "instances": 1,
  "container": {
    "type": "DOCKER",
    "docker": {
      "image": "alenkacz/marathon-rabbitmq-autoscale",
      "network": "BRIDGE",
      "forcePullImage": true
    }
  },
  "env": {
    "JAVA_OPTS": "-DrabbitMq.0.username=user -DrabbitMq.0.password=password -DrabbitMq.0.httpApiEndpoint=https://rabbitmq.yourdomain.com:15671/api -Dmarathon.url=http://marathon.yourdomain.com/"
  }
}

配置自动扩缩容的应用

有两种配置方式：

1. 为Marathon应用添加标签（推荐）
   为应用添加以下标签启用自动扩缩容：

   • AUTOSCALE_QUEUE：监控的队列名称（必填）
   • AUTOSCALE_VHOST：队列所在vhost（可选，默认"/"）
   • AUTOSCALE_MAXMESSAGES：触发扩容的消息阈值（必填）
   • AUTOSCALE_MAXINSTANCES：最大实例数（可选）
   • AUTOSCALE_MININSTANCES：最小实例数（可选，启用缩容）
   • AUTOSCALE_RMQSERVER：RabbitMQ服务器名称（可选，支持多服务器）
   • AUTOSCALE_UPCOUNT：扩容增加的实例数（可选，默认1）
   • AUTOSCALE_DOWNCOUNT：缩容减少的实例数（可选，默认1）

   示例：API添加标签

   json
   {
       "id": "/product/service/myApp",
       "labels": {
           "AUTOSCALE_QUEUE": "queuename"
       }
   }
   

2. 修改autoscaler配置
   通过JAVA_OPTS直接配置应用，格式遵循https://github.com/typesafehub/config%E8%A7%84%E8%8C%83%EF%BC%8C%E4%BE%8B%E5%A6%82%60-Dapps.0.name=testapp%60%E3%80%82