Browse Source

update smart-socket to to 1.4.0-rc.4 (#4454)

* update dockerfile

* update to 1.0.10-SNAPSHOT

* update to 1.0.10-beta

* fix bug

* update to 1.0.10.1119-beta

* update to 1.0.10.1128-beta

* 还原代码

* update to 1.0.10.1206-beta

* update to 1.0.10.1209-beta

* update to 1.0.10.1214-beta

* 增加缓冲区

* update to 1.0.10-beta

* update to 1.0.10.1231-beta

* update to 1.0.10.0106-beta

* update to 1.0.0107-beta

* update to 1.0.10.0113-beta

* set new pageSize

* update smart-socket to 1.4.0-rc.2

* update to 1.4.0-rc.3

* update smart-socket to 1.4.0-rc.4
三刀 6 years ago
parent
commit
ebaa2c6a64

+ 1 - 1
frameworks/Java/smart-socket/pom.xml

@@ -25,7 +25,7 @@
         <dependency>
         <dependency>
             <groupId>org.smartboot.socket</groupId>
             <groupId>org.smartboot.socket</groupId>
             <artifactId>aio-core</artifactId>
             <artifactId>aio-core</artifactId>
-            <version>1.4.0-rc.3</version>
+            <version>1.4.0-rc.4</version>
         </dependency>
         </dependency>
         <dependency>
         <dependency>
             <groupId>com.alibaba</groupId>
             <groupId>com.alibaba</groupId>

+ 1 - 1
frameworks/Java/smart-socket/src/main/java/org/smartboot/http/Bootstrap.java

@@ -51,7 +51,7 @@ public class Bootstrap {
     public static void http(MessageProcessor<Http11Request> processor) {
     public static void http(MessageProcessor<Http11Request> processor) {
         // 定义服务器接受的消息类型以及各类消息对应的处理器
         // 定义服务器接受的消息类型以及各类消息对应的处理器
         AioQuickServer<Http11Request> server = new AioQuickServer<>(8080, new HttpRequestProtocol(), processor);
         AioQuickServer<Http11Request> server = new AioQuickServer<>(8080, new HttpRequestProtocol(), processor);
-        server.setReadBufferSize(1024 * 8);
+        server.setReadBufferSize(1024 * 4);
 //        server.setThreadNum((int)(Runtime.getRuntime().availableProcessors() * 1.5));
 //        server.setThreadNum((int)(Runtime.getRuntime().availableProcessors() * 1.5));
         try {
         try {
             server.start();
             server.start();