现在都是微服务化访问,某系统访问另一系统时,总有一些公用参数需要处理,另外还需要对访问情况进行日志打印。
调用的服务是dubbo服务,如何封装这一些公共参数而不是每次调用方法时都做反复的事呢?
三个方法:
1. 写一个公共方法,在调用rpc方法前和方法后,都进行调用;
简单直接且易读,且想加就加更灵活。不好处就是每个地方都要重复写这两段公用代码,不简洁。
2. 使用反射方法,进行调用dubbo方法,在调用前调用后,都进行参数组装,并将日志打印好。
好处是每次只需调用一个反射封装方法,就能完成所有工作,简单实用。坏处是方法被反射调用后,不直观,无法使用ide的语法检查快速发现潜在问题。
3. 使用切面进行设值处理。
好处是代码无侵入,简洁明了。坏处是新来的同学不易理解一些运行原理,不能很好利用切面辅助,另外,切面规则需要保持一致,否则无法实现处理。
来几个实现的例子吧!
使用公共方法:
// 公用封装参数方法,四处调用,当然这里是不完整的封装,可能还需要更复杂的代码侵入 public static void wrapCommonField(Object param) { ThreadlocalVar session = ThreadlocalVar.getVar(); if (null != param && (param instanceof BaseDTO)) { BaseDTO basePara = (BaseDTO) param; if (null != session) { basePara.setIp(session.getIp()); if(session.getUserId() != null) { basePara.setUserId(session.getUserId()); } } } // ... } // 调用,在调用service方法时,先鲁一段该调用代码 public static void main(String[] args) { RpcServiceA serviceA = new RpcServiceA(); Object param = ...; wrapCommonField(param); // ... }
使用反射:
// 公用反射方法 public static <T> T callMethod(Object service, String mName, Object param) { ThreadlocalVar session = ThreadlocalVar.getVar(); if (null != param && (param instanceof BaseDTO)) { BaseDTO basePara = (BaseDTO) param; if (null != session) { basePara.setIp(session.getIp()); if(session.getUserId() != null) { basePara.setUserId(session.getUserId()); } } } Class<?> rpcServiceClass = service.getClass(); logger.info("call method:{},param:{}", mName, param); try { Method method = rpcServiceClass.getMethod(mName, new Class[] { param.getClass() }); ResponseResult<T> re = (ResponseResult<T>) method.invoke(rpcService, new Object[] { param }); logger.info("result:{}", re); if (null == re || !"1111".equals(re.getCode())) { throw new RuntimeException(re.getCode(), re.getMsg()); } return re.getData(); } catch (NoSuchMethodException | InvocationTargetException e) { logger.error("exception:{}", e); throw e; } catch (SecurityException | IllegalAccessException | IllegalArgumentException e) { logger.error("exception:{}", e); throw e; } } // 调用 public static void main(String[] args) { RpcServiceA serviceA = new RpcServiceA(); Object param = ...; callMethod(serviceA, "giveMeFive", param); // ... }
使用切面:
// 完整切面类,独立 @Order(1) @Component @Aspect public class SignLoginAop { private Logger logger = LoggerFactory.getLogger(getClass()); public static final String CALLAPI_POINT = "execution(* com.xx.api.web.d.*.*(..))"; @Around(CALLAPI_POINT) public Object validSign(ProceedingJoinPoint pjp) throws NoSuchMethodException, SecurityException, KydException { Object retVal = null; Object[] args = pjp.getArgs(); Object param = (null != args && args.length > 0) ? args[0] : null; if (null != param && (param instanceof BaseDTO)) { BaseDTO basePara = (BaseDTO) param; ThreadlocalVar session = ThreadlocalVar.getSession(); BaseDTO basePara = (BaseDTO) param; if (null != session) { basePara.setIp(session.getIp()); if(session.getUserId() != null) { basePara.setUserId(session.getUserId()); } } } Signature signature = pjp.getSignature(); try { logger.info("call method {}, param:{}", signature, args); retVal = pjp.proceed(args); logger.info("end method {}, retVal:{}", signature, retVal); } catch (Exception e) { logger.error("发生了错误:", e); throw e; } //... } } // 使用,独立写业务
性能对比!额,就不去收集对比数据了。第一个自然最快。第二、三个不相伯仲!
封装是为了代码更简洁!哟豁。