[dubbo] branch 3.2 updated: triple server batch flush (#11723)

[guohao]

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

guohao pushed a commit to branch 3.2
in repository https://gitbox.apache.org/repos/asf/dubbo.git


The following commit(s) were added to refs/heads/3.2 by this push:
     new 92421ba634 triple server batch flush (#11723)
92421ba634 is described below

commit 92421ba6342d41a0bfdda9c80c21cac69062b66a
Author: icodening <cleverb...@gmail.com>
AuthorDate: Fri Mar 24 14:04:53 2023 +0800

    triple server batch flush (#11723)
    
    Co-authored-by: earthchen <earthchen1...@gmail.com>
---
 .../java/org/apache/dubbo/rpc/protocol/tri/TripleHttp2Protocol.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleHttp2Protocol.java
 
b/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleHttp2Protocol.java
index 321af9d614..69259ead06 100644
--- 
a/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleHttp2Protocol.java
+++ 
b/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleHttp2Protocol.java
@@ -47,6 +47,7 @@ import io.netty.handler.codec.http2.Http2FrameLogger;
 import io.netty.handler.codec.http2.Http2MultiplexHandler;
 import io.netty.handler.codec.http2.Http2Settings;
 import io.netty.handler.codec.http2.Http2StreamChannel;
+import io.netty.handler.flush.FlushConsolidationHandler;
 import io.netty.handler.logging.LogLevel;
 
 import java.util.ArrayList;
@@ -141,6 +142,7 @@ public class TripleHttp2Protocol extends 
AbstractWireProtocol implements ScopeMo
             });
         List<ChannelHandler> handlers = new ArrayList<>();
         handlers.add(new ChannelHandlerPretender(codec));
+        handlers.add(new ChannelHandlerPretender(new 
FlushConsolidationHandler(64, true)));
         handlers.add(new ChannelHandlerPretender(new 
TripleServerConnectionHandler()));
         handlers.add(new ChannelHandlerPretender(handler));
         handlers.add(new ChannelHandlerPretender(new TripleTailHandler()));