优化代码

java110-core/src/main/java/com/java110/core/aop/Java110TransactionalAop.java

@@ -0,0 +1,84 @@
+package com.java110.core.aop;
+
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.After;
+import org.aspectj.lang.annotation.AfterReturning;
+import org.aspectj.lang.annotation.AfterThrowing;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Before;
+import org.aspectj.lang.annotation.Pointcut;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+
+import java.io.IOException;
+
+/**
+ * @ClassName Java110TransactionalAop
+ * @Description TODO
+ * @Author wuxw
+ * @Date 2020/7/3 22:13
+ * @Version 1.0
+ * add by wuxw 2020/7/3
+ **/
+@Component
+@Aspect
+public class Java110TransactionalAop {
+
+    private static Logger logger = LoggerFactory.getLogger(Java110TransactionalAop.class);
+
+    @Pointcut("@annotation(com.java110.core.annotation.Java110Transactional)")
+    public void dataProcess() {
+    }
+
+    /**
+     * 初始化数据
+     *
+     * @param joinPoint
+     * @throws Throwable
+     */
+    @Before("dataProcess()")
+    public void deBefore(JoinPoint joinPoint) throws Throwable {
+        // 接收到请求，记录请求内容
+        logger.debug("方法调用前执行deBefore（）");
+
+    }
+
+    @AfterReturning(returning = "ret", pointcut = "dataProcess()")
+    public void doAfterReturning(Object ret) throws Throwable {
+        // 处理完请求，返回内容
+        logger.debug("方法调用前执行doAfterReturning（）");
+    }
+
+    //后置异常通知
+    @AfterThrowing("dataProcess()")
+    public void throwException(JoinPoint jp) {
+        logger.debug("方法调用异常执行throwException（）");
+
+    }
+
+    //后置最终通知,final增强，不管是抛出异常或者正常退出都会执行
+    @After("dataProcess()")
+    public void after(JoinPoint jp) throws IOException {
+        // 接收到请求，记录请求内容
+        logger.debug("方法调用后执行after（）");
+
+
+    }
+
+    //环绕通知,环绕增强，相当于MethodInterceptor
+    @Around("dataProcess()")
+    public Object around(ProceedingJoinPoint pjp) {
+        try {
+            Object o = pjp.proceed();
+            return o;
+        } catch (Throwable e) {
+            logger.error("执行方法异常", e);
+            return new ResponseEntity("内部异常" + e.getLocalizedMessage(), HttpStatus.BAD_REQUEST);
+        }
+    }
+}

java110-core/src/main/java/com/java110/core/factory/Java110TransactionalFactory.java

@@ -0,0 +1,49 @@
+package com.java110.core.factory;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @ClassName Java110TransactionalFactory
+ * @Description TODO
+ * @Author wuxw
+ * @Date 2020/7/3 22:30
+ * @Version 1.0
+ * add by wuxw 2020/7/3
+ **/
+public class Java110TransactionalFactory {
+
+    //全局事务ID
+    public static final String T_ID = "t-id";
+
+    //当前服务ID
+    public static final String SERVICE_ID = "service-id";
+
+    private static ThreadLocal<Map<String, String>> threadLocal = new ThreadLocal<Map<String, String>>() {
+        @Override
+        protected Map<String, String> initialValue() {
+            return new HashMap<String, String>();
+        }
+    };
+
+    public static String put(String key, String value) {
+        return threadLocal.get().put(key, value);
+    }
+
+    public static String get(String key) {
+        return threadLocal.get().get(key);
+    }
+
+    public static String remove(String key) {
+        return threadLocal.get().remove(key);
+    }
+
+    public static Map<String, String> entries() {
+        return threadLocal.get();
+    }
+
+    public static String getOrCreateTId(){
+        return "";
+    }
+
+}