如果发生读取超时，如何在Cassandra中重试

Question

在我的生产Cassandra集群（10个节点）中，我经常获得ReadTimeoutException。因此，为了在我的本地开发环境（四个节点的Cassandra集群）中重现这个问题，我运行了我的代码，然后停止了两个CassandRadaemon。我有以下例外

线程“main”com.datastax.driver.core.exceptions.unavailableException:在com.datastax.driver.core.exceptions.unavailableException.copy（UnavailableException.copy（UnavailableException.java：79）在com.datastax.driver.core.defailableException.java）在com.datastax.driver.core.defailableExceptionExceptionExceptionException在com.datastax.driver.core.arraybackedResultset.java:245).在在com.datastax.driver.core.exceptions.unavailableException.copy（unavailableException.java:79)在com.datastax.driver.core.responses$error.asException(response.java:94)在com.datastax.driver.core.arrayBackedResultSet$multipage$1.onset(arrayBackedResultSet:352)在.java:45)在com.datastax.driver.core.requestHandler$screstativeExecution.setfinalResult(requestHandler.java:748)在com.datastax.driver.core.requestHandler$screstativeExecution.onset(requestHandler.java:587)在com.datastax.driver.core.connection$dispatcher.channelRead0(connection.java.connection$dispatcher.channelRead0.channel.AbstractChannelHandlio.netty.channel.abstractChannelContext.java:339)在io.netty.channel.abstractChannelHandlerContext.firechannelRead（AbstractChannelHandlerContext.java:324)在io.netty.handler.timeout.idlestateHandler.java:254)在io.netty.channel.abstractChannelContext.java:254)，在io.netty.channel.abstractChannelContext.java:339)在codec.messageTomessageDecoder.channelRead（MessageTomessageDecoder.java:103)在io.netty.channel.abstractChannelHandlerContext.invokeChannelRead（AbstractChannelHandlerContext.java:339)在io.netty.channel.abstractChannelContext.fireChannelRead（AbstractChannelHandlerContext.java:324)在：339）在io.netty.channel。AbstractChannelHandlerContext.FireChannelRead（AbstractChannelHandlerContext.java:324)在io.netty.channel.defaultChannelPipeline.fireChannelRead（DefaultChannelPipeline.java:847)在io.netty.channel.nio.abstractNiobyTechannel.java:131)在io.netty.channel.nio.abstractNiobyTechannel.java:131)在O.nioEventLoop.ProcessSelectedKeys(NioEventLoop.java:382)(io.netty.channel.nio.nioEventLoop.run(NioEventLoop.java:354)(io.netty.util.concurrent.singleThreadEventExecutor$2.run（singleThreadEventExecutor.java(thread.java:745)(java.lang.thread.run（thread.java.executor.111)由：.响应$错误$1.decode（responses.java:37)在com.datastax.driver.core.message$protocoldecoder.decode（message.java:213)在com.datastax.driver.core.message$protocoldecoder.decode（message.java:204)在io.netty.handler.codec.messageMessageDecoder.channelRead（messageTomessageDecoder.java:89)...还有13个

我的Cassandra连接代码如下所示

SocketOptions so = new SocketOptions();
so.setReadTimeoutMillis(Integer.MAX_VALUE);
so.setConnectTimeoutMillis(sockettimeoutinmillis);

Builder builder = new Cluster.Builder().
                addContactPoints(connectionpoints).withPort(port);

builder.withPoolingOptions(new PoolingOptions().setCoreConnectionsPerHost(HostDistance.LOCAL, new PoolingOptions().getMaxConnectionsPerHost(HostDistance.LOCAL)));

cluster = builder
               .withRetryPolicy(DowngradingConsistencyRetryPolicy.INSTANCE)
               .withReconnectionPolicy(new ConstantReconnectionPolicy(10000L))
               .build();

session=cluster.connect();

我在连接到Cassandra时提供了重试策略，那么为什么我会遇到这样的html" target="_blank">异常？我还没有编写任何特定的代码来处理ReadTimeoutException和重试。是否需要任何特定的代码或处理？

Answer 1

如果需要自定义逻辑来处理读/写超时和UnavailableExceptions，可以实现自己的自定义RetryPolicy。

您可以重写onreadtimeout方法，使其完全符合您的要求。

但是，您提供的异常是unavailableException，这是一个cassandra协调器，它告诉您没有副本可以完成您的查询（在本例中，意味着拥有您试图读取的数据的所有副本都用C*标记下来），因此它甚至没有尝试，并且很快就失败了。在这种情况下，重试可能不会提供太多价值，因为您可能会经历相同的结果。根据您指定的RetryPolicy(DowngradingConsistencyRetryPolicy)，可能发生的情况是遇到了ReadTimeout或UnavailableException，并且RetryPolicy在较低的ConsistencyLevel(ONE)再次尝试，但仍然失败，因为遇到了另一个UnavailableException。

有几个问题可能有助于你澄清：

1. 您正在使用的密钥空间使用什么复制因子？在开发环境中提到4个节点。如果有1个节点宕机，而RF为1，则可能有25%的查询会遇到UnavailableException。
2. 您用什么一致性级别查询？如果您没有提供一个，那么无论如何您总是在使用'one'，所以降级ConsistencyRetryPolicy可能对您没有好处。