update

apache · Jul 6, 2022 · 598dac9 · 598dac9
1 parent bd011c0
commit 598dac9
Show file tree

Hide file tree

Showing 5 changed files with 17 additions and 6 deletions.
diff --git a/common/src/main/java/io/seata/common/ConfigurationKeys.java b/common/src/main/java/io/seata/common/ConfigurationKeys.java
@@ -850,8 +850,8 @@ public interface ConfigurationKeys {
     String XA_CONNECTION_TWO_PHASE_HOLD_TIMEOUT = CLIENT_RM_PREFIX + "connectionTwoPhaseHoldTimeoutXA";
 
     /**
-     * The constant ENABLED_PARALLEL_REQUEST_HANDLE_KEY
+     * The constant ENABLE_PARALLEL_REQUEST_HANDLE_KEY
      */
-    String ENABLED_PARALLEL_REQUEST_HANDLE_KEY = SERVER_PREFIX + "enabledParallelRequestHandle";
+    String ENABLE_PARALLEL_REQUEST_HANDLE_KEY = SERVER_PREFIX + "enableParallelRequestHandle";
 
 }
diff --git a/core/src/main/java/io/seata/core/rpc/processor/server/ServerOnRequestProcessor.java b/core/src/main/java/io/seata/core/rpc/processor/server/ServerOnRequestProcessor.java
@@ -102,7 +102,7 @@ public class ServerOnRequestProcessor implements RemotingProcessor, Disposable {
     private static final long KEEP_ALIVE_TIME = Integer.MAX_VALUE;
     private static final String BATCH_RESPONSE_THREAD_PREFIX = "rpcBatchResponse";
     private static final boolean PARALLEL_REQUEST_HANDLE =
-        ConfigurationFactory.getInstance().getBoolean(ConfigurationKeys.ENABLED_PARALLEL_REQUEST_HANDLE_KEY, false);
+        ConfigurationFactory.getInstance().getBoolean(ConfigurationKeys.ENABLE_PARALLEL_REQUEST_HANDLE_KEY, false);
 
     public ServerOnRequestProcessor(RemotingServer remotingServer, TransactionMessageHandler transactionMessageHandler) {
         this.remotingServer = remotingServer;

diff --git a/script/config-center/config.txt b/script/config-center/config.txt
@@ -121,6 +121,7 @@ server.distributedLockExpireTime=10000
 server.xaerNotaRetryTimeout=60000
 server.session.branchAsyncQueueSize=5000
 server.session.enableBranchAsyncRemove=false
+server.enableParallelRequestHandle=false
 
 #Metrics configuration, only for the server
 metrics.enabled=false

diff --git a/.../src/main/java/io/seata/spring/boot/autoconfigure/properties/server/ServerProperties.java b/.../src/main/java/io/seata/spring/boot/autoconfigure/properties/server/ServerProperties.java
@@ -33,6 +33,7 @@ public class ServerProperties {
     private Duration maxRollbackRetryTimeout = DurationUtil.DEFAULT_DURATION;
     private Boolean rollbackRetryTimeoutUnlockEnable = false;
     private Boolean enableCheckAuth = true;
+    private Boolean enableParallelRequestHandle = false;
     private Integer retryDeadThreshold = 130000;
     private Integer servicePort;
     private Integer xaerNotaRetryTimeout = 60000;
@@ -98,4 +99,12 @@ public Integer getXaerNotaRetryTimeout() {
     public void setXaerNotaRetryTimeout(Integer xaerNotaRetryTimeout) {
         this.xaerNotaRetryTimeout = xaerNotaRetryTimeout;
     }
+
+    public Boolean getEnableParallelRequestHandle() {
+        return enableParallelRequestHandle;
+    }
+
+    public void setEnableParallelRequestHandle(Boolean enableParallelRequestHandle) {
+        this.enableParallelRequestHandle = enableParallelRequestHandle;
+    }
 }
diff --git a/server/src/main/resources/application.example.yml b/server/src/main/resources/application.example.yml
@@ -104,9 +104,10 @@ seata:
     max-commit-retry-timeout: -1
     max-rollback-retry-timeout: -1
     rollback-retry-timeout-unlock-enable: false
-    enableCheckAuth: true
-    retryDeadThreshold: 130000
-    xaerNotaRetryTimeout: 60000
+    enable-check-auth: true
+    enable-parallel-request-handle: true
+    retry-dead-threshold: 130000
+    xaer-nota-retry-timeout: 60000
     recovery:
       handle-all-session-period: 1000
     undo: