线程池拒绝异常捕获

Author: dolyw

SpringBoot/ThreadPool/src/main/java/com/example/exception/ExceptionAdvice.java

@@ -0,0 +1,104 @@
+package com.example.exception;
+
+import cn.hutool.core.util.ObjectUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+import org.springframework.web.servlet.NoHandlerFoundException;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.RejectedExecutionException;
+
+/**
+ * 全局异常控制处理器
+ * 未找到指定异常处理方法exception，则以全局异常方法globalException兜底
+ *
+ * @author wliduo[i@dolyw.com]
+ * @date 2021/10/12 15:46
+ */
+@RestControllerAdvice
+public class ExceptionAdvice {
+
+    /**
+     * logger
+     */
+    private static final Logger logger = LoggerFactory.getLogger(ExceptionAdvice.class);
+
+    @Autowired
+    private HttpServletRequest request;
+
+    /**
+     * 捕捉RejectedExecutionException-线程拒绝策略异常
+     *
+     * @param e
+     * @return java.lang.Object
+     * @throws
+     * @author wliduo[i@dolyw.com]
+     * @date 2021/11/9 13:49
+     */
+    @ResponseStatus(HttpStatus.OK)
+    @ExceptionHandler(RejectedExecutionException.class)
+    public Object exception(RejectedExecutionException e) {
+        // logger.error("{}接口线程服务异常:{}", request.getRequestURI(), ExceptionUtil.stacktraceToOneLineString(e.getCause(), 10000000));
+        logger.error("{}接口线程服务异常:{}", request.getRequestURI(), e);
+        return e.getMessage();
+    }
+
+    /**
+     * 捕捉ExecutionException-FutureTask异步线程异常
+     *
+     * @param e
+     * @return java.lang.Object
+     * @throws
+     * @author wliduo[i@dolyw.com]
+     * @date 2021/11/9 13:46
+     */
+    @ResponseStatus(HttpStatus.OK)
+    @ExceptionHandler(ExecutionException.class)
+    public Object exception(ExecutionException e) {
+        // logger.error("{}接口异步线程服务异常:{}", request.getRequestURI(), ExceptionUtil.stacktraceToOneLineString(e.getCause(), 10000000));
+        logger.error("{}接口异步线程服务异常:{}", request.getRequestURI(), e.getCause());
+        if (ObjectUtil.isNotEmpty(e.getCause().getMessage())) {
+            return e.getCause().getMessage();
+        } else {
+            return e.getMessage();
+        }
+    }
+
+    /**
+     * 捕捉404未找到路径异常
+     *
+     * @param e
+     * @return java.lang.Object
+     * @throws
+     * @author wliduo[i@dolyw.com]
+     * @date 2021/10/12 16:08
+     */
+    @ResponseStatus(HttpStatus.OK)
+    @ExceptionHandler(NoHandlerFoundException.class)
+    public Object exception(NoHandlerFoundException e) {
+        return "404";
+    }
+
+    /**
+     * 捕捉其他所有Exception异常
+     *
+     * @param e
+     * @return com.pcic.app.common.dto.ResponseMessage
+     * @throws
+     * @author wliduo[i@dolyw.com]
+     * @date 2021/10/12 16:09
+     */
+    @ResponseStatus(HttpStatus.OK)
+    @ExceptionHandler(Exception.class)
+    public Object globalException(Exception e) {
+        // logger.error("{}接口服务异常:{}", request.getRequestURI(), ExceptionUtil.stacktraceToOneLineString(e, 10000000));
+        logger.error("{}接口服务异常:{}", request.getRequestURI(), e);
+        return e.getMessage();
+    }
+}

SpringBoot/ThreadPool/src/main/java/com/example/util/SmsUtil.java

@@ -27,14 +27,10 @@ public class SmsUtil {
      * @date 2020/5/20 10:53
      */
     @Async("jdkThreadPoolExecutor")
-    public void sendCode(String phone, String code) {
+    public void sendCode(String phone, String code) throws Exception {
         logger.info("开始发送验证码...");
         // 模拟调用接口发验证码的耗时
-        try {
-            Thread.sleep(3000);
-        } catch (InterruptedException e) {
-            e.printStackTrace();
-        }
+        Thread.sleep(3000);
         logger.info("发送成功: {}", phone);
     }