java - 如何使用 Pelops 客户端每个节点与 Cassandra 数据库建立 40 个连接？

Question

默认情况下Pelops will have 20 connections per node-

我正在考虑将其修改为40 connections per node. 那么我怎么能在 Pelops 中做到这一点呢？目前，我正在创建这样的池-

private void createPool() {
    Pelops.addPool(getPoolName(), getCluster(), getKeyspace());

}

/**
 * Gets the cluster information
 * 
 * @return
 */
private Cluster getCluster() {

    Config casconf = new Config(ModelConstants.CASSANDRA_PORT, true, 0); 

    Cluster cluster= new Cluster(nodes, casconf, ModelConstants.NODE_DISCOVERY);

    return cluster; 
}

/**
 * Get the keyspace name
 * 
 * @return
 */
public String getKeyspace() {
    return keyspace;
}

/**
 * Get the pool name
 * 
 * @return
 */
public String getPoolName() {
    return poolName;
}

谁能为此提供一个示例，以便我可以将其修改为每个节点保持 40 个连接？谢谢您的帮助。

更新代码：-

    CommonsBackedPool.Policy pt = new Policy();
    pt.setMaxActivePerNode(40);

    OperandPolicy op = new OperandPolicy();

    Pelops.addPool(getPoolName(), getCluster(), getKeyspace(), pt, op);

我不确定我在上面做的是否正确？让我知道它是否正确。

Answer 1

查看 Pelops的JavaDocs，您将使用另 Pelops.addPool()一种方法，该方法允许您提供CommonsBackedPool.Policy的实例，该实例用于控制它。