如何用Golang结合KEDA实现基于消息队列的HPA事件驱动扩容？

本文共计1157个文字，预计阅读时间需要5分钟。

KEDA通过HTTP API间接连接RabbitMQ，不直接编写Go代码。它依赖触发器（trigger）拉取指标，而RabbitMQ的队列长度通过HTTP API暴露。首先，确认RabbitMQ实例已启动并管理插件，且KEDA可以访问（网络连接+认证配置）。

常见错误现象：Failed to get metric value from external metrics API，大概率是 TriggerAuthentication 里填错了用户名/密码，或 RabbitMQ 管理端口（默认 15672）没开放给 KEDA 所在命名空间。

• Go 服务只需作为标准消费者运行，不需改业务逻辑；KEDA 控制的是它的 Deployment 副本数
• RabbitMQ 队列名必须和 ScaledObject 中 queueName 完全一致（区分大小写）
• 推荐用 vhost 参数限定作用域，避免跨虚拟主机误读队列
• 指标采样频率默认 30s，若消息突发性强，可在 ScaledObject.spec.triggers[0].metadata.pollingInterval 调至 15

Go 服务要暴露什么接口才能配合 KEDA 优雅扩缩

KEDA 不查健康或指标接口，但它依赖的底层机制（如 HPA 和 kubelet）仍需要这些。真正关键的是：Go 服务必须支持快速启停 + 流量无损切换，否则扩容进来的新 Pod 还没 ready 就被转发流量，缩容时老 Pod 被 SIGTERM 杀掉却还在处理请求，结果就是超时或丢消息。