我们在初始化连接的时候,没有retry策略,在初始化和cassandra集群的连接时,设置socketOption如下:
SocketOptions socketOptions = new SocketOptions(); socketOptions.setKeepAlive(configuration.isKeepAlive()); socketOptions.setConnectTimeoutMillis(configuration.getConnectTimeoutMillis()); socketOptions.setReadTimeoutMillis(configuration.getReadTimeoutMillis());
ReadTimeoutMillis这个设置是有效的。我们测试的过程是
1、建立和cassandra集群的连接
2、中断cassandra驱动所在的客户端和集群的网络,发生读取的请求
3、在ReadTimeoutMillis设置的超时时间左右会有超时的异常。
但是我没有找到类似 WriteTimeoutMillis的参数,当我们在中断网络之后,发生写入请求,这个超时时间有变化,一般在20s~30s之间。
我想知道有没有类似ReadTimeoutMillis的 WriteTimeoutMillis参数,可以再socketOption里面设置?