sleuth+zipkin系列之异常处理（十三）

本文的异常处理分为两种，第一种讲的是zipkin原生的异常处理，第二种就是针对实际业务作异常处理的扩展，本文的重点讲的是如何根据自身的实际状况定制异常处理。

zipkin经过对span打tag，打上error的tag表示此次调用出错了。

zipkin异常处理
zipkin的默认会捕获没有被应用程序catch的异常，这是什么意思？

这句话的意思就是，加入你程序发生了错误，若是异常被你程序给捕获了，那么zipkin就会默认此次请求是成功的。

若是应用将异常一直往外抛，没有作任何处理，这就被zipkin给获取到了，那么zipkin就会默认此次请求是失败的，会打对此次请求产生的span打上error的tag .

自定义异常处理
咱们本身的应用，确定都是有统一的异常处理的，因此没有处理的异常，一直往外抛的异常能够说不多的， 有时候判断一个调用链是否成功，并非简简单单的判断这个应用程序有没有出错，有没有报异常。 至少对我来讲，我但愿看到的是这个调用链的实际执行结果，执行失败了，那么为何执行会执行失败？是参数不符合要求？ 仍是网络异常？ 仍是一些条件不符合？ 这些我都想收集到， 那么，这种状况怎么办，默认的zipkin是不会知足的。 其实要实现这种功能很简单，一个切面就能够搞定。

/**
 * @Author 张云和
 * @Date 2018/8/20
 * @Time 11:36
 */
@Aspect
@Component
@Slf4j
public class ResponseStatusAspect {
  
    @Pointcut("@annotation(org.springframework.web.bind.annotation.RequestMapping)")
    public void requestMapping() {}
    @Pointcut("@annotation(org.springframework.web.bind.annotation.PostMapping)")
    public void postMapping() {}
    @Pointcut("@annotation(org.springframework.web.bind.annotation.PutMapping)")
    public void putMapping() {}
    @Pointcut("@annotation(org.springframework.web.bind.annotation.GetMapping)")
    public void getMapping() {}
    @Pointcut("@annotation(org.springframework.web.bind.annotation.DeleteMapping)")
    public void deleteMapping() {}
    @Pointcut("@annotation(org.springframework.web.bind.annotation.PatchMapping)")
    public void patchMapping() {}
    // 全局的trace对象
    @Autowired
    Tracer tracer;
     // 针对全部Controller层的方法的切面
    @Around("requestMapping() || postMapping() || putMapping() || getMapping() || deleteMapping() || patchMapping()")
    public Object doSurround(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
         
        // 方法的执行结果
        Object result = proceedingJoinPoint.proceed();

        try {
            // 返回值为空的直接跳过
            if(null!=result){
                // 结果转换
                BaseResult baseResult = (BaseResult) result;
                // 判断是否执行成功
                if(!baseResult.isSuccess()){
                    // 执行失败，打上错误标签
                    tracer.addTag("error",baseResult.getErrorMessage());
                }
            }
           // 针对这一块，使用try catch ， 保证不会影响程序的正常运行
        }catch (Exception ignored){}

        return result;
    }

}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
例：

@RequestMapping("/api/login")
public BaseResult login(User user) throws Exception {
  // 
  return userService.login(user);
}

1
2
3
4
5
6
1
2
3
4
5
6

总结：

Trace对象是spring容器中一个针对span操做的对象， 每一个span对象是存储在ThreadLocal中的，因此当一个请求进来以后，能够随时对他进行添加修改的操做。

上面的这种作法，使用一个切面就解决了， 这种作法，须要公司内部的java应用的返回值格式要高度统一。由于这个切面咱们最终是会作成一个starter包，供各个java应用调用的。 ---------------------