diff --git a/frameworks/Java/smart-socket/pom.xml b/frameworks/Java/smart-socket/pom.xml index 42798001efd..ef625a5dce7 100644 --- a/frameworks/Java/smart-socket/pom.xml +++ b/frameworks/Java/smart-socket/pom.xml @@ -25,7 +25,7 @@ org.smartboot.socket aio-core - 1.4.1.rc-1 + 1.4.1.rc-2 com.alibaba diff --git a/frameworks/Java/smart-socket/src/main/java/org/smartboot/http/Bootstrap.java b/frameworks/Java/smart-socket/src/main/java/org/smartboot/http/Bootstrap.java index d5b794d2604..28150b801d2 100755 --- a/frameworks/Java/smart-socket/src/main/java/org/smartboot/http/Bootstrap.java +++ b/frameworks/Java/smart-socket/src/main/java/org/smartboot/http/Bootstrap.java @@ -54,8 +54,10 @@ public static void http(MessageProcessor processor) { // 定义服务器接受的消息类型以及各类消息对应的处理器 AioQuickServer server = new AioQuickServer<>(8080, new HttpRequestProtocol(), processor); server.setReadBufferSize(1024 * 4); - server.setBossThreadNum(Runtime.getRuntime().availableProcessors()); - server.setThreadNum(Runtime.getRuntime().availableProcessors() >> 1); +// server.setBossShareToWorkerThreadNum(0); +// server.setBossThreadNum(Runtime.getRuntime().availableProcessors()); +// server.setWorkerThreadNum(Runtime.getRuntime().availableProcessors()); +// server.setWorkerThreadNum(4); try { server.start(); } catch (IOException e) {