随着业务的增长,我们不得不面临一个问题:进行业务的拆分。随之而来的就是微服务的诞生。微服务解决了我们以前难以解决的痛点。以及增加了我们编码的难度,我们不在需要关心以前的各种各样的业务代码之间的耦合,可以专心开发自己的业务代码。但是微服务也并不是全是优点。就拿我现在的编码情况来看,随着调用服务越来越多,出问题的概率也就越来越大。如果只是在本地环境还好我们可以通过debug来查看问题。但是产品一旦上线。一旦某个服务出现脱机,我们就需要发给很大的力气一个一个排查是哪里的调用链出现问题了。当然这里的问题可以用现在很多开源的调用链追踪的开源包。但是引入这个我们是不是又得花精力去维护这个项目。如果我们现在做的是一个非常大的项目还好,但是我相信百分之85的用户是还是处于中小项目之中。那么我们如何通过自己的方式来解决这个问题?
AOP简介
AOP的全称是 Aspect-Oriented Programming,即面向切面编程(也称面向方面编程)。它是面向对象编程(OOP)的一种补充,目前已成为一种比较成熟的编程方式。
在传统的业务处理代码中,通常会进行事务处理、日志记录等操作。虽然OOP可以通过组合或者继承的方式来达到代码的重用,但如果要实现某个功能(如日志记录),同样的代码仍然会分散到各个方法中。这样如果想要关闭某个功能,或者对其进行修改,就必须要修改所有的相关方法。这不但增加了开发人员的工作量,而且提高了代码的出错率。
为了解决这一问题,AOP的思想随之产生。AOP采取横向抽取机制,将分散在各个方法中的重复代码提取出来,然后在程序编译或运行时,再将这些提取出来的代码应用到需要执行的地方。这种采用横向抽取机制的方式,采用传统的OOP思想显然是无法办到的,因为OOP只能实现父子关系的纵向的重用。虽然AOP是一种新的编程思想,但不是OOP的替代品,它只是OOP的延伸和补充 。
-
Aspect(切面):在实际应用中,切面通常是指封装的用于横向插入系统功能(如事务)的类,如上图的Aspect。该类要被 Spring 容器识别为切面,需要在配置文件中通过元素指定。
-
Joinpoint(连接点):在程序执行过程中的某个阶段点,它实际上是对象的一个操作,例如方法的调用或异常的抛出。在 Spring AOP中,连接点就是指方法的调用。
-
Pointcut(切入点):是指切面与程序流程的交叉点,即那些需要处理的连接点,如下图程序流程所示。通常在程序中,切入点指的是类或方法名,如某个通知要应用到所有以add开头的方法中,那么所有满足这一规则的方法都是切入点。
-
Advice(通知/增强处理):AOP 框架在特定的切入点执行的增强处理,即在定义好的切入点处所要执行的程序代码。可以将其理解为切面类中的方法,它是切面的具体实现。
-
Target Object(目标对象):是指所有被通知的对象,也称为被增强对象。如果AOP框架采用的是动态的AOP实现,那么该对象就是一个被代理对象。
-
Proxy(代理):将通知应用到目标对象之后,被动态创建的对象。
-
Weaving(织入):将切面代码插入到目标对象上,从而生成代理对象的过程。
这里盗了一张图:
1240732-20171028155526461-2018964464.png
aop的事情差不多说完了,接下来我们如何通过他来进行我们的代码简化工作。首先在动手之前我们应该好好想想,这件事应该如何解决。
在解决一个问题时我们首先应该想到的是我们如何分解问题。如何将一个看似庞大的事情一步一步细化。
问题:远程调用各种服务时,我们可能会面临各种各样的问题:网络中断,服务商脱机....
分析:
- 既然调用会遇到各种各样的问题,那么我们能不能再每一个调用的服务上增加一个标识,用来标识我们会需要调用这个远程服务。
- 我们通过spring给我们提供好了实现,对打上标识的方法或类进行一个环绕处理。
- 我们捕获对应的异常,然后统一的进行处理。大概的思路就是这样。
开始代码:
定义我们的标识:这里采用 注解的方式。
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface AspectException {
String className() default "";
String description() default "";//这里的描述是用来对每一个远程调用,描述自己特殊性
}
对标识了注解的类或方法进行统一处理
@Aspect
@Component
public class ExceptionUtils {
@Pointcut("@annotation(cn.com.huijin.cts.common.annotation.AspectException)")
public void pointCut(){}
@Around("pointCut()")
public Object around(ProceedingJoinPoint point) throws Throwable {
try{
return point.proceed();
}catch (SocketTimeoutException e){
throw new CommonException("time out:"+exceptionInfo(point));
}catch (UnknownHostException e) {
throw new CommonException("Connection exception:"+exceptionInfo(point));
}catch (Exception e){
throw new CommonException("other exception"+exceptionInfo(point));
}
}
public String exceptionInfo(ProceedingJoinPoint point){
ExceptionEntity exceptionEntity = new ExceptionEntity();
MethodSignature signature = (MethodSignature) point.getSignature();
Method method = signature.getMethod();
AspectException annotation = method.getAnnotation(AspectException.class);
if(null != annotation){
exceptionEntity.setDescription(annotation.description());
}
String className = point.getTarget().getClass().getName();
String methodName = signature.getName();
exceptionEntity.setClassName(className);
exceptionEntity.setMethodName(methodName);
//请求的参数
Object[] args = point.getArgs();
String params = JSON.toJSONString(args[0]);
exceptionEntity.setParams(params);
return String.format("调用描述:异常信息[%s]==调用类[%s]==调用方法[%s]==调用参数[%s]",
exceptionEntity.getDescription(),exceptionEntity.getClassName(),
exceptionEntity.getMethodName(),exceptionEntity.getParams());
}
}
这里我抛出的是一个自定义的异常CommonException 大家也可以直接用RuntimeException这里没有什么区别。
剩下的只是需要在我们需要调用的远程端打上标识即可
大致就是这样的效果了。
网友评论