Merge pull request #5 from zhongxunking/develop

1.3.0.RELEASE

Author: zhongxunking

README.md

@@ -6,7 +6,7 @@
     <parent>
         <groupId>org.bekit</groupId>
         <artifactId>bekit</artifactId>
-        <version>1.2.5.RELEASE</version>
+        <version>1.3.0.RELEASE</version>
     </parent>
 
     <artifactId>common</artifactId>
@@ -21,6 +21,12 @@
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-api</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-autoconfigure</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
         <dependency>
             <groupId>org.springframework</groupId>
             <artifactId>spring-tx</artifactId>

common/pom.xml

@@ -0,0 +1,23 @@
+/* 
+ * 作者：钟勋 (e-mail:zhongxunking@163.com)
+ */
+
+/*
+ * 修订记录:
+ * @author 钟勋 2019-12-02 20:37 创建
+ */
+package org.bekit.common.boot;
+
+import org.springframework.boot.autoconfigure.AutoConfigureAfter;
+import org.springframework.boot.autoconfigure.transaction.TransactionAutoConfiguration;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+/**
+ * 公共自动配置
+ */
+@Configuration
+@AutoConfigureAfter(TransactionAutoConfiguration.class)
+@Import(CommonConfiguration.class)
+public class CommonAutoConfiguration {
+}

common/src/main/java/org/bekit/common/boot/CommonAutoConfiguration.java

@@ -0,0 +1,67 @@
+/* 
+ * 作者：钟勋 (e-mail:zhongxunking@163.com)
+ */
+
+/*
+ * 修订记录:
+ * @author 钟勋 2019-12-02 20:37 创建
+ */
+package org.bekit.common.boot;
+
+import org.bekit.common.transaction.TransactionManager;
+import org.bekit.common.transaction.support.EmptyTransactionManager;
+import org.bekit.common.transaction.support.SpringTransactionManager;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingClass;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+import org.springframework.transaction.PlatformTransactionManager;
+
+/**
+ * 公共配置
+ */
+@Configuration
+public class CommonConfiguration {
+    /**
+     * 事务配置
+     */
+    @Configuration
+    @ConditionalOnMissingBean(TransactionManager.class)
+    public static class TransactionManagerConfiguration {
+        /**
+         * PlatformTransactionManager存在
+         */
+        @Configuration
+        @ConditionalOnClass(PlatformTransactionManager.class)
+        public static class PlatformTransactionManagerClassExists {
+            /**
+             * Spring事务管理器配置
+             */
+            @Configuration
+            @ConditionalOnBean(PlatformTransactionManager.class)
+            @Import(SpringTransactionManager.class)
+            public static class SpringTransactionManagerConfiguration {
+            }
+
+            /**
+             * 空事务管理器配置
+             */
+            @Configuration
+            @ConditionalOnMissingBean(PlatformTransactionManager.class)
+            @Import(EmptyTransactionManager.class)
+            public static class EmptyTransactionManagerConfiguration {
+            }
+        }
+
+        /**
+         * PlatformTransactionManager不存在
+         */
+        @Configuration
+        @ConditionalOnMissingClass("org.springframework.transaction.PlatformTransactionManager")
+        @Import(EmptyTransactionManager.class)
+        public static class PlatformTransactionManagerClassNotExists {
+        }
+    }
+}

common/src/main/java/org/bekit/common/boot/CommonConfiguration.java

@@ -8,48 +8,49 @@
  */
 package org.bekit.common.method;
 
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
 import java.lang.reflect.InvocationTargetException;
 import java.lang.reflect.Method;
 
 /**
  * 方法执行器
  */
