Java設計模式之代理模式與@Async非同步註解失效的解決

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface ExtAsync {
}

//介面
public interface OrderService {
    String addOrder();
    void addOrderLog();
}
//實現類
public class OrderServiceImpl implements OrderService {
    private OrderService orderServiceProxy;
    public String addOrder() {
        System.out.println(Thread.currentThread().getName() + ">>>流程1");
        orderServiceProxy.addOrderLog();
        System.out.println(Thread.currentThread().getName() + ">>>流程3");
        return "addOrder";
    }
    @ExtAsync
    public void addOrderLog() {
        System.out.println(Thread.currentThread().getName() + ">>>流程2");
    }
    public void setOrderServiceProxy(OrderService orderServiceProxy) {
        this.orderServiceProxy = orderServiceProxy;
    }
}

public class MayiktInvocationHandler implements InvocationHandler {
    /**
     * 目標物件
     */
    private Object target;
    /**
     * 定義執行緒池
     */
    private ExecutorService executorService;
    public MayiktInvocationHandler(Object target) {
        this.target = target;
        executorService = Executors.newFixedThreadPool(10);
    }
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        //使用反射技術執行目標方法
//        ExtAsync extAsync = method.getDeclaredAnnotation(ExtAsync.class);
        //根據介面的資訊查詢到目標物件的的方法
        Method methodImpl = target.getClass().getMethod(method.getName(), method.getParameterTypes());
        ExtAsync extAsync = methodImpl.getDeclaredAnnotation(ExtAsync.class);
        if (extAsync == null) {
            // 該方法上沒有加上非同步註解，則直接呼叫目標方法
            return method.invoke(target, args);
        }
        // 單獨開啟一個執行緒非同步處理目標方法
        executorService.execute(new Runnable() {
            @Override
            public void run() {
                try {
                    method.invoke(target, args);
                } catch (Exception e) {
                }
            }
        });
        return null;
    }
    /**
     * 生成代理類
     *
     * @param <T>
     * @return
     */
    public <T> T getProxy() {
        return (T) Proxy.newProxyInstance(target.getClass().getClassLoader(),
                target.getClass().getInterfaces(), this);
    }
}

public class Test001 {
    public static void main(String[] args) {
        OrderServiceImpl orderServiceImpl = new OrderServiceImpl();
        MayiktInvocationHandler mayiktInvocationHandler =
                new MayiktInvocationHandler(orderServiceImpl);
        // 使用Jdk生成代理物件
        OrderService orderServiceProxy = mayiktInvocationHandler.getProxy();
        // 將代理設定給目標物件
        orderServiceImpl.setOrderServiceProxy(orderServiceProxy);
        orderServiceProxy.addOrder();
    }
}

@Component
@Aspect
@Slf4j
public class ExtAsyncAop {
    private ExecutorService executorService;
    public ExtAsyncAop() {
        executorService = Executors.newFixedThreadPool(10);
    }
    @Around(value = "@annotation(com.kaico.designMode.proxy.aopAsync.ext.ExtAsync)")
    public void doBefore(ProceedingJoinPoint joinPoint) throws Throwable {
        // 直接獲取到方法上有加上ExtAsync
        log.info(">>>攔截到我們方法上有加上ExtAsync");
        executorService.execute(new Runnable() {
            @Override
            public void run() {
                // 執行我們的目標方法
                try {
                    joinPoint.proceed();
                } catch (Throwable throwable) {
                    throwable.printStackTrace();
                }
            }
        });
    }
}