Browse Source

update to 1.0.10.0106-beta (#4324)

* 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
三刀 6 years ago
parent
commit
80354943ce

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

@@ -9,7 +9,7 @@
     <parent>
     <parent>
         <groupId>org.smartboot.http</groupId>
         <groupId>org.smartboot.http</groupId>
         <artifactId>smart-http-parent</artifactId>
         <artifactId>smart-http-parent</artifactId>
-        <version>1.0.10.1231-beta</version>
+        <version>1.0.10.0106-beta</version>
     </parent>
     </parent>
     <properties>
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

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

@@ -22,7 +22,7 @@ public class Bootstrap {
 
 
     public static void main(String[] args) {
     public static void main(String[] args) {
         System.setProperty("smart-socket.server.pageSize", (5 * 1024 * 1024) + "");
         System.setProperty("smart-socket.server.pageSize", (5 * 1024 * 1024) + "");
-        System.setProperty("smart-socket.session.writeChunkSize", (1024 * 4) + "");
+        System.setProperty("smart-socket.session.writeChunkSize", (1024 * 8) + "");
         HttpMessageProcessor processor = new HttpMessageProcessor(System.getProperty("webapps.dir", "./"));
         HttpMessageProcessor processor = new HttpMessageProcessor(System.getProperty("webapps.dir", "./"));
         processor.route("/plaintext", new HttpHandle() {
         processor.route("/plaintext", new HttpHandle() {
 
 
@@ -52,7 +52,7 @@ public class Bootstrap {
         // 定义服务器接受的消息类型以及各类消息对应的处理器
         // 定义服务器接受的消息类型以及各类消息对应的处理器
         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 * 8);
-//        server.setThreadNum((int) (Runtime.getRuntime().availableProcessors() * 2));
+        server.setThreadNum((int)(Runtime.getRuntime().availableProcessors() * 1.5));
         try {
         try {
             server.start();
             server.start();
         } catch (IOException e) {
         } catch (IOException e) {