浏览代码

update handlers to set size of the buffer

Steve Hu 8 年之前
父节点
当前提交
be24e63d3a

+ 6 - 0
frameworks/Java/light-java/README.md

@@ -13,3 +13,9 @@ Light-Java 1.2.3 (https://github.com/networknt/light-java)
 ### JSON Encoding Test
 
     http://localhost:8080
+### Local build database
+
+start database at light-java folder
+
+docker run -it -p 5432:5432 -v $PWD/src/main/resources/script/postgres:/docker-entrypoint-initdb.d --env POSTGRES_PASSWORD=benchmarkdbpass --env POSTGRES_DB=hello_world postgres:9.6.0
+docker run -it -p 3306:3306 -v $PWD/src/main/resources/script/mysql:/docker-entrypoint-initdb.d --env MYSQL_ROOT_PASSWORD=benchmarkdbpass mysql:5.7.16

+ 3 - 1
frameworks/Java/light-java/src/main/java/com/networknt/techempower/handler/QueriesMysqlGetHandler.java

@@ -1,5 +1,6 @@
 package com.networknt.techempower.handler;
 
+import com.dslplatform.json.DslJson;
 import com.dslplatform.json.JsonWriter;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.networknt.config.Config;
@@ -27,7 +28,8 @@ import javax.sql.DataSource;
 
 public class QueriesMysqlGetHandler implements HttpHandler {
     private final DataSource ds = MysqlStartupHookProvider.ds;
-    private JsonWriter writer = new JsonWriter();
+    private DslJson<Object> dsl = new DslJson<>();
+    private JsonWriter writer = dsl.newWriter(25000);
 
     @Override
     public void handleRequest(HttpServerExchange exchange) throws Exception {

+ 3 - 2
frameworks/Java/light-java/src/main/java/com/networknt/techempower/handler/QueriesPostgresqlGetHandler.java

@@ -1,5 +1,6 @@
 package com.networknt.techempower.handler;
 
+import com.dslplatform.json.DslJson;
 import com.dslplatform.json.JsonWriter;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.networknt.config.Config;
@@ -28,8 +29,8 @@ import javax.sql.DataSource;
 
 public class QueriesPostgresqlGetHandler implements HttpHandler {
     private final DataSource ds = PostgresStartupHookProvider.ds;
-    private ObjectMapper mapper = Config.getInstance().getMapper();
-    private JsonWriter writer = new JsonWriter();
+    private DslJson<Object> dsl = new DslJson<>();
+    private JsonWriter writer = dsl.newWriter(25000);
 
     @Override
     public void handleRequest(HttpServerExchange exchange) throws Exception {

+ 3 - 1
frameworks/Java/light-java/src/main/java/com/networknt/techempower/handler/UpdatesMysqlGetHandler.java

@@ -1,5 +1,6 @@
 package com.networknt.techempower.handler;
 
+import com.dslplatform.json.DslJson;
 import com.dslplatform.json.JsonWriter;
 import com.networknt.techempower.Helper;
 import com.networknt.techempower.db.mysql.MysqlStartupHookProvider;
@@ -25,7 +26,8 @@ import javax.sql.DataSource;
 
 public class UpdatesMysqlGetHandler implements HttpHandler {
     private final DataSource ds = MysqlStartupHookProvider.ds;
-    private JsonWriter writer = new JsonWriter();
+    private DslJson<Object> dsl = new DslJson<>();
+    private JsonWriter writer = dsl.newWriter(25000);
 
     @Override
     public void handleRequest(HttpServerExchange exchange) throws Exception {

+ 3 - 1
frameworks/Java/light-java/src/main/java/com/networknt/techempower/handler/UpdatesPostgresqlGetHandler.java

@@ -1,5 +1,6 @@
 package com.networknt.techempower.handler;
 
+import com.dslplatform.json.DslJson;
 import com.dslplatform.json.JsonWriter;
 import com.networknt.techempower.Helper;
 import com.networknt.techempower.db.mysql.MysqlStartupHookProvider;
@@ -25,7 +26,8 @@ import javax.sql.DataSource;
 
 public class UpdatesPostgresqlGetHandler implements HttpHandler {
     private final DataSource ds = MysqlStartupHookProvider.ds;
-    private JsonWriter writer = new JsonWriter();
+    private DslJson<Object> dsl = new DslJson<>();
+    private JsonWriter writer = dsl.newWriter(25000);
 
     @Override
     public void handleRequest(HttpServerExchange exchange) throws Exception {