feature: support raft configuration center

.gitignore

@@ -46,6 +46,10 @@ dependency-reduced-pom.xml
 /distribution/sessionStore/
 /distribution/*/sessionStore/
 /file_store/
+/configStore/
+/config/configStore/
+/distribution/configStore/
+/distribution/*/configStore/
 
 # system ignore
 .DS_Store

all/pom.xml

@@ -91,6 +91,11 @@
             <artifactId>seata-config-spring-cloud</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.seata</groupId>
+            <artifactId>seata-config-raft</artifactId>
+            <version>${project.version}</version>
+        </dependency>
         <dependency>
             <groupId>org.apache.seata</groupId>
             <artifactId>seata-core</artifactId>

build/pom.xml

@@ -310,6 +310,7 @@
                                 <include>*-pom.xml</include>
                                 <include>**/db_store/**</include>
                                 <include>**/sessionStore/**</include>
+                                <include>**/configStore/**</include>
                                 <include>**/root.data</include>
                             </includes>
                             <followSymlinks>false</followSymlinks>

common/src/main/java/org/apache/seata/common/ConfigurationKeys.java

@@ -1017,6 +1017,31 @@ public interface ConfigurationKeys {
      */
     String ROCKET_MQ_MSG_TIMEOUT = SERVER_PREFIX + "rocketmqMsgTimeout";
 
+    String CONFIG_STORE_PREFIX = FILE_ROOT_PREFIX_CONFIG + "raft" + FILE_CONFIG_SPLIT_CHAR + "db" + FILE_CONFIG_SPLIT_CHAR;
+
+    /**
+     * The constant CONFIG_STORE_TYPE
+     */
+    String CONFIG_STORE_TYPE = CONFIG_STORE_PREFIX + "type";
+
+    /**
+     * The constant CONFIG_STORE_DIR
+     */
+    String CONFIG_STORE_DIR = CONFIG_STORE_PREFIX + "dir";
+
+    /**
+     * The constant CONFIG_STORE_DESTROY_ON_SHUTDOWN
+     */
+    String CONFIG_STORE_DESTROY_ON_SHUTDOWN = CONFIG_STORE_PREFIX + "destroyOnShutdown";
+
+    /**
+     * The constant CONFIG_STORE_NAMESPACE
+     */
+    String CONFIG_STORE_NAMESPACE = CONFIG_STORE_PREFIX + "namespace";
+    /**
+     * The constant CONFIG_STORE_DATA_ID
+     */
+    String CONFIG_STORE_DATA_ID = CONFIG_STORE_PREFIX + "dataId";
     /**
      *
      */
@@ -1051,4 +1076,5 @@ public interface ConfigurationKeys {
      * The constant META_PREFIX
      */
     String META_PREFIX = SEATA_FILE_ROOT_CONFIG + FILE_CONFIG_SPLIT_CHAR + FILE_ROOT_REGISTRY + FILE_CONFIG_SPLIT_CHAR + "metadata.";
+
 }

common/src/main/java/org/apache/seata/common/Constants.java

@@ -225,6 +225,36 @@ public interface Constants {
      */
     String JACKSON_JSON_TEXT_PREFIX = "{\"@class\":";
 
+    /**
+     * The constant APPLICATION_TYPE_KEY
+     */
+    String APPLICATION_TYPE_KEY = "application.type";
+
+    /**
+     * The constant APPLICATION_TYPE_SERVER
+     */
+    String APPLICATION_TYPE_SERVER = "server";
+
+    /**
+     * The constant APPLICATION_TYPE_CLIENT
+     */
+    String APPLICATION_TYPE_CLIENT = "client";
+
+    /**
+     * The constant DEFAULT_STORE_NAMESPACE in raft configuration
+     */
+
+    String DEFAULT_STORE_NAMESPACE = "default";
+    /**
+     * The constant DEFAULT_STORE_DATA_ID in raft configuration
+     */
+    String DEFAULT_STORE_DATA_ID = "seata.properties";
+
+    /**
+     * The constant RAFT_CONFIG_GROUP
+     */
+    String RAFT_CONFIG_GROUP = "config";
+
     /**
      * The constant DEAD_LOCK_SQL_STATE
      */
@@ -235,4 +265,8 @@ public interface Constants {
      */
     int DEAD_LOCK_ERROR_CODE = 1213;
 
+    /**
+     * The constant CONFIGURATION_META_FILE_NAME
+     */
+    String CONFIGURATION_META_FILE_NAME = "configuration-meta.yml";
 }

common/src/main/java/org/apache/seata/common/DefaultValues.java

@@ -314,4 +314,8 @@ public interface DefaultValues {
     String DRUID_LOCATION = "lib/sqlparser/druid.jar";
 
     int DEFAULT_ROCKET_MQ_MSG_TIMEOUT = 60 * 1000;
+
+    String DEFAULT_DB_STORE_FILE_DIR = "configStore";
+
+    String DEFAULT_DB_TYPE = "rocksdb";
 }

common/src/main/java/org/apache/seata/common/config/ConfigDataResponse.java

@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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 org.apache.seata.common.config;
+
+
+public class ConfigDataResponse<T> {
+
+    T result;
+    String errMsg;
+    Boolean success;
+
+    public T getResult() {
+        return result;
+    }
+
+    public void setResult(T result) {
+        this.result = result;
+    }
+
+    public String getErrMsg() {
+        return errMsg;
+    }
+
+    public void setErrMsg(String errMsg) {
+        this.errMsg = errMsg;
+    }
+
+    public Boolean getSuccess() {
+        return success;
+    }
+
+    public void setSuccess(Boolean success) {
+        this.success = success;
+    }
+}

common/src/main/java/org/apache/seata/common/metadata/MetadataResponse.java

@@ -25,6 +25,8 @@ public class MetadataResponse {
 
     String storeMode;
 
+    String configMode;
+
     long term;
 
     public List<Node> getNodes() {
@@ -50,5 +52,12 @@ public long getTerm() {
     public void setTerm(long term) {
         this.term = term;
     }
-
+
+    public String getConfigMode() {
+        return configMode;
+    }
+
+    public void setConfigMode(String configMode) {
+        this.configMode = configMode;
+    }
 }

common/src/main/java/org/apache/seata/common/store/StoreMode.java

@@ -16,6 +16,8 @@
  */
 package org.apache.seata.common.store;
 
+import org.apache.seata.common.util.StringUtils;
+
 /**
  * transaction log store mode
  *
@@ -55,6 +57,9 @@ public enum StoreMode {
      * @return the store mode
      */
     public static StoreMode get(String name) {
+        if (StringUtils.isEmpty(name)) {
+            return null;
+        }
         for (StoreMode sm : StoreMode.class.getEnumConstants()) {
             if (sm.name.equalsIgnoreCase(name)) {
                 return sm;

common/src/main/java/org/apache/seata/common/util/NumberUtils.java

@@ -60,4 +60,22 @@ public static Long toLong(String str) {
         }
         return null;
     }
+
+    public static byte[] longToBytes(long x) {
+        byte[] result = new byte[8];
+        for (int i = 7; i >= 0; i--) {
+            result[i] = (byte)(x & 0xFF);
+            x >>= 8;
+        }
+        return result;
+    }
+
+    public static long bytesToLong(byte[] bytes) {
+        long result = 0;
+        for (int i = 0; i < 8; i++) {
+            result <<= 8;
+            result |= bytes[i] & 0xFF;
+        }
+        return result;
+    }
 }

config/pom.xml

@@ -41,5 +41,6 @@
         <module>seata-config-etcd3</module>
         <module>seata-config-consul</module>
         <module>seata-config-spring-cloud</module>
+        <module>seata-config-raft</module>
     </modules>
 </project>

config/seata-config-all/pom.xml

@@ -60,6 +60,11 @@
             <artifactId>seata-config-spring-cloud</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>${project.groupId}</groupId>
+            <artifactId>seata-config-raft</artifactId>
+            <version>${project.version}</version>
+        </dependency>
     </dependencies>
 
 </project>

config/seata-config-core/pom.xml

@@ -43,6 +43,11 @@
             <groupId>org.yaml</groupId>
             <artifactId>snakeyaml</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.rocksdb</groupId>
+            <artifactId>rocksdbjni</artifactId>
+        </dependency>
+
     </dependencies>
 
 </project>

config/seata-config-core/src/main/java/org/apache/seata/config/ConfigType.java

@@ -52,7 +52,11 @@ public enum ConfigType {
     /**
      * Custom config type
      */
-    Custom;
+    Custom,
+    /**
+     * Raft config type
+     */
+    Raft;
 
     /**
      * Gets type.

config/seata-config-core/src/main/java/org/apache/seata/config/ConfigurationChangeEvent.java

@@ -38,6 +38,10 @@ public ConfigurationChangeEvent(String dataId, String newValue) {
         this(dataId, DEFAULT_NAMESPACE, null, newValue, ConfigurationChangeType.MODIFY);
     }
 
+    public ConfigurationChangeEvent(String namespace, String dataId, String newValue) {
+        this(dataId, namespace, null, newValue, ConfigurationChangeType.MODIFY);
+    }
+
     public ConfigurationChangeEvent(String dataId, String namespace, String oldValue, String newValue,
                                     ConfigurationChangeType type) {
         this.dataId = dataId;