release 0.4.0

Author: slievrly

.travis.yml

@@ -12,7 +12,7 @@ cache:
 install: true
 
 script:
-  - mvn clean package
+  - mvn clean package verify
 
 after_success:
-  - bash <(curl -s https://codecov.io/bash)
+  - bash <(curl -s https://codecov.io/bash)

common/pom.xml

@@ -20,7 +20,7 @@
     <parent>
         <artifactId>fescar-all</artifactId>
         <groupId>com.alibaba.fescar</groupId>
-        <version>0.3.1</version>
+        <version>0.4.0</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>fescar-common</artifactId>
@@ -38,6 +38,7 @@
         <dependency>
             <groupId>ch.qos.logback</groupId>
             <artifactId>logback-classic</artifactId>
+            <optional>true</optional>
         </dependency>
         <dependency>
             <groupId>commons-lang</groupId>

common/src/main/java/com/alibaba/fescar/common/Constants.java

@@ -40,4 +40,62 @@ public class Constants {
      */
     public static final String DBKEYS_SPLIT_CHAR = ",";
 
+    /** the start time of transaction */
+    public static final String START_TIME  = "start-time";
+
+    /**
+     * app name
+     */
+    public static final String APP_NAME = "appName";
+
+    /**
+     * TCC start time
+     */
+    public static final String ACTION_START_TIME = "action-start-time";
+
+    /**
+     * TCC name
+     */
+    public final static String ACTION_NAME = "actionName";
+
+    /**
+     * phase one method name
+     */
+    public final static String PREPARE_METHOD = "sys::prepare";
+
+    /**
+     * phase two commit method name
+     */
+    public final static String COMMIT_METHOD = "sys::commit";
+
+    /**
+     * phase two rollback method name
+     */
+    public final static String ROLLBACK_METHOD = "sys::rollback";
+
+    /**
+     * host ip
+     */
+    public final static String HOST_NAME = "host-name";
+
+    /**
+     * The constant TCC_METHOD_RESULT.
+     */
+    public final static String TCC_METHOD_RESULT = "result";
+
+    /**
+     * The constant TCC_METHOD_ARGUMENTS.
+     */
+    public final static String TCC_METHOD_ARGUMENTS = "arguments";
+
+    /**
+     * transaction context
+     */
+    public final static String TCC_ACTIVITY_CONTEXT = "activityContext";
+
+    /**
+     * branch context
+     */
+    public final static String TCC_ACTION_CONTEXT = "actionContext";
+
 }

common/src/main/java/com/alibaba/fescar/common/exception/NotSupportYetException.java

@@ -18,6 +18,8 @@
 
 /**
  * The type Not support yet exception.
+ *
+ * @author jimin.jm @alibaba-inc.com
  */
 public class NotSupportYetException extends RuntimeException {
 

common/src/main/java/com/alibaba/fescar/common/exception/ShouldNeverHappenException.java

@@ -18,6 +18,8 @@
 
 /**
  * The type Should never happen exception.
+ *
+ * @author jimin.jm @alibaba-inc.com
  */
 public class ShouldNeverHappenException extends RuntimeException {
 

common/src/main/java/com/alibaba/fescar/common/executor/Callback.java

@@ -0,0 +1,36 @@
+/*
+ *  Copyright 1999-2018 Alibaba Group Holding Ltd.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+package com.alibaba.fescar.common.executor;
+
+/**
+ * The interface Callback.
+ *
+ * @param <T> the type parameter
+ *
+ * @author zhangsen
+ */
+public interface Callback<T> {
+
+    /**
+     * Execute t.
+     *
+     * @return the t
+     * @throws Throwable the throwable
+     */
+    public T execute() throws Throwable;
+}
+

common/src/main/java/com/alibaba/fescar/common/executor/Initialize.java

@@ -0,0 +1,31 @@
+/*
+ *  Copyright 1999-2018 Alibaba Group Holding Ltd.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+package com.alibaba.fescar.common.executor;
+
+/**
+ * The interface Initialize.
+ *
+ * @author zhangsen
+ */
+public interface Initialize {
+
+    /**
+     * init method
+     */
+    public void init();
+
+}

common/src/main/java/com/alibaba/fescar/common/loader/EnhancedServiceLoader.java

@@ -16,6 +16,14 @@
 
 package com.alibaba.fescar.common.loader;
 
+import com.alibaba.fescar.common.executor.Initialize;
+import com.alibaba.fescar.common.util.CollectionUtils;
+import org.apache.commons.lang.ObjectUtils;
+import org.apache.commons.lang.StringUtils;
+import org.apache.commons.lang.exception.ExceptionUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.InputStreamReader;
@@ -28,12 +36,6 @@
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
-import org.apache.commons.lang.ObjectUtils;
-import org.apache.commons.lang.StringUtils;
-import org.apache.commons.lang.exception.ExceptionUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 /**
  * The type Enhanced service loader.
  *
@@ -100,6 +102,29 @@ public static <S> S load(Class<S> service, String activateName, ClassLoader load
         return loadFile(service, activateName, loader);
     }
 
+    /**
+     * get all implements
+     *
+     * @param <S>     the type parameter
+     * @param service the service
+     * @return list
+     */
+    public static <S> List<S> loadAll(Class<S> service){
+        List<S> allInstances = new ArrayList<>();
+        List<Class> allClazzs = getAllExtensionClass(service);
+        if(CollectionUtils.isEmpty(allClazzs)){
+            return allInstances;
+        }
+        try {
+            for(Class clazz : allClazzs){
+                allInstances.add(initInstance(service, clazz));
+            }
+        } catch (Throwable t) {
+            throw new EnhancedServiceNotFoundException(t);
+        }
+        return allInstances;
+    }
+
     /**
      * 获取所有的扩展类，按照{@linkplain LoadLevel}定义的order顺序进行排序
      *
@@ -163,20 +188,18 @@ private static <S> S loadFile(Class<S> service, String activateName, ClassLoader
                     "not found service provider for : " + service.getName() + "[" + activateName
                         + "] and classloader : " + ObjectUtils.toString(loader));
             }
-            Class<?> extension = extensions.get(extensions.size() - 1);
-            S result = service.cast(extension.newInstance());
+            Class<?> extension = extensions.get(extensions.size() - 1);// 最大的一个
+            S result = initInstance(service, extension);
             if (!foundFromCache && LOGGER.isInfoEnabled()) {
-                LOGGER.info("load " + service.getSimpleName() + "[" + activateName + "] extension by class[" + extension
-                    .getName() + "]");
+                LOGGER.info("load " + service.getSimpleName() + "[" + activateName + "] extension by class[" + extension.getName() + "]");
             }
             return result;
         } catch (Throwable e) {
             if (e instanceof EnhancedServiceNotFoundException) {
-                throw (EnhancedServiceNotFoundException)e;
+                throw (EnhancedServiceNotFoundException) e;
             } else {
                 throw new EnhancedServiceNotFoundException(
-                    "not found service provider for : " + service.getName() + " caused by " + ExceptionUtils
-                        .getFullStackTrace(e));
+                    "not found service provider for : " + service.getName() + " caused by " + ExceptionUtils.getFullStackTrace(e));
             }
         }
     }
@@ -263,6 +286,24 @@ private static void loadFile(Class<?> service, String dir, ClassLoader classLoad
         }
     }
 
+    /**
+     * init instance
+     *
+     * @param <S>       the type parameter
+     * @param service   the service
+     * @param implClazz the impl clazz
+     * @return s
+     * @throws IllegalAccessException the illegal access exception
+     * @throws InstantiationException the instantiation exception
+     */
+    protected static <S> S initInstance(Class<S> service, Class implClazz) throws IllegalAccessException, InstantiationException {
+        S s = service.cast(implClazz.newInstance());
+        if(s instanceof Initialize){
+            ((Initialize)s).init();
+        }
+        return s;
+    }
+
     private static ClassLoader findClassLoader() {
         // 不能使用TCCL,在pandora容器中会导致无法加载plugin中的类
         return EnhancedServiceLoader.class.getClassLoader();

common/src/main/java/com/alibaba/fescar/common/thread/RejectedPolicies.java

@@ -23,7 +23,7 @@
 /**
  * Policies for RejectedExecutionHandler
  *
- * Created by guoyao on 2019/2/26.
+ * @author guoyao
  */
 public final class RejectedPolicies {
 

common/src/main/java/com/alibaba/fescar/common/util/BlobUtils.java

@@ -26,6 +26,8 @@
 
 /**
  * The type Blob utils.
+ *
+ * @author jimin.jm @alibaba-inc.com
  */
 public class BlobUtils {
 

common/src/main/java/com/alibaba/fescar/common/util/CollectionUtils.java

@@ -0,0 +1,47 @@
+/*
+ *  Copyright 1999-2018 Alibaba Group Holding Ltd.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+package com.alibaba.fescar.common.util;
+
+import java.util.Collection;
+
+/**
+ * The type Collection utils.
+ *
+ * @author zhangsen
+ */
+public class CollectionUtils {
+
+    /**
+     * Is empty boolean.
+     *
+     * @param col the col
+     * @return the boolean
+     */
+    public static boolean isEmpty(Collection col){
+        return !isNotEmpty(col);
+    }
+
+    /**
+     * Is not empty boolean.
+     *
+     * @param col the col
+     * @return the boolean
+     */
+    public static boolean isNotEmpty(Collection col){
+        return col != null && col.size() > 0;
+    }
+}