open-source/MallChat
1
0
Fork 0
mirror of https://github.com/zongzibinbin/MallChat.git synced 2026-03-13 21:53:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #39 from TH1nker2/main

Browse Source 
netty服务的worker的EventLoopGroup大小根据当前cpu核心数动态获取
This commit is contained in:
zongzibinbin
2023-06-16 10:45:25 +08:00
committed by GitHub
parent ab7d06d333 a3eeb4ee9f
commit c8c20aa6ce
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
mallchat-custom-server/src/main/java/com/abin/mallchat/custom/user/websocket/NettyWebSocketServer.java
View File

@@ -15,6 +15,7 @@ import io.netty.handler.logging.LogLevel;
import io.netty.handler.logging.LoggingHandler; import io.netty.handler.logging.LoggingHandler;
import io.netty.handler.stream.ChunkedWriteHandler; import io.netty.handler.stream.ChunkedWriteHandler;
import io.netty.handler.timeout.IdleStateHandler; import io.netty.handler.timeout.IdleStateHandler;
import io.netty.util.NettyRuntime;
import io.netty.util.concurrent.Future; import io.netty.util.concurrent.Future;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
@@ -28,7 +29,7 @@ public class NettyWebSocketServer {
public static final int WEB_SOCKET_PORT = 8090; public static final int WEB_SOCKET_PORT = 8090;
// 创建线程池执行器 // 创建线程池执行器
private EventLoopGroup bossGroup = new NioEventLoopGroup(1); private EventLoopGroup bossGroup = new NioEventLoopGroup(1);
private EventLoopGroup workerGroup = new NioEventLoopGroup(8); private EventLoopGroup workerGroup = new NioEventLoopGroup(NettyRuntime.availableProcessors());
/** /**
* 启动 ws server * 启动 ws server