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

默认情况下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);

我不确定是否在上面做了正确的事情？让我知道它看起来是否正确。

最佳答案

查看JavaDocs for Pelops时，您将使用另一个Pelops.addPool()方法，该方法允许您提供CommonsBackedPool.Policy实例的控制对象。

关于java - 如何使用Pelops客户端每个节点与Cassandra数据库建立40个连接？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/16347867/