Java编程重试重试机制实例详解

　　

本文研究的主要的是Java编程重试重试机制实例详解,分享了相关代码示例,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下

　　

1,业务场景
　　

　　

应用中需要实现一个功能:需要将数据上传到远程存储服务,同时在返回处理成功情况下做其他操作。这个功能不复杂,分为两个步骤:第一步调用远程的休息服务逻辑包装给处理方法返回处理结果;第二步拿到第一步结果或者捕捉异常,如果出现错误或异常实现重试上传逻辑,否则继续逻辑操作。

　　

2,常规解决方案演化
　　

　　

1) try-catch-redo简单重试模式:
　　

　　

包装正常上传逻辑基础上,通过判断返回结果或监听异常决策是否重试,同时为了解决立即重试的无效执行(假设异常是有外部执行不稳定导致的),休眠一定延迟时间重新执行功能逻辑。

　　 　　 　　公共空间commonRetry (Map<字符串,Object>dataMap)抛出InterruptedException { 　　Object> Map<字符串;paramMap=Maps.newHashMap (); 　　paramMap。把(“表”、“creativeTable”); 　　paramMap。把(“ds”、“20160220”); 　　paramMap。把(“dataMap”, dataMap); 　　布尔结果=false; 　　尝试{ 　　结果=uploadToOdps (paramMap); 　　如果结果(!){ 　　thread . sleep (1000); 　　uploadToOdps (paramMap);//一次重试 　　} 　　}捕捉(异常e) { 　　thread . sleep (1000); 　　uploadToOdps (paramMap);//一次重试 　　} 　　} 　　 　　

2) try-catch-redo-retry战略策略重试模式:
　　

　　

上述方案还是有可能重试无效,解决这个问题尝试增加重试次数retrycount以及重试间隔周期区间,达到增加重试有效的可能性。

　　 　　 　　公共空间commonRetry (Map<字符串,Object>dataMap)抛出InterruptedException { 　　Object> Map<字符串;paramMap=Maps.newHashMap (); 　　paramMap。把(“表”、“creativeTable”); 　　paramMap。把(“ds”、“20160220”); 　　paramMap。把(“dataMap”, dataMap); 　　布尔结果=false; 　　尝试{ 　　结果=uploadToOdps (paramMap); 　　如果结果(!){ 　　reuploadToOdps (paramMap 1000 l 10);//延迟多次重试 　　} 　　}捕捉(异常e) { 　　reuploadToOdps (paramMap 1000 l 10);//延迟多次重试 　　} 　　} 　　 　　

方案一和方案二存在一个问题:正常逻辑和重试逻辑强耦合,重试逻辑非常依赖正常逻辑的执行结果,对正常逻辑预期结果被动重试触发,对于重试根源往往由于逻辑复杂被淹没,可能导致后续运维对于重试逻辑要解决什么问题产生不一致理解。重试正确性难保证而且不利于运维,原因是重试设计依赖正常逻辑异常或重试根源的臆测。

　　

3,优雅重试方案尝试:
　　

　　

那有没有可以参考的方案实现正常逻辑和重试逻辑解耦,同时能够让重试逻辑有一个标准化的解决思路?答案是有:那就是基于代理设计模式的重试工具,我们尝试使用相应工具来重构上述场景。
　　

　　

1)应用命令设计模式解耦正常和重试逻辑:
　　

　　

命令设计模式具体定义不展开阐述,主要该方案看中命令模式能够通过执行对象完成接口操作逻辑,同时内部封装处理重试逻辑,不暴露实现细节,对于调用者来看就是执行了正常逻辑,达到解耦的目标,具体看下功能实现。(类图结构)

　　

癑ava编程重试重试机制实例详解"

　　

IRetry约定了上传和重试接口,其实现类OdpsRetry封odp装上传逻辑,同时封装重试机制和重试策略。与此同时使用恢复方法在结束执行做恢复操作。

　　

而我们的调用者LogicClient无需关注重试,通过重试者重试实现约定接口功能,同时重试需要对重试逻辑做出响应和处理,重试具体重试处理又交给真正的IRtry接口的实现类OdpsRetry完成。通过采用命令模式,优雅实现正常逻辑和重试逻辑分离,同时通过构建重试者角色,实现正常逻辑和重试逻辑的分离,让重试有更好的扩展性。

　　

2) spring-retry规范正常和重试逻辑
　　

　　

spring-retry是一个开源工具包,目前可用的版本为1.1.2.RELEASE,该工具把重试操作模板定制化,可以设置重试策略和回退策略。同时重试执行实例保证线程安全,具体场景操作实例如下:

　　 　　 　　公共空间上传(最终Map<字符串,Object>{地图)抛出异常//构建重试模板实例 　　RetryTemplate RetryTemplate=new RetryTemplate ();//设置重试策略,主要设置重试次数 　　SimpleRetryPolicy政策=new SimpleRetryPolicy(3、集合。你们;Class

Java编程重试重试机制实例详解