Golang分布式任务在Kubernetes中实现高可用部署，核心是确保自动恢复、精准流量调度、防重复与防丢失：需静态编译镜像并监听0.0.0.0；分离/healthz（存活）与/readyz（就绪）探针路径；解耦任务队列与Worker；基于队列长度而非CPU扩缩容；通过preStop+terminationGracePeriodSeconds实现优雅终止；并在Go代码中强制实现任务幂等性。
Golang分布式任务在Kubernetes中实现高可用部署，核心不是“能不能跑”，而是“挂了会不会自动恢复、流量会不会打到坏实例、任务会不会重复或丢失”。这需要把任务系统本身（如基于RabbitMQ/Kafka/Redis的任务队列 + Go Worker）和K8s的调度、探针、扩缩容机制对齐，否则容易出现任务卡死、重复消费、Worker副本失联却不被剔除等问题。
Go Worker容器镜像必须静态编译且监听0.0.0.0
很多Golang任务Worker用http.ListenAndServe(":8080", nil)启动健康端点，但忘了改监听地址——默认127.0.0.1:8080会导致Kubernetes的readinessProbe始终失败，Pod永远不Ready。更隐蔽的问题是：CGO没关，镜像里带libc依赖，换基础镜像就panic。
- 构建阶段加
CGO_ENABLED=0 GOOS=linux go build -a -ldflags '-extldflags "-static"' -o worker . - 运行阶段用
scratch或alpine:latest，不要留sh、curl等工具——它们不是探针必需的，反而是攻击入口 - HTTP健康接口必须绑定
0.0.0.0:8080，例如http.ListenAndServe("0.0.0.0:8080", mux) - 非HTTP Worker（如纯goroutine消费RabbitMQ）也得暴露一个HTTP端点供探针调用，哪怕只是返回
OK；否则K8s无法判断进程是否真在干活
Deployment必须配两个探针且路径分离
Kubernetes不会管你的Worker是不是在消费消息队列，它只认livenessProbe和readinessProbe返回码。共用一个/health路径是常见错误：一旦DB临时不可用，livenessProbe失败触发重启，而正在处理的任务就丢了。
-
readinessProbe走/readyz：检查消息队列连接、本地工作池是否空闲、是否有积压任务；失败则从Service摘除，但不重启 -
livenessProbe走/healthz：只检查进程存活、内存不过载、goroutine数未爆炸；失败才重启 -
initialDelaySeconds要设够——Worker启动时可能要连RabbitMQ、初始化DB连接池，5秒不够，建议设30起 - 别用
exec探针调ps aux | grep worker，容器里没ps，且进程存在 ≠ 服务可用
任务队列与Worker需解耦部署，避免单点故障
把RabbitMQ或Redis塞进同一个Pod跟Worker绑死，等于把鸡蛋放一个篮子。K8s能帮你扩Worker，但扩不了内嵌的MQ——一旦MQ崩，所有Worker一起失效。
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
立即学习“go语言免费学习笔记（深入）”；
- RabbitMQ用
StatefulSet + PVC部署，开启镜像队列，设置replicas: 3；别用Deployment跑无状态MQ - Worker的Deployment用
topologySpreadConstraints分散到不同节点，防止单机宕机导致整组Worker下线 - Consumer代码里必须设
autoAck: false，处理完再ack；否则Pod被杀时未ack的消息会重回队列，造成重复执行 - 用
ConfigMap注入队列地址、vhost、exchange名；敏感凭据（密码、TLS证书）必须走Secret，不能写进镜像或环境变量明文
HorizontalPodAutoscaler要基于真实负载指标
按CPU使用率扩缩Worker是误导性的——CPU低可能只是Worker在等RabbitMQ发消息，实际任务已堆积。真正该看的是队列长度或待处理任务数。
- 对接Prometheus + RabbitMQ Exporter，采集
rabbitmq_queue_messages_ready指标 - HPA配置
metrics类型为External，目标值设为每Pod分摊≤10条就绪消息 - 避免HPA频繁抖动：设
minReplicas: 2，并加stabilizationWindowSeconds: 300（5分钟冷却） - Worker启动时加
preStop钩子：收到SIGTERM后先拒绝新任务、等当前任务完成再退出，配合terminationGracePeriodSeconds: 60
最容易被忽略的一点：任务幂等性不在K8s里实现，而在Go代码里。K8s只能保证Worker不挂，不能保证消息不重发。每个任务处理前必须查DB或Redis做去重校验，比如用task_id做唯一键插入，失败即跳过——这点无论探针多准、HPA多灵，都绕不开。
