如何在K8s集群中查询指定客户端ID是否连接TCP服务器副本？

现有方案的问题分析 #

你提到的两个方案都存在明显缺陷：

• 方案1的FanOut广播会让所有API副本收到响应，造成资源冗余；且必须等待超时才能判定未连接，效率和可靠性都一般。
• 方案2的Redis缓存若不处理状态一致性，会出现TCP服务器异常退出后缓存残留无效连接数据的问题，导致查询结果失真。

推荐实现方案 #

一、改进RabbitMQ消息路由方案（适配现有技术栈） #

放弃FanOut广播，改用Direct Exchange + 唯一请求ID的精准路由方式，避免冗余：

• API X生成唯一request_id，将查询请求（包含client_id和request_id）发送到Direct Exchange，该Exchange绑定所有TCP服务器的监听队列。
• 每个TCP服务器收到请求后，检查本地连接列表：
  • 若存在目标client_id，则将响应（包含client_id、request_id、connected: true）发送到专属响应Exchange，路由键设为response.{request_id}。
  • 若不存在，直接忽略请求，不返回响应。
• API X在发送查询前，创建一个临时响应队列，绑定到响应Exchange的response.{request_id}路由键，并设置队列自动过期时间（比如5秒，与查询超时时间一致）。API X只监听这个临时队列，一旦收到connected: true的响应，立即返回结果并销毁队列；超时未收到则判定为未连接。

该方案优势：

• 只有发起查询的API X能收到响应，不会干扰其他副本。
• 无冗余空结果消息，降低RabbitMQ负载。
• 临时队列自动过期，无需手动清理资源。

二、增强型Redis缓存方案（适合高频查询场景） #

如果需要更高的查询效率，可基于Redis优化状态一致性：

• 每个TCP服务器维护Hash结构tcp_connections:{tcp_server_pod_id}，Key为client_id，Value存连接时间戳。
• 维护全局Set集合active_client_ids，客户端连接建立时将client_id加入Set，断开时移除。
• API X查询时，直接检查active_client_ids中是否存在目标client_id，O(1)复杂度，效率极高。
• 为避免脏数据，给每个client_id设置1分钟过期时间，TCP服务器每隔30秒为当前维护的client_id续期；客户端正常断开时立即删除对应Hash键和Set中的值。TCP服务器启动/退出时，也需同步更新自身的活跃标识到Redis，确保API X能感知到所有在线的TCP节点。

方案选择建议 #

• 若当前集群规模小（仅2个TCP副本），且不想引入额外依赖，优先选改进后的RabbitMQ方案，完全适配现有技术栈。
• 若后续TCP副本会扩容，或有高频查询需求，优先选增强型Redis方案，查询效率更高，还支持连接状态统计等扩展功能。

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