<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-aop --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId><version>2.1.6.RELEASE</version></dependency><!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-mail --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-mail</artifactId><version>2.1.6.RELEASE</version></dependency>

package com.dev.config;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.beans.factory.InitializingBean;import java.lang.reflect.Method;
import java.util.concurrent.*;/*** Created on 2019-08-05 14:00.** @author zgq7*/
public class LocalThreadPool implements InitializingBean, DisposableBean {public static final String PACKAGE_BEAN_NAME = "localThreadPool";private static final Logger logger = LoggerFactory.getLogger(LocalThreadPool.class);/*** capacity 队列容量**/private final BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(5000);private final RejectedExecutionHandler handler = new ThreadPoolExecutor.CallerRunsPolicy();private final ThreadFactory defaultThreadFactory = Executors.defaultThreadFactory();private final ThreadFactory privilegedThreadFactory = Executors.privilegedThreadFactory();/*** corePoolSize             核心线程数量* maximumPoolSize          线程池允许最大线程池数量* keepAliveTime            当线程数超过本地线程核心数同时又小于设置的最大线程数，需要重新创建一个新线程时需要等待的时间* TimeUnit.MILLISECONDS    时间单位，这里我设置的是豪秒* workQueue                一个队列：当一个task被执行前进行使用* threadFactory            用于创建新线程的线程工厂* handler                  一个处理器：当线程被锁、或者队列的容量达到上限时 被调用**/public final ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 10, 3000, TimeUnit.MILLISECONDS, workQueue, defaultThreadFactory, handler);/*** 本地线程池被销毁后的回调方法**/@Overridepublic void destroy() throws Exception {logger.info("指令->[本地线程池已销毁]");}/*** 本地线程池成功初始化的回调犯法**/@Overridepublic void afterPropertiesSet() throws Exception {logger.info("指令->[本地线程池已成功初始化]");}}

