(rocketmq) branch develop updated: [ISSUE #8720] Support disable netty server worker group by config (#8721)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 845f468129 [ISSUE #8720] Support disable netty server worker group by 
config (#8721)
845f468129 is described below

commit 845f468129b2c4159bf0d5e5854f441b67e3c73c
Author: lizhimins <707364...@qq.com>
AuthorDate: Fri Sep 20 17:19:23 2024 +0800

    [ISSUE #8720] Support disable netty server worker group by config (#8721)
---
 .../org/apache/rocketmq/remoting/netty/NettyRemotingServer.java  | 5 +++--
 .../org/apache/rocketmq/remoting/netty/NettyServerConfig.java    | 9 +++++++++
 2 files changed, 12 insertions(+), 2 deletions(-)

diff --git 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java
 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java
index 8a329a37ac..cbf25c23c6 100644
--- 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java
+++ 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java
@@ -270,8 +270,9 @@ public class NettyRemotingServer extends 
NettyRemotingAbstract implements Remoti
      */
     protected ChannelPipeline configChannel(SocketChannel ch) {
         return ch.pipeline()
-            .addLast(defaultEventExecutorGroup, HANDSHAKE_HANDLER_NAME, new 
HandshakeHandler())
-            .addLast(defaultEventExecutorGroup,
+            .addLast(nettyServerConfig.isServerNettyWorkerGroupEnable() ? 
defaultEventExecutorGroup : null,
+                HANDSHAKE_HANDLER_NAME, new HandshakeHandler())
+            .addLast(nettyServerConfig.isServerNettyWorkerGroupEnable() ? 
defaultEventExecutorGroup : null,
                 encoder,
                 new NettyDecoder(),
                 distributionHandler,
diff --git 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java
 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java
index 6564404b92..664dee8371 100644
--- 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java
+++ 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java
@@ -36,6 +36,7 @@ public class NettyServerConfig implements Cloneable {
     private int writeBufferHighWaterMark = 
NettySystemConfig.writeBufferHighWaterMark;
     private int writeBufferLowWaterMark = 
NettySystemConfig.writeBufferLowWaterMark;
     private int serverSocketBacklog = NettySystemConfig.socketBacklog;
+    private boolean serverNettyWorkerGroupEnable = true;
     private boolean serverPooledByteBufAllocatorEnable = true;
 
     private boolean enableShutdownGracefully = false;
@@ -175,6 +176,14 @@ public class NettyServerConfig implements Cloneable {
         this.writeBufferHighWaterMark = writeBufferHighWaterMark;
     }
 
+    public boolean isServerNettyWorkerGroupEnable() {
+        return serverNettyWorkerGroupEnable;
+    }
+
+    public void setServerNettyWorkerGroupEnable(boolean 
serverNettyWorkerGroupEnable) {
+        this.serverNettyWorkerGroupEnable = serverNettyWorkerGroupEnable;
+    }
+
     public boolean isEnableShutdownGracefully() {
         return enableShutdownGracefully;
     }