SpringBoot手动取消接口执行方案

现实开辟中经常会遇到比较耗时的接口操作，但页面强制刷新或主动取消接口调用后后台还是会继续运行，特别是有大量数据库操作时会增加服务器压力，以是举行研究测试后总结了一套主动取消接口调用的办理方案
自定义注解用于标记耗时接口

1. @Retention(RetentionPolicy.RUNTIME)
2. @Target({ElementType.METHOD})
3. @Inherited
4. public @interface HandleCancel {
5. }

复制代码

自定义切面对注解的接口调用线程举行记录

1. @Aspect
2. @Component
3. public class HandleCacelAspect {
5.     @Pointcut("@annotation(org.springframework.web.bind.annotation.PostMapping) " +
6.             "|| @within(org.springframework.web.bind.annotation.PostMapping)"+
7.             "@annotation(org.springframework.web.bind.annotation.GetMapping) " +
8.             "|| @within(org.springframework.web.bind.annotation.GetMapping)")
9.     public void handleCacelAspect() {
11.     }
13.     @Around("handleCacelAspect()")
14.     public Object around(ProceedingJoinPoint point) throws Throwable {
16.         boolean handleCacel = false;
17.         Object result = null;
18.         try{
19.             HandleCancel handleCancelAnnotation = method.getAnnotation(HandleCancel.class);
20.             if (handleCancelAnnotation != null) {
21.                 handleCacel = true;
22.             }
23.             if(handleCacel){
24.                 //这里将对应的耗时接口请求线程名称和token关联存储到redis中，请安实际情况编写
25.                 TokenModel userModel = authService.getTokenModel();
26.                 userModel.addThread(Thread.currentThread().getName());
27.                 authService.updateToken(authService.getTokenString(),userModel);
28.             }
29.              result = point.proceed();
30.         }finally {
31.             if(handleCacel){
32.                 //这里在耗时接口执行完毕后删除对应存储的线程名称，请安实际情况编写
33.                 TokenModel userModel = authService.getTokenModel();
34.                 userModel.removeThread(Thread.currentThread().getName());
35.                 authService.updateToken(authService.getTokenString(),userModel);
36.             }
37.         }
39.         return result;
40.     }
41. }

复制代码

提供统一取消调用的接口

1.     @PostMapping("/killUserHandleThread")
2.     @ResponseBody
3.     public Object killUserHandleThread(@RequestBody Map<String, Object> params) {
4.         Result result = Result.okResult();
5.         TokenModel userModel = authService.getTokenModel();
6.         List<String> threadNameList = userModel.getThreadList();
8.         ThreadGroup currentGroup = Thread.currentThread().getThreadGroup();
9.         int noThreads = currentGroup.activeCount();
10.         Thread[] lstThreads = new Thread[noThreads];
11.         currentGroup.enumerate(lstThreads);
13.         for (int i = 0; i < noThreads; i++) {
14.             String threadName = lstThreads[i].getName();
15.             if (threadNameList.contains(threadName)) {
16.                 System.out.println("中断线程：" + threadName);
17.                 lstThreads[i].interrupt();
18.                 userModel.removeThread(threadName);
19.                 authService.updateToken(authService.getTokenString(),userModel);
20.             }
21.         }
22.         return result;
23.     }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。