需求:项目增加幂等
场景:
1.三个项目:a 、b、c
2.a项目加幂等
3.b项目dubbo调用项目a的时候超时没有获取返回结果,增加重试机制(非立即重试,3min or 5min 后重试)
4.c项目是一个异步的job项目,用来接收mq,异步处理,管理task等。
方案:
1.a项目设置请求流水id,将请求先存入redis缓存,处理完成之后更新redis中的状态,同一个流水id认为是重复提交,不进行业务处理,直接返回redis中的状态
2.b项目捕获调用a项目的超时异常,存入redis队列
3.c项目启动两个task,task1用来获取redis队列里面的信息,落库。task2用来扫库,及重试。
重点:
1.c项目只是异步接口消息没有业务处理逻辑
2.task2重试的时候需要通过dubbo接口调用b来进行重新发起请求,及后续处理。
这里重点分享一下通过反射机制调用dubbo接口(map为请求参数)
String inter = "com.xxx.xxx.xxx.xxx.xxx.xxx";
Class<?> mClass = Class.forName(inter);
Method method = mClass.getMethod("methodNamexxx",new Class[]{String.class});
Object object = method.invoke(mClass.newInstance(),JSON.toJSONString(map));
圈重点:
1.inter需要是serviceImpl实现类,如果是interface的话,会报
Caused by: java.lang.NoSuchMethodException: com.xxx.xxx.xxx.xxx.xxx.<init>()
2.invoke(Object obj,Object... args) 这里的obj需要newInstance()一下,否则会报
java.lang.IllegalArgumentException: object is not an instance of declaring class
调用dubbo接口的写法:(map为请求参数)
String inter = "com.xxx.xxx.xxx.IxxxService";
String methodName = "xxxxx";
Class<?> mClass = Class.forName(inter);
Map<String,Object> map = new HashMap<>();
AbstractApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
Object obj = context.getBean(this.getBeanName(inter));
Method method = mClass.getMethod(methodName,new Class[]{Object.class});
Object object = method.invoke(obj,JSON.toJSON(map));
public String getBeanName(String str){
String name = str.substring(str.lastIndexOf(".")+2,str.length());
name = name.substring(0,1).toLowerCase() + name.substring(1,name.length());
return name;
}
通过解析inter获取beanName,通过spring获取bean的方式获取对象进行反射调用。
将interface及method配置到数据库中,就能实现不用改动代码进行调用的操作了。