From f6193e30498ef791a22cf8cba9e6571f13c07d10 Mon Sep 17 00:00:00 2001 From: jsbxyyx Date: Mon, 14 Dec 2020 20:50:59 +0800 Subject: [PATCH] optimize: get netty config property from system properties. (#3336) --- .../core/rpc/netty/NettyServerConfig.java | 24 ++++++++++++------- 1 file changed, 16 insertions(+), 8 deletions(-) diff --git a/core/src/main/java/io/seata/core/rpc/netty/NettyServerConfig.java b/core/src/main/java/io/seata/core/rpc/netty/NettyServerConfig.java index 71ff7b5d1cf..11d0c4e1e46 100644 --- a/core/src/main/java/io/seata/core/rpc/netty/NettyServerConfig.java +++ b/core/src/main/java/io/seata/core/rpc/netty/NettyServerConfig.java @@ -33,16 +33,24 @@ */ public class NettyServerConfig extends NettyBaseConfig { - private int serverSelectorThreads = WORKER_THREAD_SIZE; - private int serverSocketSendBufSize = 153600; - private int serverSocketResvBufSize = 153600; - private int serverWorkerThreads = WORKER_THREAD_SIZE; - private int soBackLogSize = 1024; - private int writeBufferHighWaterMark = 67108864; - private int writeBufferLowWaterMark = 1048576; + 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 static final int DEFAULT_LISTEN_PORT = 8091; private static final int RPC_REQUEST_TIMEOUT = 30 * 1000; - private int serverChannelMaxIdleTimeSeconds = 30; + private int serverChannelMaxIdleTimeSeconds = Integer.parseInt(System.getProperty( + ConfigurationKeys.TRANSPORT_PREFIX + "serverChannelMaxIdleTimeSeconds", String.valueOf(30))); private static final String EPOLL_WORKER_THREAD_PREFIX = "NettyServerEPollWorker"; /**