com.alicloud.openservices.tablestore.model

类 CustomRetryStrategy

java.lang.Object

com.alicloud.openservices.tablestore.model.CustomRetryStrategy

所有已实现的接口:

RetryStrategy

public class CustomRetryStrategy
extends Object
implements RetryStrategy

TableStore SDK支持自定义重试逻辑RetryStrategy, 重试逻辑用于判断在发生异常时是否需要重试, 并给出本次重试的时间间隔. DefaultRetryStrategy为TableStore SDK默认的重试逻辑.

构造器概要

构造器

构造器和说明
CustomRetryStrategy()
CustomRetryStrategy(long timeout, TimeUnit unit)
CustomRetryStrategy(long timeout, TimeUnit unit, boolean retryUnIdempotentWriteOperation)

方法概要

限定符和类型	方法和说明
RetryStrategy	clone() 返回一个同类型且尚未重试的RetryStrategy对象。
int	getRetries() 返回当前重试的次数
long	nextPause(String action, Exception ex) 若返回0，代表不可重试，否则返回本次重试的间隔时间。
boolean	shouldRetry(String action, Exception ex) 幂等操作： 本策略中，认为所有读相关的操作是幂等的，而所有写相关的操作会被认为是非幂等的。

从类继承的方法 java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

CustomRetryStrategy

public CustomRetryStrategy()

CustomRetryStrategy

public CustomRetryStrategy(long timeout,
                           TimeUnit unit)

CustomRetryStrategy

public CustomRetryStrategy(long timeout,
                           TimeUnit unit,
                           boolean retryUnIdempotentWriteOperation)

参数:

timeout - 重试超时时间

unit - 超时时间单位

retryUnIdempotentWriteOperation - 是否在可能非幂等的情况下重试写操作

方法详细资料

clone

public RetryStrategy clone()

从接口复制的说明: RetryStrategy

返回一个同类型且尚未重试的RetryStrategy对象。

指定者:

clone 在接口中 RetryStrategy

覆盖:

clone 在类中 Object

返回:

同类型且尚未重试的RetryStrategy对象。

getRetries

public int getRetries()

从接口复制的说明: RetryStrategy

返回当前重试的次数

指定者:

getRetries 在接口中 RetryStrategy

返回:

当前重试的次数

shouldRetry

public boolean shouldRetry(String action,
                           Exception ex)

幂等操作： 本策略中，认为所有读相关的操作是幂等的，而所有写相关的操作会被认为是非幂等的。 重试策略，规则为： 1. 若异常为TableStoreException，则明确收到了服务端返回的异常，通过shouldRetryWithOTSException判断是否可重试。 特别的是，对于batch操作部分行失败的情况，仅当所有失败行都可重试时，才会进行重试。 2. 若异常为ClientException，一般为网络错误等，没有收到服务端响应，此时只重试幂等操作。

参数:

action - 操作名，比如"ListTable"、"GetRow"、"PutRow"等

ex - 上次访问失败的错误信息、为ClientException或OTSException

返回:

nextPause

public long nextPause(String action,
                      Exception ex)

若返回0，代表不可重试，否则返回本次重试的间隔时间。 重试间隔的基础值(base)，会随着重试次数倍增，最大不超过MAX_BASE。 为了请求的平滑性考虑，实际的重试间隔会在base基础上做一些随机的浮动。

指定者:

nextPause 在接口中 RetryStrategy

参数:

action - 操作名，比如"ListTable"、"GetRow"、"PutRow"等

ex - 上次访问失败的错误信息、为ClientException或TableStoreException

返回: