opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 02:23:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #6438] Optimizing the memory usage of MultiProtocolRemotingServer (#6439)

Browse Source
This commit is contained in:
lk
2023-03-22 19:09:49 +08:00
committed by GitHub
parent c17baf1e33
commit e3b5f07ae8
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolRemotingServer.java
+12 -7
View File
@@ -44,9 +44,19 @@ public class MultiProtocolRemotingServer extends NettyRemotingServer {
private final static Logger log = LoggerFactory.getLogger(LoggerName.PROXY_LOGGER_NAME);
private final NettyServerConfig nettyServerConfig;
private final RemotingProtocolHandler remotingProtocolHandler;
private final Http2ProtocolProxyHandler http2ProtocolProxyHandler;
public MultiProtocolRemotingServer(NettyServerConfig nettyServerConfig, ChannelEventListener channelEventListener) {
super(nettyServerConfig, channelEventListener);
this.nettyServerConfig = nettyServerConfig;
this.remotingProtocolHandler = new RemotingProtocolHandler(
this.getEncoder(),
this.getDistributionHandler(),
this.getConnectionManageHandler(),
this.getServerHandler());
this.http2ProtocolProxyHandler = new Http2ProtocolProxyHandler();
}
@Override
@@ -70,13 +80,8 @@ public class MultiProtocolRemotingServer extends NettyRemotingServer {
.addLast(this.getDefaultEventExecutorGroup(), HANDSHAKE_HANDLER_NAME, this.getHandshakeHandler())
.addLast(this.getDefaultEventExecutorGroup(),
new IdleStateHandler(0, 0, nettyServerConfig.getServerChannelMaxIdleTimeSeconds()),
new ProtocolNegotiationHandler(
new RemotingProtocolHandler(
this.getEncoder(),
this.getDistributionHandler(),
this.getConnectionManageHandler(),
this.getServerHandler()))
.addProtocolHandler(new Http2ProtocolProxyHandler())
new ProtocolNegotiationHandler(this.remotingProtocolHandler)
.addProtocolHandler(this.http2ProtocolProxyHandler)
);
}
}