通過工廠模式創建鏈接

 static {// 創建連接池工廠BasePooledObjectFactory<MilvusServiceClient> factory = new BasePooledObjectFactory<MilvusServiceClient>() {@Overridepublic MilvusServiceClient create() throws Exception {return new MilvusServiceClient(ConnectParam.newBuilder().withHost(Consist.MILVUS_HOST).withPort(Consist.MILVUS_PORT).withAuthorization(Consist.MILVUS_USERNAME, Consist.MILVUS_PASSWORD) .build());}@Overridepublic PooledObject<MilvusServiceClient> wrap(MilvusServiceClient obj) {return new DefaultPooledObject<>(obj);}};

配置連接池

  // 配置連接池GenericObjectPoolConfig<MilvusServiceClient> config = new GenericObjectPoolConfig<>();config.setMaxTotal(Consist.MAX_TOTAL);config.setMaxIdle(Consist.MAX_IDLE);config.setMinIdle(Consist.MIN_IDLE);config.setMaxWaitMillis(Consist.MAX_WAIT_MILLIS);pool = new GenericObjectPool<>(factory, config);

從連接池中獲取連接，并設置超時設置

 public static MilvusServiceClient borrowClient(long timeout) throws Exception {return pool.borrowObject(timeout);}

歸還連接

  public static void returnClient(MilvusServiceClient client) {pool.returnObject(client);}

關閉鏈接池

  public static void close() {pool.close();}