#1099, worker group and user group share the acceptor.size configuration

sharding-core/src/main/java/io/shardingsphere/core/constant/ShardingPropertiesConstant.java

@@ -42,6 +42,17 @@ public enum ShardingPropertiesConstant {
      */
     SQL_SHOW("sql.show", Boolean.FALSE.toString(), boolean.class),
     
+    /**
+     * Worker group or user group thread max size.
+     *
+     * <p>
+     * Worker group accept tcp connection.
+     * User group accept MySQL command.
+     * Default: CPU cores * 2.
+     * </p>
+     */
+    ACCEPTOR_SIZE("acceptor.size", String.valueOf(Runtime.getRuntime().availableProcessors() * 2), int.class),
+    
     /**
      * Worker thread max size.
      * 

sharding-proxy/src/main/java/io/shardingsphere/proxy/config/RuleRegistry.java

@@ -75,6 +75,8 @@ public final class RuleRegistry {
     
     private ConnectionMode connectionMode;
     
+    private int acceptorSize;
+    
     private int executorSize;
     
     private BackendNIOConfiguration backendNIOConfig;
@@ -108,6 +110,7 @@ public final class RuleRegistry {
         connectionMode = ConnectionMode.valueOf(shardingProperties.<String>getValue(ShardingPropertiesConstant.CONNECTION_MODE));
         transactionType = TransactionType.valueOf(shardingProperties.<String>getValue(ShardingPropertiesConstant.PROXY_TRANSACTION_MODE));
         transactionManager = ProxyTransactionLoader.load(transactionType);
+        acceptorSize = shardingProperties.getValue(ShardingPropertiesConstant.ACCEPTOR_SIZE);
         executorSize = shardingProperties.getValue(ShardingPropertiesConstant.EXECUTOR_SIZE);
         // TODO :jiaqi force off use NIO for backend, this feature is not complete yet
         boolean useNIO = false;

sharding-proxy/src/main/java/io/shardingsphere/proxy/frontend/ShardingProxy.java

@@ -101,8 +101,8 @@ public final class ShardingProxy {
     }
     
     private void groupsEpoll(final ServerBootstrap bootstrap) {
-        workerGroup = new EpollEventLoopGroup(RULE_REGISTRY.getExecutorSize());
-        userGroupContext.setUserGroup(new EpollEventLoopGroup(RULE_REGISTRY.getExecutorSize()));
+        workerGroup = new EpollEventLoopGroup(RULE_REGISTRY.getAcceptorSize());
+        userGroupContext.setUserGroup(new EpollEventLoopGroup(RULE_REGISTRY.getAcceptorSize()));
         bootstrap.group(bossGroup, workerGroup)
             .channel(EpollServerSocketChannel.class)
             .option(EpollChannelOption.SO_BACKLOG, 128)
@@ -114,8 +114,8 @@ public final class ShardingProxy {
     }
     
     private void groupsNio(final ServerBootstrap bootstrap) {
-        workerGroup = new NioEventLoopGroup(RULE_REGISTRY.getExecutorSize());
-        userGroupContext.setUserGroup(new NioEventLoopGroup(RULE_REGISTRY.getExecutorSize()));
+        workerGroup = new NioEventLoopGroup(RULE_REGISTRY.getAcceptorSize());
+        userGroupContext.setUserGroup(new NioEventLoopGroup(RULE_REGISTRY.getAcceptorSize()));
         bootstrap.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             .option(ChannelOption.SO_BACKLOG, 128)

sharding-proxy/src/main/resources/conf/config.yaml

@@ -61,6 +61,7 @@
 #    # CONNECTION_STRICTLY: Proxy will release connections after get the overall rows from the ResultSet.
 #    #                      Meanwhile, the cost of the memory will be increased.
 #    connection.mode: MEMORY_STRICTLY
+#    acceptor.size: 16  # The default value is available processors count * 2.
 #    executor.size: 16  # The default value is available processors count.
 #    sql.show: false
 #

sharding-proxy/src/main/resources/conf/config_master_slave.yaml

@@ -40,6 +40,7 @@
 #    # CONNECTION_STRICTLY: Proxy will release connections after get the overall rows from the ResultSet.
 #    #                      Meanwhile, the cost of the memory will be increased.
 #    connection.mode: MEMORY_STRICTLY
+#    acceptor.size: 16  # The default value is available processors count * 2.
 #    executor.size: 16  # The default value is available processors count.
 #    sql.show: false
 

sharding-proxy/src/test/resources/conf/config.yaml

@@ -45,6 +45,7 @@ shardingRule:
 
   props:
     connection.mode: MEMORY_STRICTLY
+    acceptor.size: 16
     executor.size: 16
     sql.show: false