如何使用pelops客户机在每个节点上有40个到cassandra数据库的连接?

yiytaume  于 2021-06-14  发布在  Cassandra
关注(0)|答案(1)|浏览(268)

默认情况下 Pelops will have 20 connections per node -
我想把它改成 40 connections per node . 我怎么能在佩洛普斯做到呢?目前,我正在创建这样的池-

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个连接吗?谢谢你的帮助。
更新code:-

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

    OperandPolicy op = new OperandPolicy();

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

我不确定我是否做了正确的事?如果看上去合适,请告诉我。

4xy9mtcn

4xy9mtcn1#

查看用于pelops的javadocs,您将使用另一个 Pelops.addPool() 方法,该方法允许您提供CommonBackedPool.policy的示例,该示例控制该策略。

相关问题