我正在使用datastax cassandra 2.1驱动程序，并以8000 IOPS的速率执行读/写操作。我使用了池选项来配置我的会话，并使用单独的会话进行读写，每个会话都以连接点的形式连接到群集中的另一个节点。这可以说5分钟，但是之后我得到了很多异常，例如：
失败：com.datastax.driver.core.exceptions.NoHostAvailableException：尝试查询的所有主机均失败（尝试：/10.0.1.123:9042（com.datastax.driver.core.TransportException：[/10.0.1.123： [9042]连接已关闭），/ 10.0.1.56:9042（com.datastax.driver.core.exceptions.DriverException：尝试获取可用连接时超时（您可能希望增加每个主机连接的驱动程序数量）） ）
有人可以在这方面帮助我吗？
异常要求我增加每个主机的连接数，但是可以为此参数设置多少值？我也无法设置CoreConnectionsPerHost超过2，因为它抛出异常，说2是最大值。
这就是我创建每个读/写会话的方式。
PoolingOptions poolingOpts = new PoolingOptions();
poolingOpts.setCoreConnectionsPerHost(HostDistance.REMOTE, 2);
poolingOpts.setMaxConnectionsPerHost(HostDistance.REMOTE, 200);
poolingOpts.setMaxSimultaneousRequestsPerConnectionThreshold(HostDistance.REMOTE, 128);
poolingOpts.setMinSimultaneousRequestsPerConnectionThreshold(HostDistance.REMOTE, 2);
cluster = Cluster
.builder()
.withPoolingOptions( poolingOpts )
.addContactPoint(ip)
.withRetryPolicy( DowngradingConsistencyRetryPolicy.INSTANCE )
.withReconnectionPolicy( new ConstantReconnectionPolicy( 100L ) ).build();
Session s = cluster.connect(keySpace);
您的问题可能实际上不出在您的代码或连接方式中。如果您说问题是在几分钟后发生的，那可能只是您的群集正变得超载，试图处理数据的接收而无法跟上。这种情况的典型征兆是，当您开始在cassandra system.log文件中看到JVM垃圾收集“ GC”消息时，太多的小垃圾堆单独地与大垃圾堆在一起可能意味着传入的客户端未响应导致这种情况。设想。在开始查看代码之前，请首先验证您的日志中没有出现太多此类事件。这是大型GC事件的一个很好的示例：
INFO [ScheduledTasks：1] 2014-05-15 23：19：49,678 GCInspector.java（第116行）GC用于ConcurrentMarkSweep：2个集合的2896毫秒，已使用310563800；最大值是8375238656
连接到群集时，有一些建议，其中每个真实群集仅包含一个Cluster对象。根据我在下面链接的文章（如果您已经研究过，则表示歉意）：
http://www.datastax.com/documentation/developer/java-driver/2.1/java-driver/fourSimpleRules.html
当您进行大量读取时，setFetchSize如果可以将其应用于您的代码，我绝对建议您也使用
供您参考，以备不时之需。
希望这可以帮助。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句