从cassandra-driver-core(3.4.0)迁移至java-driver-core(4.14.1)，求PoolingOptions替代方案

在Java Driver 4.x（比如你用的4.14.1）里，确实没有直接对应3.x中PoolingOptions的类——官方把连接池的配置逻辑拆分成了更细粒度的配置项，以及提供了自定义扩展的接口，具体可以这么处理：

• 通过配置文件/代码配置核心连接池参数
  4.x用DriverConfig统一管理所有驱动配置，连接池的核心参数都可以通过配置项设置，对应3.xPoolingOptions的常见配置：

  • 本地节点的连接数：对应配置项basic.connection-pool.local.size（替代3.x的setCoreConnectionsPerHost(HostDistance.LOCAL, ...)和setMaxConnectionsPerHost(HostDistance.LOCAL, ...)，4.x里本地节点的核心与最大连接数合并为一个配置）
  • 远程节点的连接数：对应basic.connection-pool.remote.size（替代3.x的远程节点连接数配置）
  • 获取连接的超时时间：对应basic.connection-pool.timeout.get（替代3.x的setPoolTimeoutMillis(...)）

  如果用代码硬编码配置，可以这么写：

  DriverConfigLoader configLoader = DriverConfigLoader.programmaticBuilder()
      // 设置本地节点连接数
      .withInt("basic.connection-pool.local.size", 4)
      // 设置远程节点连接数
      .withInt("basic.connection-pool.remote.size", 2)
      // 设置获取连接超时为5秒
      .withDuration("basic.connection-pool.timeout.get", Duration.ofSeconds(5))
      .build();
  
  CqlSession session = CqlSession.builder().withConfigLoader(configLoader).build();
  

• 自定义连接池实现（特殊需求场景）
  如果业务需要更复杂的连接池逻辑（比如自定义连接复用策略、监控统计），可以实现ConnectionPoolFactory接口替换默认的连接池工厂：

  public class CustomConnectionPoolFactory implements ConnectionPoolFactory {
      @Override
      public ConnectionPool create(Node node, DriverContext context) {
          // 这里实现自己的连接池逻辑，比如基于现有DefaultConnectionPool扩展
          return new DefaultConnectionPool(node, context);
      }
  }
  
  // 初始化Session时指定自定义工厂
  CqlSession session = CqlSession.builder()
      .withConnectionPoolFactory(new CustomConnectionPoolFactory())
      .build();
  

• 迁移注意点

  • 4.x默认连接数配置和3.x不同：4.x本地默认4个连接，远程默认2个；3.x本地默认2个，远程默认1个，需根据业务负载调整。
  • 超时参数在4.x里用Duration类型，而3.x是毫秒值，注意单位转换。
  • 4.x不再区分核心连接数和最大连接数（同一节点类型下），统一用一个size配置，驱动会自动维护连接数量在该值左右。

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