Lanmikeman/Launcher
1
1
Fork 0
mirror of https://github.com/GravitLauncher/Launcher synced 2024-12-23 00:51:01 +03:00
Code Issues Projects Releases Packages Wiki Activity

[FEATURE] Netty maxWebSocketRequestBytes

Browse source
This commit is contained in:
Gravit 2020-11-21 20:33:10 +07:00
parent ae2ef5e7c2
commit 5e048905cc
No known key found for this signature in database
GPG key ID: 98A079490768CCE5
2 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
LaunchServer/src/main/java/pro/gravit/launchserver/config/LaunchServerConfig.java
View file

@ -313,6 +313,7 @@ public static class NettyPerformanceConfig {
public int bossThread; public int bossThread;
public int workerThread; public int workerThread;
public long sessionLifetimeMs = 24 * 60 * 60 * 1000; public long sessionLifetimeMs = 24 * 60 * 60 * 1000;
public int maxWebSocketRequestBytes = 1024 * 1024;
} }
public static class NettyBindAddress { public static class NettyBindAddress {

2
LaunchServer/src/main/java/pro/gravit/launchserver/socket/LauncherNettyServer.java
View file

@ -56,7 +56,7 @@ public void initChannel(SocketChannel ch) {
NettyConnectContext context = new NettyConnectContext(); NettyConnectContext context = new NettyConnectContext();
//p.addLast(new LoggingHandler(LogLevel.INFO)); //p.addLast(new LoggingHandler(LogLevel.INFO));
pipeline.addLast("http-codec", new HttpServerCodec()); pipeline.addLast("http-codec", new HttpServerCodec());
pipeline.addLast("http-codec-compressor", new HttpObjectAggregator(65536)); pipeline.addLast("http-codec-compressor", new HttpObjectAggregator(server.config.netty.performance.maxWebSocketRequestBytes));
if (server.config.netty.ipForwarding) if (server.config.netty.ipForwarding)
pipeline.addLast("forward-http", new NettyIpForwardHandler(context)); pipeline.addLast("forward-http", new NettyIpForwardHandler(context));
pipeline.addLast("websock-comp", new WebSocketServerCompressionHandler()); pipeline.addLast("websock-comp", new WebSocketServerCompressionHandler());