This is an automated email from the ASF dual-hosted git repository.
jianbin pushed a commit to branch 2.x
in repository https://gitbox.apache.org/repos/asf/incubator-seata.git
The following commit(s) were added to refs/heads/2.x by this push:
new 13546e82ea Refactor: server netty config changed to use CONFIG format
(#7461)
13546e82ea is described below
commit 13546e82ea5e9c6d90da8c81968208b6959b4039
Author: YoWuwuuuw <2216348...@qq.com>
AuthorDate: Sat Jun 21 20:46:01 2025 +0800
Refactor: server netty config changed to use CONFIG format (#7461)
---
changes/en-us/2.x.md | 1 +
changes/zh-cn/2.x.md | 1 +
.../org/apache/seata/common/DefaultValues.java | 50 ++++++++++
.../seata/core/rpc/netty/NettyServerConfig.java | 99 ++++++++++++--------
script/config-center/config.txt | 14 +++
.../properties/TransportProperties.java | 103 +++++++++++++++++++++
.../properties/TransportPropertiesTest.java | 20 ++++
7 files changed, 249 insertions(+), 39 deletions(-)
diff --git a/changes/en-us/2.x.md b/changes/en-us/2.x.md
index 0212ba8360..483bcd2b67 100644
--- a/changes/en-us/2.x.md
+++ b/changes/en-us/2.x.md
@@ -102,6 +102,7 @@ Add changes here for all PR submitted to the 2.x branch.
### refactor:
- [[#7315](https://github.com/apache/incubator-seata/pull/7315)] Refactor log
testing to use ListAppender for more accurate and efficient log capture
+- [[#7461](https://github.com/apache/incubator-seata/pull/7461)] Refactor
server netty config changed to use CONFIG format
### doc:
diff --git a/changes/zh-cn/2.x.md b/changes/zh-cn/2.x.md
index 1fe6b3881e..29bb3d6c75 100644
--- a/changes/zh-cn/2.x.md
+++ b/changes/zh-cn/2.x.md
@@ -104,6 +104,7 @@
### refactor:
- [[#7315](https://github.com/apache/incubator-seata/pull/7315)]
重构日志测试，使用ListAppender实现更准确高效的日志捕获
+- [[#7461](https://github.com/apache/incubator-seata/pull/7461)] 重构 server
netty 配置改为使用 CONFIG 格式
### doc:
diff --git a/common/src/main/java/org/apache/seata/common/DefaultValues.java
b/common/src/main/java/org/apache/seata/common/DefaultValues.java
index 03c62644fd..53427b7f79 100644
--- a/common/src/main/java/org/apache/seata/common/DefaultValues.java
+++ b/common/src/main/java/org/apache/seata/common/DefaultValues.java
@@ -181,6 +181,56 @@ public interface DefaultValues {
*/
int DEFAULT_HTTP_POOL_KEEP_ALIVE_TIME = 500;
+ /**
+ * The constant DEFAULT_SERVER_SOCKET_SEND_BUF_SIZE.
+ */
+ int DEFAULT_SERVER_SOCKET_SEND_BUF_SIZE = 153600;
+
+ /**
+ * The constant DEFAULT_SERVER_SOCKET_RESV_BUF_SIZE.
+ */
+ int DEFAULT_SERVER_SOCKET_RESV_BUF_SIZE = 153600;
+
+ /**
+ * The constant DEFAULT_WRITE_BUFFER_HIGH_WATER_MARK.
+ */
+ int DEFAULT_WRITE_BUFFER_HIGH_WATER_MARK = 67108864;
+
+ /**
+ * The constant DEFAULT_WRITE_BUFFER_LOW_WATER_MARK.
+ */
+ int DEFAULT_WRITE_BUFFER_LOW_WATER_MARK = 1048576;
+
+ /**
+ * The constant DEFAULT_SO_BACK_LOG_SIZE.
+ */
+ int DEFAULT_SO_BACK_LOG_SIZE = 1024;
+
+ /**
+ * The constant DEFAULT_SERVER_CHANNEL_MAX_IDLE_TIME_SECONDS.
+ */
+ int DEFAULT_SERVER_CHANNEL_MAX_IDLE_TIME_SECONDS = 30;
+
+ /**
+ * The constant DEFAULT_MIN_SERVER_POOL_SIZE.
+ */
+ int DEFAULT_MIN_SERVER_POOL_SIZE = 50;
+
+ /**
+ * The constant DEFAULT_MAX_SERVER_POOL_SIZE.
+ */
+ int DEFAULT_MAX_SERVER_POOL_SIZE = 500;
+
+ /**
+ * The constant DEFAULT_MAX_TASK_QUEUE_SIZE.
+ */
+ int DEFAULT_MAX_TASK_QUEUE_SIZE = 20000;
+
+ /**
+ * The constant DEFAULT_KEEP_ALIVE_TIME.
+ */
+ int DEFAULT_KEEP_ALIVE_TIME = 500;
+
/**
* The constant DEFAULT_TRANSPORT_HEARTBEAT.
*/
diff --git
a/core/src/main/java/org/apache/seata/core/rpc/netty/NettyServerConfig.java
b/core/src/main/java/org/apache/seata/core/rpc/netty/NettyServerConfig.java
index b07db90055..5450cc499d 100644
--- a/core/src/main/java/org/apache/seata/core/rpc/netty/NettyServerConfig.java
+++ b/core/src/main/java/org/apache/seata/core/rpc/netty/NettyServerConfig.java
@@ -26,54 +26,74 @@ import static
org.apache.seata.common.DefaultValues.DEFAULT_BOSS_THREAD_PREFIX;
import static org.apache.seata.common.DefaultValues.DEFAULT_BOSS_THREAD_SIZE;
import static
org.apache.seata.common.DefaultValues.DEFAULT_EXECUTOR_THREAD_PREFIX;
import static
org.apache.seata.common.DefaultValues.DEFAULT_NIO_WORKER_THREAD_PREFIX;
-import static
org.apache.seata.common.DefaultValues.DEFAULT_RPC_TC_REQUEST_TIMEOUT;
import static
org.apache.seata.common.DefaultValues.DEFAULT_SHUTDOWN_TIMEOUT_SEC;
/**
* The type Netty server config.
- *
*/
public class NettyServerConfig extends NettyBaseConfig {
+ private int serverListenPort = 0;
+ private static final String EPOLL_WORKER_THREAD_PREFIX =
"NettyServerEPollWorker";
+ // Network Buffer Config
+ private int serverSocketSendBufSize = CONFIG.getInt(
+ ConfigurationKeys.TRANSPORT_PREFIX + "serverSocketSendBufSize",
+ DefaultValues.DEFAULT_SERVER_SOCKET_SEND_BUF_SIZE);
+ private int serverSocketResvBufSize = CONFIG.getInt(
+ ConfigurationKeys.TRANSPORT_PREFIX + "serverSocketResvBufSize",
+ DefaultValues.DEFAULT_SERVER_SOCKET_RESV_BUF_SIZE);
+ private int writeBufferHighWaterMark = CONFIG.getInt(
+ ConfigurationKeys.TRANSPORT_PREFIX + "writeBufferHighWaterMark",
+ DefaultValues.DEFAULT_WRITE_BUFFER_HIGH_WATER_MARK);
+ private int writeBufferLowWaterMark = CONFIG.getInt(
+ ConfigurationKeys.TRANSPORT_PREFIX + "writeBufferLowWaterMark",
+ DefaultValues.DEFAULT_WRITE_BUFFER_LOW_WATER_MARK);
+
+ // Connection Management
+ private int soBackLogSize =
+ CONFIG.getInt(ConfigurationKeys.TRANSPORT_PREFIX +
"soBackLogSize", DefaultValues.DEFAULT_SO_BACK_LOG_SIZE);
+ private int serverChannelMaxIdleTimeSeconds = CONFIG.getInt(
+ ConfigurationKeys.TRANSPORT_PREFIX +
"serverChannelMaxIdleTimeSeconds",
+ DefaultValues.DEFAULT_SERVER_CHANNEL_MAX_IDLE_TIME_SECONDS);
+
+ // RPC Configuration
+ private static final long RPC_TC_REQUEST_TIMEOUT =
+ CONFIG.getLong(ConfigurationKeys.RPC_TC_REQUEST_TIMEOUT,
DefaultValues.DEFAULT_RPC_TC_REQUEST_TIMEOUT);
+ private static boolean ENABLE_TC_SERVER_BATCH_SEND_RESPONSE =
CONFIG.getBoolean(
+ ConfigurationKeys.ENABLE_TC_SERVER_BATCH_SEND_RESPONSE,
+ DefaultValues.DEFAULT_ENABLE_TC_SERVER_BATCH_SEND_RESPONSE);
+
+ // Thread Pool Config
private int serverSelectorThreads = Integer.parseInt(System.getProperty(
ConfigurationKeys.TRANSPORT_PREFIX + "serverSelectorThreads",
String.valueOf(WORKER_THREAD_SIZE)));
- private int serverSocketSendBufSize = Integer.parseInt(
- System.getProperty(ConfigurationKeys.TRANSPORT_PREFIX +
"serverSocketSendBufSize", String.valueOf(153600)));
- private int serverSocketResvBufSize = Integer.parseInt(
- System.getProperty(ConfigurationKeys.TRANSPORT_PREFIX +
"serverSocketResvBufSize", String.valueOf(153600)));
private int serverWorkerThreads = Integer.parseInt(System.getProperty(
ConfigurationKeys.TRANSPORT_PREFIX + "serverWorkerThreads",
String.valueOf(WORKER_THREAD_SIZE)));
- private int soBackLogSize = Integer.parseInt(
- System.getProperty(ConfigurationKeys.TRANSPORT_PREFIX +
"soBackLogSize", String.valueOf(1024)));
- private int writeBufferHighWaterMark = Integer.parseInt(System.getProperty(
- ConfigurationKeys.TRANSPORT_PREFIX + "writeBufferHighWaterMark",
String.valueOf(67108864)));
- private int writeBufferLowWaterMark = Integer.parseInt(System.getProperty(
- ConfigurationKeys.TRANSPORT_PREFIX + "writeBufferLowWaterMark",
String.valueOf(1048576)));
- private int serverListenPort = 0;
- private static final long RPC_TC_REQUEST_TIMEOUT =
- CONFIG.getLong(ConfigurationKeys.RPC_TC_REQUEST_TIMEOUT,
DEFAULT_RPC_TC_REQUEST_TIMEOUT);
- private int serverChannelMaxIdleTimeSeconds =
Integer.parseInt(System.getProperty(
- ConfigurationKeys.TRANSPORT_PREFIX +
"serverChannelMaxIdleTimeSeconds", String.valueOf(30)));
- private static final String EPOLL_WORKER_THREAD_PREFIX =
"NettyServerEPollWorker";
+
+ // Seata and Grpc Protocol Thread Pool
private static int minServerPoolSize =
-
Integer.parseInt(System.getProperty(ConfigurationKeys.MIN_SERVER_POOL_SIZE,
"50"));
+ CONFIG.getInt(ConfigurationKeys.MIN_SERVER_POOL_SIZE,
DefaultValues.DEFAULT_MIN_SERVER_POOL_SIZE);
private static int maxServerPoolSize =
-
Integer.parseInt(System.getProperty(ConfigurationKeys.MAX_SERVER_POOL_SIZE,
"500"));
+ CONFIG.getInt(ConfigurationKeys.MAX_SERVER_POOL_SIZE,
DefaultValues.DEFAULT_MAX_SERVER_POOL_SIZE);
private static int maxTaskQueueSize =
-
Integer.parseInt(System.getProperty(ConfigurationKeys.MAX_TASK_QUEUE_SIZE,
"20000"));
- private static int keepAliveTime =
Integer.parseInt(System.getProperty(ConfigurationKeys.KEEP_ALIVE_TIME, "500"));
+ CONFIG.getInt(ConfigurationKeys.MAX_TASK_QUEUE_SIZE,
DefaultValues.DEFAULT_MAX_TASK_QUEUE_SIZE);
+ private static int keepAliveTime =
+ CONFIG.getInt(ConfigurationKeys.KEEP_ALIVE_TIME,
DefaultValues.DEFAULT_KEEP_ALIVE_TIME);
+
+ // HTTP Protocol Thread Pool
+ private static int minHttpPoolSize =
+ CONFIG.getInt(ConfigurationKeys.MIN_HTTP_POOL_SIZE,
DefaultValues.DEFAULT_MIN_HTTP_POOL_SIZE);
+ private static int maxHttpPoolSize =
+ CONFIG.getInt(ConfigurationKeys.MAX_HTTP_POOL_SIZE,
DefaultValues.DEFAULT_MAX_HTTP_POOL_SIZE);
+ private static int maxHttpTaskQueueSize =
+ CONFIG.getInt(ConfigurationKeys.MAX_HTTP_TASK_QUEUE_SIZE,
DefaultValues.DEFAULT_MAX_HTTP_TASK_QUEUE_SIZE);
+ private static int httpKeepAliveTime =
+ CONFIG.getInt(ConfigurationKeys.HTTP_POOL_KEEP_ALIVE_TIME,
DefaultValues.DEFAULT_HTTP_POOL_KEEP_ALIVE_TIME);
+
+ // Branch Result Thread Pool
private static int minBranchResultPoolSize =
Integer.parseInt(System.getProperty(
ConfigurationKeys.MIN_BRANCH_RESULT_POOL_SIZE,
String.valueOf(WorkThreadMode.Pin.getValue())));
private static int maxBranchResultPoolSize =
Integer.parseInt(System.getProperty(
ConfigurationKeys.MAX_BRANCH_RESULT_POOL_SIZE,
String.valueOf(WorkThreadMode.Pin.getValue())));
- private static boolean ENABLE_TC_SERVER_BATCH_SEND_RESPONSE =
CONFIG.getBoolean(
- ConfigurationKeys.ENABLE_TC_SERVER_BATCH_SEND_RESPONSE,
- DefaultValues.DEFAULT_ENABLE_TC_SERVER_BATCH_SEND_RESPONSE);
-
- private static int minHttpPoolSize =
CONFIG.getInt(ConfigurationKeys.MIN_HTTP_POOL_SIZE, 10);
- private static int maxHttpPoolSize =
CONFIG.getInt(ConfigurationKeys.MAX_HTTP_POOL_SIZE, 100);
- private static int maxHttpTaskQueueSize =
CONFIG.getInt(ConfigurationKeys.MAX_HTTP_TASK_QUEUE_SIZE, 1000);
- private static int httpKeepAliveTime =
CONFIG.getInt(ConfigurationKeys.HTTP_POOL_KEEP_ALIVE_TIME, 500);
/**
* The Server channel clazz.
@@ -334,6 +354,15 @@ public class NettyServerConfig extends NettyBaseConfig {
return httpKeepAliveTime;
}
+ /**
+ * Get the tc server batch send response enable
+ *
+ * @return true or false
+ */
+ public static boolean isEnableTcServerBatchSendResponse() {
+ return ENABLE_TC_SERVER_BATCH_SEND_RESPONSE;
+ }
+
/**
* Get the min size for branch result thread pool
*
@@ -342,6 +371,7 @@ public class NettyServerConfig extends NettyBaseConfig {
public static int getMinBranchResultPoolSize() {
return minBranchResultPoolSize;
}
+
/**
* Get the max size for branch result thread pool
*
@@ -350,13 +380,4 @@ public class NettyServerConfig extends NettyBaseConfig {
public static int getMaxBranchResultPoolSize() {
return maxBranchResultPoolSize;
}
-
- /**
- * Get the tc server batch send response enable
- *
- * @return true or false
- */
- public static boolean isEnableTcServerBatchSendResponse() {
- return ENABLE_TC_SERVER_BATCH_SEND_RESPONSE;
- }
}
diff --git a/script/config-center/config.txt b/script/config-center/config.txt
index 84c0b678c5..1cf9422126 100644
--- a/script/config-center/config.txt
+++ b/script/config-center/config.txt
@@ -46,6 +46,20 @@ transport.maxHttpPoolSize=100
transport.maxHttpTaskQueueSize=1000
transport.httpPoolKeepAliveTime=500
+transport.serverSocketSendBufSize=153600
+transport.serverSocketResvBufSize=153600
+transport.writeBufferHighWaterMark=67108864
+transport.writeBufferLowWaterMark=1048576
+
+transport.soBackLogSize=1024
+transport.serverChannelMaxIdleTimeSeconds=30
+
+transport.minServerPoolSize=50
+transport.maxServerPoolSize=500
+transport.maxTaskQueueSize=20000
+transport.keepAliveTime=500
+
+
#Transaction routing rules configuration, only for the client
service.vgroupMapping.default_tx_group=default
#If you use a registry, you can ignore it
diff --git
a/seata-spring-autoconfigure/seata-spring-autoconfigure-core/src/main/java/org/apache/seata/spring/boot/autoconfigure/properties/TransportProperties.java
b/seata-spring-autoconfigure/seata-spring-autoconfigure-core/src/main/java/org/apache/seata/spring/boot/autoconfigure/properties/TransportProperties.java
index a64ca0a86d..764eb3affb 100644
---
a/seata-spring-autoconfigure/seata-spring-autoconfigure-core/src/main/java/org/apache/seata/spring/boot/autoconfigure/properties/TransportProperties.java
+++
b/seata-spring-autoconfigure/seata-spring-autoconfigure-core/src/main/java/org/apache/seata/spring/boot/autoconfigure/properties/TransportProperties.java
@@ -25,14 +25,24 @@ import static
org.apache.seata.common.DefaultValues.DEFAULT_ENABLE_RM_CLIENT_BAT
import static
org.apache.seata.common.DefaultValues.DEFAULT_ENABLE_TC_SERVER_BATCH_SEND_RESPONSE;
import static
org.apache.seata.common.DefaultValues.DEFAULT_ENABLE_TM_CLIENT_BATCH_SEND_REQUEST;
import static
org.apache.seata.common.DefaultValues.DEFAULT_HTTP_POOL_KEEP_ALIVE_TIME;
+import static org.apache.seata.common.DefaultValues.DEFAULT_KEEP_ALIVE_TIME;
import static org.apache.seata.common.DefaultValues.DEFAULT_MAX_HTTP_POOL_SIZE;
import static
org.apache.seata.common.DefaultValues.DEFAULT_MAX_HTTP_TASK_QUEUE_SIZE;
+import static
org.apache.seata.common.DefaultValues.DEFAULT_MAX_SERVER_POOL_SIZE;
+import static
org.apache.seata.common.DefaultValues.DEFAULT_MAX_TASK_QUEUE_SIZE;
import static org.apache.seata.common.DefaultValues.DEFAULT_MIN_HTTP_POOL_SIZE;
+import static
org.apache.seata.common.DefaultValues.DEFAULT_MIN_SERVER_POOL_SIZE;
import static org.apache.seata.common.DefaultValues.DEFAULT_PROTOCOL;
import static
org.apache.seata.common.DefaultValues.DEFAULT_RPC_RM_REQUEST_TIMEOUT;
import static
org.apache.seata.common.DefaultValues.DEFAULT_RPC_TC_REQUEST_TIMEOUT;
import static
org.apache.seata.common.DefaultValues.DEFAULT_RPC_TM_REQUEST_TIMEOUT;
+import static
org.apache.seata.common.DefaultValues.DEFAULT_SERVER_CHANNEL_MAX_IDLE_TIME_SECONDS;
+import static
org.apache.seata.common.DefaultValues.DEFAULT_SERVER_SOCKET_RESV_BUF_SIZE;
+import static
org.apache.seata.common.DefaultValues.DEFAULT_SERVER_SOCKET_SEND_BUF_SIZE;
+import static org.apache.seata.common.DefaultValues.DEFAULT_SO_BACK_LOG_SIZE;
import static
org.apache.seata.common.DefaultValues.DEFAULT_TRANSPORT_HEARTBEAT;
+import static
org.apache.seata.common.DefaultValues.DEFAULT_WRITE_BUFFER_HIGH_WATER_MARK;
+import static
org.apache.seata.common.DefaultValues.DEFAULT_WRITE_BUFFER_LOW_WATER_MARK;
import static
org.apache.seata.spring.boot.autoconfigure.StarterConstants.TRANSPORT_PREFIX;
@Component
@@ -121,6 +131,19 @@ public class TransportProperties {
*/
private int httpPoolKeepAliveTime = DEFAULT_HTTP_POOL_KEEP_ALIVE_TIME;
+ private int serverSocketSendBufSize = DEFAULT_SERVER_SOCKET_SEND_BUF_SIZE;
+ private int serverSocketResvBufSize = DEFAULT_SERVER_SOCKET_RESV_BUF_SIZE;
+ private int writeBufferHighWaterMark =
DEFAULT_WRITE_BUFFER_HIGH_WATER_MARK;
+ private int writeBufferLowWaterMark = DEFAULT_WRITE_BUFFER_LOW_WATER_MARK;
+
+ private int soBackLogSize = DEFAULT_SO_BACK_LOG_SIZE;
+ private int serverChannelMaxIdleTimeSeconds =
DEFAULT_SERVER_CHANNEL_MAX_IDLE_TIME_SECONDS;
+
+ private int minServerPoolSize = DEFAULT_MIN_SERVER_POOL_SIZE;
+ private int maxServerPoolSize = DEFAULT_MAX_SERVER_POOL_SIZE;
+ private int maxTaskQueueSize = DEFAULT_MAX_TASK_QUEUE_SIZE;
+ private int keepAliveTime = DEFAULT_KEEP_ALIVE_TIME;
+
public String getType() {
return type;
}
@@ -272,4 +295,84 @@ public class TransportProperties {
public void setHttpPoolKeepAliveTime(int httpPoolKeepAliveTime) {
this.httpPoolKeepAliveTime = httpPoolKeepAliveTime;
}
+
+ public int getServerSocketSendBufSize() {
+ return serverSocketSendBufSize;
+ }
+
+ public void setServerSocketSendBufSize(int serverSocketSendBufSize) {
+ this.serverSocketSendBufSize = serverSocketSendBufSize;
+ }
+
+ public int getServerSocketResvBufSize() {
+ return serverSocketResvBufSize;
+ }
+
+ public void setServerSocketResvBufSize(int serverSocketResvBufSize) {
+ this.serverSocketResvBufSize = serverSocketResvBufSize;
+ }
+
+ public int getWriteBufferHighWaterMark() {
+ return writeBufferHighWaterMark;
+ }
+
+ public void setWriteBufferHighWaterMark(int writeBufferHighWaterMark) {
+ this.writeBufferHighWaterMark = writeBufferHighWaterMark;
+ }
+
+ public int getWriteBufferLowWaterMark() {
+ return writeBufferLowWaterMark;
+ }
+
+ public void setWriteBufferLowWaterMark(int writeBufferLowWaterMark) {
+ this.writeBufferLowWaterMark = writeBufferLowWaterMark;
+ }
+
+ public int getSoBackLogSize() {
+ return soBackLogSize;
+ }
+
+ public void setSoBackLogSize(int soBackLogSize) {
+ this.soBackLogSize = soBackLogSize;
+ }
+
+ public int getServerChannelMaxIdleTimeSeconds() {
+ return serverChannelMaxIdleTimeSeconds;
+ }
+
+ public void setServerChannelMaxIdleTimeSeconds(int
serverChannelMaxIdleTimeSeconds) {
+ this.serverChannelMaxIdleTimeSeconds = serverChannelMaxIdleTimeSeconds;
+ }
+
+ public int getMinServerPoolSize() {
+ return minServerPoolSize;
+ }
+
+ public void setMinServerPoolSize(int minServerPoolSize) {
+ this.minServerPoolSize = minServerPoolSize;
+ }
+
+ public int getMaxServerPoolSize() {
+ return maxServerPoolSize;
+ }
+
+ public void setMaxServerPoolSize(int maxServerPoolSize) {
+ this.maxServerPoolSize = maxServerPoolSize;
+ }
+
+ public int getMaxTaskQueueSize() {
+ return maxTaskQueueSize;
+ }
+
+ public void setMaxTaskQueueSize(int maxTaskQueueSize) {
+ this.maxTaskQueueSize = maxTaskQueueSize;
+ }
+
+ public int getKeepAliveTime() {
+ return keepAliveTime;
+ }
+
+ public void setKeepAliveTime(int keepAliveTime) {
+ this.keepAliveTime = keepAliveTime;
+ }
}
diff --git
a/seata-spring-autoconfigure/seata-spring-autoconfigure-core/src/test/java/org/apache/seata/spring/boot/autoconfigure/properties/TransportPropertiesTest.java
b/seata-spring-autoconfigure/seata-spring-autoconfigure-core/src/test/java/org/apache/seata/spring/boot/autoconfigure/properties/TransportPropertiesTest.java
index f57134f499..4294ff5f7f 100644
---
a/seata-spring-autoconfigure/seata-spring-autoconfigure-core/src/test/java/org/apache/seata/spring/boot/autoconfigure/properties/TransportPropertiesTest.java
+++
b/seata-spring-autoconfigure/seata-spring-autoconfigure-core/src/test/java/org/apache/seata/spring/boot/autoconfigure/properties/TransportPropertiesTest.java
@@ -41,6 +41,16 @@ public class TransportPropertiesTest {
transportProperties.setMaxHttpPoolSize(200);
transportProperties.setMaxHttpTaskQueueSize(2000);
transportProperties.setHttpPoolKeepAliveTime(600);
+ transportProperties.setServerSocketSendBufSize(1024);
+ transportProperties.setServerSocketResvBufSize(2048);
+ transportProperties.setWriteBufferHighWaterMark(65536);
+ transportProperties.setWriteBufferLowWaterMark(32768);
+ transportProperties.setSoBackLogSize(512);
+ transportProperties.setServerChannelMaxIdleTimeSeconds(60);
+ transportProperties.setMinServerPoolSize(100);
+ transportProperties.setMaxServerPoolSize(1000);
+ transportProperties.setMaxTaskQueueSize(50000);
+ transportProperties.setKeepAliveTime(1000);
Assertions.assertEquals("server", transportProperties.getServer());
Assertions.assertEquals("type", transportProperties.getType());
@@ -59,5 +69,15 @@ public class TransportPropertiesTest {
Assertions.assertEquals(200, transportProperties.getMaxHttpPoolSize());
Assertions.assertEquals(2000,
transportProperties.getMaxHttpTaskQueueSize());
Assertions.assertEquals(600,
transportProperties.getHttpPoolKeepAliveTime());
+ Assertions.assertEquals(1024,
transportProperties.getServerSocketSendBufSize());
+ Assertions.assertEquals(2048,
transportProperties.getServerSocketResvBufSize());
+ Assertions.assertEquals(65536,
transportProperties.getWriteBufferHighWaterMark());
+ Assertions.assertEquals(32768,
transportProperties.getWriteBufferLowWaterMark());
+ Assertions.assertEquals(512, transportProperties.getSoBackLogSize());
+ Assertions.assertEquals(60,
transportProperties.getServerChannelMaxIdleTimeSeconds());
+ Assertions.assertEquals(100,
transportProperties.getMinServerPoolSize());
+ Assertions.assertEquals(1000,
transportProperties.getMaxServerPoolSize());
+ Assertions.assertEquals(50000,
transportProperties.getMaxTaskQueueSize());
+ Assertions.assertEquals(1000, transportProperties.getKeepAliveTime());
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@seata.apache.org
For additional commands, e-mail: notifications-h...@seata.apache.org
