K8S发送SIGTERM关闭Pod导致RabbitMQ服务端出现孤儿客户端如何解决？

• 调整网络规则避免preStop阶段流量被切断
  preStop阶段无法对外发流量的核心原因是kube-proxy、CNI插件的网络规则清理动作与preStop执行、SIGTERM信号发送是并行触发的，而非等preStop执行完成后再清理网络，可通过以下两种方式解决：
  1. 若集群版本≥1.23，可配置专属网络策略，明确允许Terminating状态的Pod对RabbitMQ服务端端口的出站TCP流量，绝大多数默认网络策略会主动终止Terminating Pod的外部通信
  2. 若Pod直接通过固定IP访问RabbitMQ（而非K8S Service地址），可在容器启动脚本中手动添加RabbitMQ/集群内部通信网段的静态路由，静态路由不会随Pod标记为Terminating被kube-proxy清理，可保证preStop或信号处理阶段的报文正常发出
• 优化应用侧的信号处理逻辑
  Python Pika默认的信号处理逻辑不会主动触发连接关闭，需手动修改代码适配K8S终止流程：
  1. 为应用注册SIGTERM信号处理器，收到信号后第一时间调用connection.close()主动向RabbitMQ服务端发送连接关闭报文
  2. 发送关闭报文后增加1~2秒的等待逻辑，确保报文已发出再终止进程，避免请求被丢弃
  3. 将Pod的terminationGracePeriodSeconds配置为≥15秒，给信号处理、报文发送预留足够时间，避免进程被提前强制杀死
• 兜底方案：调整RabbitMQ服务端的异常连接检测策略
  若暂时无法调整集群或应用配置，可将RabbitMQ的心跳超时时间调整为更短的数值（比如默认60秒可改为15秒），同时调低未响应心跳的剔除阈值，避免无效连接占用服务端资源过长时间

内容的提问来源于stack exchange，提问作者Spanky