+@AllArgsConstructor
+@Getter
 public abstract class MethodExecutor {
-    // 目标方法
-    private final Method targetMethod;
-
-    public MethodExecutor(Method targetMethod) {
-        this.targetMethod = targetMethod;
-    }
+    // 方法
+    private final Method method;
 
     /**
      * 执行方法
      *
      * @param obj  被执行的对象
      * @param args 需传入目标方法的参数
-     * @return 目标方法返回的结果
+     * @return 方法返回的结果
      * @throws Throwable 执行过程中发生任何异常都会往外抛
      */
     protected Object execute(Object obj, Object[] args) throws Throwable {
         try {
-            return targetMethod.invoke(obj, args);
+            return method.invoke(obj, args);
         } catch (InvocationTargetException e) {
             // 抛出原始异常
             throw e.getTargetException();
         }
     }
 
     /**
-     * 获取目标方法入参类型
+     * 获取方法入参类型
      */
-    public Class[] getParameterTypes() {
-        return targetMethod.getParameterTypes();
+    public Class<?>[] getParameterTypes() {
+        return method.getParameterTypes();
     }
 
     /**
-     * 获取目标方法返回类型
+     * 获取方法返回类型
      */
-    public Class getReturnType() {
-        return targetMethod.getReturnType();
+    public Class<?> getReturnType() {
+        return method.getReturnType();
     }
 }

common/src/main/java/org/bekit/common/method/MethodExecutor.java

@@ -0,0 +1,57 @@
+/* 
+ * 作者：钟勋 (e-mail:zhongxunking@163.com)
+ */
+
+/*
+ * 修订记录:
+ * @author 钟勋 2016-12-19 01:26 创建
+ */
+package org.bekit.common.registrar;
+
+import lombok.AllArgsConstructor;
+
+import java.util.Collections;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.function.Function;
+
+/**
+ * 抽象注册器
+ */
+@AllArgsConstructor
+public abstract class AbstractRegistrar<N, E> {
+    // 元素集
+    private final Map<N, E> elementMap = new ConcurrentHashMap<>();
+    // 名称提取器
+    private final Function<E, N> nameExtractor;
+
+    /**
+     * 注册元素
+     *
+     * @param element 被注册的元素
+     * @return 被替换的元素
+     */
+    public E register(E element) {
+        return elementMap.put(nameExtractor.apply(element), element);
+    }
+
+    /**
+     * 获取所有元素的名称
+     *
+     * @return 所有所有元素的名称
+     */
+    public Set<N> getNames() {
+        return Collections.unmodifiableSet(elementMap.keySet());
+    }
+
+    /**
+     * 获取元素
+     *
+     * @param name 元素名称
+     * @return 元素
+     */
+    public E get(N name) {
+        return elementMap.get(name);
+    }
+}

common/src/main/java/org/bekit/common/registrar/AbstractRegistrar.java

@@ -0,0 +1,40 @@
+/* 
+ * 作者：钟勋 (e-mail:zhongxunking@163.com)
+ */
+
+/*
+ * 修订记录:
+ * @author 钟勋 2019-12-24 22:23 创建
+ */
+package org.bekit.common.scanner;
+
+import lombok.AllArgsConstructor;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.event.ContextRefreshedEvent;
+
+import java.lang.annotation.Annotation;
+
+/**
+ * 抽象扫描器
+ */
+@AllArgsConstructor
+public abstract class AbstractScanner implements ApplicationListener<ContextRefreshedEvent> {
+    // 需扫描的注解类型
+    private final Class<? extends Annotation> annotationType;
+
+    @Override
+    public void onApplicationEvent(ContextRefreshedEvent event) {
+        // 扫描
+        String[] beanNames = event.getApplicationContext().getBeanNamesForAnnotation(annotationType);
+        for (String beanName : beanNames) {
+            onScan(event.getApplicationContext().getBean(beanName));
+        }
+    }
+
+    /**
+     * 扫描模版方法
+     *
+     * @param obj 扫描到的对象
+     */
+    protected abstract void onScan(Object obj);
+}

common/src/main/java/org/bekit/common/scanner/AbstractScanner.java

@@ -0,0 +1,48 @@
+/* 
+ * 作者：钟勋 (e-mail:zhongxunking@163.com)
+ */
+
+/*
+ * 修订记录:
+ * @author 钟勋 2019-12-01 22:02 创建
+ */
+package org.bekit.common.transaction;
+
+/**
+ * 事务管理器
+ */
+public interface TransactionManager {
+    /**
+     * 获取事务
+     *
+     * @param type 事务类型
+     * @return 事务状态（非null）
+     */
+    Object getTransaction(TransactionType type);
+
+    /**
+     * 提交
+     *
+     * @param status 事务状态
+     */
+    void commit(Object status);
+
+    /**
+     * 回滚
+     *
+     * @param status 事务状态
+     */
+    void rollback(Object status);
+
+    /**
+     * 事务类型
+     */
+    enum TransactionType {
+        // 融合事务（如果已存在事务，则使用已存在事务；否则创建新事务）
+        REQUIRED,
+        // 新事务（不管是否已存在事务，都创建新事务）
+        REQUIRES_NEW,
+        // 无事务（如果已存在事务，则挂起已存在事务；否则不做处理）
+        NOT_SUPPORTED
+    }
+}