package com.dev.config.aop;import com.dev.config.LocalThreadPool;
import com.dev.model.email.EmailModel;
import com.dev.utils.email.MailSendUtils;
import com.dev.utils.exception.ExceptionCodes;
import com.dev.utils.exception.ServiceException;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.annotation.Order;import java.util.Arrays;/*** Created on 2019-07-31 9:41.** @author zgq7*/
@Aspect
@Order(2)
public class RuntimeExceptionAspectJ {@Autowiredprivate MailSendUtils mailSendUtils;@Autowiredprivate LocalThreadPool localThreadPool;private final Logger log = LoggerFactory.getLogger(this.getClass());//@Pointcut("execution(public * com.dev..*(..))")@Pointcut("execution(public * com.dev.controller.TestController.*(..))")private void runtimeExceptionAspect() {}/*** 切面报错**/@AfterThrowing(value = "runtimeExceptionAspect()", throwing = "exception")public void afterThrowing(Throwable exception) {Class klass = exception.getClass();log.error("occured a [{}] , msg : [{}]", klass.getSimpleName(), ExceptionCodes.getMsgByKlass(klass));EmailModel emailModel = new EmailModel();emailModel.setEmailTheme("测试");emailModel.setRecieverName("测试");emailModel.setEmailContent(exception.toString() + ":\n" + Arrays.toString(exception.getStackTrace()));emailModel.setRecieverEmailAddress("xxx@qq.com");localThreadPool.threadPoolExecutor.getThreadFactory().newThread(() -> mailSendUtils.sendEmailAsSysExceptionHtml(emailModel)).start();throw new ServiceException(ExceptionCodes.getCodeByKlass(klass), ExceptionCodes.getMsgByKlass(klass));}}

package com.dev.utils.exception;import java.io.FileNotFoundException;
import java.io.IOException;
import java.net.ProtocolException;
import java.sql.SQLException;/*** Created on 2019-07-31 16:01.** @author zgq7* @apiNote 自定义的code - XxxException.class*/
public enum ExceptionCodes {//RuntimeException 类型异常RUNTIME_EXCEPTION(100, "运行时异常", RuntimeException.class),NULL_POINT_EXCEPTION(101, "空指针异常", NullPointerException.class),ARITHMETIC_EXCEPTION(102, "数学错误，被0除", ArithmeticException.class),INDEX_OUT_OF_BOUNDS_EXCEPTION(103, "当某对象的索引超出范围时抛出异常", IndexOutOfBoundsException.class),ARRAY_INDEX_OUT_OF_EXCEPTION(103001, "数组下标越界", ArrayIndexOutOfBoundsException.class),CLASS_CAST_EXCEPTION(104, "强制转换异常", ClassCastException.class),ILLEGAL_ARGUMENT_EXCEPTION(105, "非法转换", IllegalArgumentException.class),NUMBER_FORMAT_EXCEPTION(105001, "字符串转换为数字异常类", NumberFormatException.class),PROTOCOL_EXCEPTION(106, "网络协议有错误", ProtocolException.class),//IOException 类型异常IO_EXCEPTION(200, "IO 流异常", IOException.class),FILE_NOT_FOUND_EXCEPTION(201, "文件找不到", FileNotFoundException.class),//数据库 sql 操作异常SQL_EXCEPTION(300, "操作数据库异常", SQLException.class),//其他相关异常REFLECTIVE_OPERATION_EXCEPTION(400, "", ReflectiveOperationException.class),ILLEGAL_ACESS_EXCEPTION(401, "访问某类被拒绝时抛出的异常", IllegalAccessException.class);private int code;private String msg;private Class<Exception> klass;ExceptionCodes(int code, String msg, Class klass) {this.code = code;this.msg = msg;this.klass = klass;}public int getCode() {return this.code;}public String getMsg() {return this.msg;}public Class<Exception> getKlass() {return this.klass;}/*** 通过异常码获取对应异常类**/public static Class<Exception> getKlassByCode(int code) {for (ExceptionCodes exceptionCodes : ExceptionCodes.values()) {if (exceptionCodes.getCode() == code)return exceptionCodes.getKlass();}return null;}/*** 根据异常码获取对应异常信息**/public static String getMsgByCode(int code) {for (ExceptionCodes exceptionCodes : ExceptionCodes.values()) {if (exceptionCodes.getCode() == code)return exceptionCodes.getMsg();}return null;}/*** 根据异常类获取异常码**/public static int getCodeByKlass(Class<? extends Exception> klass) {for (ExceptionCodes exceptionCodes : ExceptionCodes.values()) {if (exceptionCodes.getKlass() == klass)return exceptionCodes.getCode();}return 3000;}/*** 根据异常类获取异常信息**/public static String getMsgByKlass(Class<? extends Exception> klass) {for (ExceptionCodes exceptionCodes : ExceptionCodes.values()) {if (exceptionCodes.getKlass() == klass)return exceptionCodes.getMsg();}return null;}}

异常枚举

package com.dev.config;import com.dev.config.aop.BaseAop;
import com.dev.config.aop.RuntimeExceptionAspectJ;
import com.dev.filter.BaseFilter;
import com.dev.utils.email.MailSendUtils;
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.core.annotation.Order;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.mail.javamail.JavaMailSenderImpl;import java.util.*;/*** Created by zgq7 on 2019/6/6.* 注册一些bean进入ioc** @EnableAspectJAutoProxy 开启aop代理*/
@Configuration
@EnableAspectJAutoProxy
public class BeanRegistryCenterConfig {/*** 邮箱工具类 bean 注册**/@Beanpublic MailSendUtils mailSendUtils() {return new MailSendUtils();}/*** 本地线程 bean 注册**/@Bean(name = LocalThreadPool.PACKAGE_BEAN_NAME)public LocalThreadPool localThreadPool() {return new LocalThreadPool();}/*** 异常捕获类 RuntimeExceptionAspectJ bean 注册**/@Beanpublic RuntimeExceptionAspectJ runtimeExceptionAspectJ() {return new RuntimeExceptionAspectJ();}}

package com.dev.controller;import com.dev.controller.bases.BaseController;
import com.dev.service.AopiService;
import com.dev.utils.exception.ServiceException;
import com.google.common.collect.ImmutableMap;
import okhttp3.*;
import org.springframework.web.bind.annotation.*;import javax.annotation.Resource;
import java.io.*;
import java.util.Collections;
import java.util.Map;/*** Created by zgq7 on 2019/6/6.*/
@RestController
@RequestMapping(value = "/dev")
public class TestController extends BaseController {@Resource(name = AopiService.PACKAGE_BEAN_NAME)private AopiService aopiService;@GetMapping(value = "")public Map<Object, Object> get() {if (1 == 1)throw new NullPointerException();return ImmutableMap.of("code", aopiService.getAopList());}

}