我在cassandra上找不到池选项的任何配置（使用scala，但我可以用java示例来管理）。以前有人做过吗？编辑：我将java驱动程序与scala extra一起使用。我的目标是优化密集io应用程序（db读取查询）。
6ljaweal1#
因为您处于jvm环境中，所以可以通过scala加载工作的java配置。
puruo6ea2#
您需要按照驱动程序文档中的描述进行调整。Cassandra2.0使用的协议v2对飞行中请求的数量有限制，所以您只能增加从驱动程序到cassandra打开的连接的数量。默认情况下，对于协议v2，它至少有2个连接，最多有2个连接。您可以使用以下代码将其最小值增加到4，最大值增加到10：
PoolingOptions poolingOptions = new PoolingOptions(); poolingOptions .setConnectionsPerHost(HostDistance.LOCAL, 4, 10) .setConnectionsPerHost(HostDistance.REMOTE, 2, 4);
创建群集/会话对象时，应添加以下选项：
Cluster cluster = Cluster.builder() .withContactPoints("127.0.0.1") .withPoolingOptions(poolingOptions) .build();
2条答案
按热度按时间6ljaweal1#
因为您处于jvm环境中，所以可以通过scala加载工作的java配置。
puruo6ea2#
您需要按照驱动程序文档中的描述进行调整。Cassandra2.0使用的协议v2对飞行中请求的数量有限制，所以您只能增加从驱动程序到cassandra打开的连接的数量。默认情况下，对于协议v2，它至少有2个连接，最多有2个连接。您可以使用以下代码将其最小值增加到4，最大值增加到10：
创建群集/会话对象时，应添加以下选项：