package com.example.demo.retry;
import java.util.concurrent.atomic.AtomicInteger;
/**
* 模拟rpc 远程失败后重试，
* 有的busi方法是通过aop拦截器，拦截器中配置重试次数，读取注解中重试次数后，完成重试，也可以对重试加入sleep间隔
*/
public class RetryClz {
public static void rpc(){
throw new RuntimeException("rpc error："+count.get());
}
public static void busi(){
//方法内部进行重试
int no = count.addAndGet(1);
try{
if(no<=max){
rpc();
}
}catch (Exception e){
System.out.println(e.getMessage());
long s = no*1000;
System.out.println("retry："+no+" ,sleep "+s+" ms");
busi();
}
}
//max 重试次数,可以是环境变量，可以是注解的参数，可以是apollo配置==
private static int max = 3;
private static AtomicInteger count = new AtomicInteger(0);
public static void main(String[] args) {
//1.主业务方法调用busi（）方法,busi（）内部调用rpc远程方法，完成重试，重试次数可配
busi();
}
}
随笔：模拟rpc远程调用失败的重试
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
