Aerospike Java客户端如何检测陈旧连接并重建新连接？

一、检测并丢弃陈旧连接、重建新连接 #

Aerospike Java客户端本身提供了多种机制处理节点变更，无需重启应用即可清理旧连接：

• 利用内置节点健康检查与自动清理
  客户端默认会定期执行节点健康探测（默认nodeRefreshInterval为10秒），可通过调整ClientPolicy参数强化这一机制：

  ClientPolicy policy = new ClientPolicy();
  // 缩短节点刷新间隔，加快发现失效节点
  policy.nodeRefreshInterval = 5000; // 5秒
  // 设置连接超时，超时后自动标记节点不可用
  policy.connectionTimeout = 2000; // 2秒
  policy.socketTimeout = 3000; // 3秒
  AerospikeClient client = new AerospikeClient(policy, seedHosts);
  

  当旧节点无法响应时，客户端会自动将其从活跃节点列表移除，清理对应连接池，后续请求会自动路由到新集群节点。

• 主动触发集群拓扑刷新
  可在应用中添加定时任务或事件触发逻辑，主动调用客户端的节点刷新方法：

  // 主动刷新集群节点列表，获取最新拓扑
  client.refreshNodes();
  

  调用后客户端会重新从种子节点拉取集群信息，丢弃指向旧节点的所有连接，并建立新连接。

• 手动清理指定旧节点连接
  如果明确知道旧节点的地址，可直接关闭对应节点的所有连接：

  // 获取当前客户端已知的所有节点
  Node[] nodes = client.getNodes();
  for (Node node : nodes) {
      // 判断是否为旧集群节点（比如对比IP地址）
      if (isOldClusterNode(node.getHost().getAddress())) {
          // 关闭该节点的所有连接
          client.closeNode(node);
      }
  }
  

  关闭后客户端会自动从新集群节点补充连接。

二、重启应用后实现连接自动重建的关键配置 #

重启应用后无法自动连接新集群，通常是初始化配置问题，需注意以下几点：

• 使用集群种子节点列表而非单个节点
  初始化客户端时，必须传入新集群的种子节点地址列表（而非旧集群的单个节点IP），客户端启动时会自动通过种子节点获取完整集群拓扑：

  Host[] seedHosts = new Host[] {
      new Host("new-seed-node-1", 3000),
      new Host("new-seed-node-2", 3000)
  };
  AerospikeClient client = new AerospikeClient(policy, seedHosts);
  

  推荐使用云端集群提供的DNS解析地址，集群重建后DNS会自动指向新节点，无需修改代码。

• 配置合理的重试策略
  在ClientPolicy中设置重试参数，确保连接失败时自动重试：

  policy.retryPolicy = new RetryPolicy();
  policy.retryPolicy.maxRetries = 3; // 连接失败后重试3次
  policy.retryPolicy.sleepBetweenRetries = 1000; // 每次重试间隔1秒
  

• 确认网络连通性
  检查应用服务器与新集群节点的网络策略，确保开放Aerospike默认端口（3000），避免防火墙或安全组拦截导致连接失败。

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