feature: Raft config center v2

.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

@@ -312,6 +312,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

@@ -1177,6 +1177,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";
     /**
      *
      */
@@ -1247,4 +1272,5 @@ public interface ConfigurationKeys {
      */
     String SERVER_REGISTRY_METADATA_EXTERNAL = SERVER_REGISTRY_METADATA_PREFIX + ".external";
 
+
 }

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

@@ -229,6 +229,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
      */
@@ -239,4 +269,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

@@ -507,20 +507,79 @@ public interface DefaultValues {
      */
     int DEFAULT_ROCKET_MQ_MSG_TIMEOUT = 60 * 1000;
 
+    /**
+     * The constant DEFAULT_DB_STORE_FILE_DIR.
+     */
+    String DEFAULT_DB_STORE_FILE_DIR = "configStore";
+
+    /**
+     * The constant DEFAULT_DB_TYPE.
+     */
+    String DEFAULT_DB_TYPE = "rocksdb";
+
+    /**
+     * The constant DEFAULT_DB_DRUID_TIME_BETWEEN_EVICTION_RUNS_MILLIS.
+     */
     long DEFAULT_DB_DRUID_TIME_BETWEEN_EVICTION_RUNS_MILLIS = 120000;
+
+    /**
+     * The constant DEFAULT_DB_DRUID_MIN_EVICTABLE_TIME_MILLIS.
+     */
     long DEFAULT_DB_DRUID_MIN_EVICTABLE_TIME_MILLIS = 300000;
+
+    /**
+     * The constant DEFAULT_DB_DRUID_TEST_WHILE_IDLE.
+     */
     boolean DEFAULT_DB_DRUID_TEST_WHILE_IDLE = true;
+
+    /**
+     * The constant DEFAULT_DB_DRUID_TEST_ON_BORROW.
+     */
     boolean DEFAULT_DB_DRUID_TEST_ON_BORROW = false;
+
+    /**
+     * The constant DEFAULT_DB_DRUID_KEEP_ALIVE.
+     */
     boolean DEFAULT_DB_DRUID_KEEP_ALIVE = false;
-
+
+    /**
+     * The constant DEFAULT_DB_HIKARI_IDLE_TIMEOUT.
+     */
     long DEFAULT_DB_HIKARI_IDLE_TIMEOUT = 600000L;
+
+    /**
+     * The constant DEFAULT_DB_HIKARI_KEEPALIVE_TIME.
+     */
     long DEFAULT_DB_HIKARI_KEEPALIVE_TIME = 120000L;
+
+    /**
+     * The constant DEFAULT_DB_HIKARI_MAX_LIFE_TIME.
+     */
     long DEFAULT_DB_HIKARI_MAX_LIFE_TIME = 1800000L;
+
+    /**
+     * The constant DEFAULT_DB_HIKARI_VALIDATION_TIMEOUT.
+     */
     long DEFAULT_DB_HIKARI_VALIDATION_TIMEOUT = 5000L;
 
+    /**
+     * The constant DEFAULT_DB_DBCP_TIME_BETWEEN_EVICTION_RUNS_MILLIS.
+     */
     long DEFAULT_DB_DBCP_TIME_BETWEEN_EVICTION_RUNS_MILLIS = 120000;
+
+    /**
+     * The constant DEFAULT_DB_DBCP_MIN_EVICTABLE_TIME_MILLIS.
+     */
     long DEFAULT_DB_DBCP_MIN_EVICTABLE_TIME_MILLIS = 300000;
+
+    /**
+     * The constant DEFAULT_DB_DBCP_TEST_WHILE_IDLE.
+     */
     boolean DEFAULT_DB_DBCP_TEST_WHILE_IDLE = true;
+
+    /**
+     * The constant DEFAULT_DB_DBCP_TEST_ON_BORROW.
+     */
     boolean DEFAULT_DB_DBCP_TEST_ON_BORROW = false;
 
     /**

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

@@ -0,0 +1,59 @@
+/*
+ * 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;
+
+import java.io.Serializable;
+
+public class ConfigDataResponse<T> implements Serializable {
+    private static final long serialVersionUID = -1959848221874923781L;
+    private T result;
+    private String errMsg;
+    private 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;
+    }
+
+    @Override
+    public String toString() {
+        return "ConfigDataResponse{" +
+                "result=" + result +
+                ", errMsg='" + errMsg + '\'' +
+                ", 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;
+    }
 }

common/src/test/java/org/apache/seata/common/util/NumberUtilsTest.java

@@ -36,4 +36,12 @@ public void testToInReturnDefaultValueWithFormatIsInvalid() {
     public void testToInReturnParsedValue() {
         Assertions.assertEquals(10, NumberUtils.toInt("10", 9));
     }
+
+    @Test
+    public void testBytesAndLong() {
+        Long a = 123456L;
+        byte[] bytes = NumberUtils.longToBytes(a);
+        long b = NumberUtils.bytesToLong(bytes);
+        Assertions.assertEquals(a, b);
+    }
 }

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

@@ -49,6 +49,10 @@ public enum ConfigType {
      * spring cloud config type
      */
     SpringCloudConfig,
+    /**
+     * Raft config type
+     */
+    Raft,
     /**
      * Custom config 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;