diff --git a/net/src/main/java/com/zfoo/net/core/AbstractServer.java b/net/src/main/java/com/zfoo/net/core/AbstractServer.java index 0b5ba396..41c0f990 100644 --- a/net/src/main/java/com/zfoo/net/core/AbstractServer.java +++ b/net/src/main/java/com/zfoo/net/core/AbstractServer.java @@ -68,9 +68,10 @@ public abstract class AbstractServer implements IServer { protected synchronized void doStart(ChannelInitializer channelChannelInitializer) { var cpuNum = Runtime.getRuntime().availableProcessors(); + // 一条线程持有一个端口对应的selector,如果我们启动不仅仅是一个服务器端口的话,为了更好的性能需要修改对应的bossGroup数量 bossGroup = Epoll.isAvailable() - ? new EpollEventLoopGroup(Math.max(1, cpuNum / 4), new DefaultThreadFactory("netty-boss", true)) - : new NioEventLoopGroup(Math.max(1, cpuNum / 4), new DefaultThreadFactory("netty-boss", true)); + ? new EpollEventLoopGroup(Math.max(1, cpuNum / 8), new DefaultThreadFactory("netty-boss", true)) + : new NioEventLoopGroup(Math.max(1, cpuNum / 8), new DefaultThreadFactory("netty-boss", true)); workerGroup = Epoll.isAvailable() ? new EpollEventLoopGroup(cpuNum * 2, new DefaultThreadFactory("netty-worker", true)) diff --git a/protocol/src/test/cpp/test/byte_buffer_test.h b/protocol/src/test/cpp/test/byte_buffer_test.h index d743fcc0..34334219 100644 --- a/protocol/src/test/cpp/test/byte_buffer_test.h +++ b/protocol/src/test/cpp/test/byte_buffer_test.h @@ -3,7 +3,7 @@ #include -#include "cppProtocol//ByteBuffer.h" +#include "cppProtocol/ByteBuffer.h" namespace byte_buffer_test {