aa

frameworks/CSharp/beetlex/PlatformBenchmarks/DBRaw.cs

@@ -75,8 +75,9 @@ private Fortune[] GetFortuneBuffer()
 
         public async Task<World> LoadSingleQueryRow()
         {
-            using (var db = new NpgsqlConnection(_connectionString))
+            using (var db = _dbProviderFactory.CreateConnection())
             {
+                db.ConnectionString = _connectionString;
                 await db.OpenAsync();
                 SingleCommand.Connection = db;
                 mID.TypedValue = _random.Next(1, 10001);
@@ -101,12 +102,12 @@ async Task<World> ReadSingleRow(DbConnection connection, DbCommand cmd)
 
         public async Task<ArraySegment<World>> LoadMultipleQueriesRows(int count)
         {
-            using (var db = new NpgsqlConnection(_connectionString))
+            using (var db = _dbProviderFactory.CreateConnection())
             {
+                db.ConnectionString = _connectionString;
                 await db.OpenAsync();
                 return await LoadMultipleRows(count, db);
             }
-
         }
 
 

frameworks/CSharp/beetlex/PlatformBenchmarks/HttpHandler.cs

@@ -17,7 +17,7 @@ public partial class HttpHandler : ServerHandlerBase
 
         private static AsciiString _httpsuccess = new AsciiString("HTTP/1.1 200 OK\r\n");
 
-        private static readonly AsciiString _headerServer = "Server: TFB\r\n";
+        private static readonly AsciiString _headerServer = "Server: B\r\n";
 
         private static readonly AsciiString _headerContentLength = "Content-Length: ";
 

frameworks/CSharp/beetlex/PlatformBenchmarks/PlatformBenchmarks.csproj

@@ -8,7 +8,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="BeetleX" Version="1.6.5.38-beta" />
+    <PackageReference Include="BeetleX" Version="1.6.5.41" />
     <PackageReference Include="Microsoft.Extensions.Caching.Memory" Version="5.0.0" />
     <PackageReference Include="Microsoft.Extensions.Hosting" Version="5.0.0" />
     <PackageReference Include="Npgsql" Version="5.0.3" />

frameworks/Java/javalin/src/main/resources/environment.properties

@@ -1,10 +1,10 @@
 physicalTag=Citrine
 cloudTag=Azure
 
-mongodbPhysicalPoolSize=200
+mongodbPhysicalPoolSize=100
 mongodbCloudPoolSize=100
 mongodbDefaultPoolSize=50
 
-postgresPhysicalPoolSize=112
+postgresPhysicalPoolSize=56
 postgresCloudPoolSize=16
 postgresDefaultPoolSize=10

frameworks/Java/redkale/benchmark_config.json

@@ -1,7 +1,7 @@
 {
   "framework": "redkale",
   "tests": [{
-	"default": {
+    "default": {
       "plaintext_url": "/plaintext",   
       "json_url": "/json",   
       "port": 8080,
@@ -41,6 +41,43 @@
       "display_name": "redkale",
       "notes": "",
       "versus": "Redkale"
+    },
+	"io": {
+      "plaintext_url": "/plaintext",   
+      "json_url": "/json",   
+      "port": 8080,
+      "approach": "Realistic",
+      "classification": "Fullstack",
+      "database": "Postgres",
+      "framework": "Redkale",
+      "language": "Java",
+      "flavor": "None",
+      "orm": "Raw",
+      "platform": "Redkale",
+      "webserver": "Redkale",
+      "os": "Linux",
+      "database_os": "Linux",
+      "display_name": "redkale",
+      "notes": "",
+      "versus": "Redkale"
+    },
+	"json": { 
+      "json_url": "/json",   
+      "port": 8080,
+      "approach": "Realistic",
+      "classification": "Fullstack",
+      "database": "Postgres",
+      "framework": "Redkale",
+      "language": "Java",
+      "flavor": "None",
+      "orm": "Raw",
+      "platform": "Redkale",
+      "webserver": "Redkale",
+      "os": "Linux",
+      "database_os": "Linux",
+      "display_name": "redkale",
+      "notes": "",
+      "versus": "Redkale"
     }
   }]
 }

frameworks/Java/redkale/conf/application.xml

@@ -3,19 +3,18 @@
 <application port="8585">     
 
     <resources>
-		<executor threads="0"/>
-		<properties>		
+        <executor threads="0"/>
+        <properties>    
+            <property name="system.property.convert.tiny" value="false"/>    
             <property name="system.property.http.response.header.connection" value="none"/>
         </properties>
     </resources> 
 
     <server protocol="HTTP" lazy="true" port="8080">      
-
         <response>
-			<contenttype plain="text/plain" json="application/json"/>  
-			<date period="1000"/>
-		</response>
-
+            <contenttype plain="text/plain" json="application/json"/>  
+            <date period="1000"/>
+        </response>
         <services autoload="true"/>        
         <rest autoload="true"/>
         <servlets autoload="true"/>

frameworks/Java/redkale/conf/persistence.xml

@@ -6,7 +6,8 @@
         <shared-cache-mode>ALL</shared-cache-mode>
         <properties>
             <property name="javax.persistence.jdbc.url" value="jdbc:postgresql://tfb-database:5432/hello_world"/>
-            <property name="javax.persistence.jdbc.prepare" value="true"/>
+            <property name="javax.persistence.jdbc.preparecache" value="true"/>
+            <property name="javax.persistence.connections.limit" value="512"/>
             <property name="javax.persistence.jdbc.user" value="benchmarkdbuser"/>
             <property name="javax.persistence.jdbc.password" value="benchmarkdbpass"/>
         </properties>
@@ -16,10 +17,11 @@
         <shared-cache-mode>ALL</shared-cache-mode>
         <properties>
             <property name="javax.persistence.jdbc.url" value="jdbc:postgresql://tfb-database:5432/hello_world"/>
-            <property name="javax.persistence.jdbc.prepare" value="true"/>
+            <property name="javax.persistence.jdbc.preparecache" value="true"/>
+            <property name="javax.persistence.connections.limit" value="512"/>
             <property name="javax.persistence.jdbc.user" value="benchmarkdbuser"/>
             <property name="javax.persistence.jdbc.password" value="benchmarkdbpass"/>
         </properties>
     </persistence-unit>
-
+   
 </persistence>

frameworks/Java/redkale/config.toml

@@ -29,3 +29,28 @@ orm = "Raw"
 platform = "Redkale"
 webserver = "Redkale"
 versus = "Redkale"
+
+[io]
+urls.plaintext = "/plaintext"
+urls.json = "/json"
+approach = "Realistic"
+classification = "Fullstack"
+database = "None"
+database_os = "Linux"
+os = "Linux"
+orm = "Raw"
+platform = "Redkale"
+webserver = "Redkale"
+versus = "Redkale"
+
+[json]
+urls.json = "/json"
+approach = "Realistic"
+classification = "Fullstack"
+database = "None"
+database_os = "Linux"
+os = "Linux"
+orm = "Raw"
+platform = "Redkale"
+webserver = "Redkale"
+versus = "Redkale"

frameworks/Java/redkale/redkale-io.dockerfile

@@ -0,0 +1,15 @@
+FROM maven:3.6.1-jdk-11-slim as maven
+WORKDIR /redkale
+COPY src src
+COPY conf conf
+COPY pom.xml pom.xml
+RUN mvn package -q
+
+FROM openjdk:11.0.3-jdk-slim
+WORKDIR /redkale
+COPY conf conf
+COPY --from=maven /redkale/target/redkale-benchmark-1.0.0.jar redkale-benchmark.jar
+
+EXPOSE 8080
+
+CMD ["java", "-server", "-XX:+UseNUMA", "-XX:+UseParallelGC", "-XX:AutoBoxCacheMax=80000", "-XX:BiasedLockingStartupDelay=500", "-Dio.direct.fd=true", "-DAPP_HOME=./", "-jar", "redkale-benchmark.jar"]

frameworks/Java/redkale/redkale-json.dockerfile

@@ -0,0 +1,15 @@
+FROM maven:3.6.1-jdk-11-slim as maven
+WORKDIR /redkale
+COPY src src
+COPY conf conf
+COPY pom.xml pom.xml
+RUN mvn package -q
+
+FROM openjdk:11.0.3-jdk-slim
+WORKDIR /redkale
+COPY conf conf
+COPY --from=maven /redkale/target/redkale-benchmark-1.0.0.jar redkale-benchmark.jar
+
+EXPOSE 8080
+
+CMD ["java", "-server", "-XX:+UseNUMA", "-XX:+UseParallelGC", "-XX:AutoBoxCacheMax=80000", "-XX:BiasedLockingStartupDelay=500", "-Djson.direct.test=true", "-DAPP_HOME=./", "-jar", "redkale-benchmark.jar"]

frameworks/Java/redkale/src/main/java/org/redkalex/benchmark/Service.java

@@ -13,7 +13,7 @@
 import org.redkale.net.http.*;
 import org.redkale.service.AbstractService;
 import org.redkale.source.*;
-import org.redkale.util.AnyValue;
+import org.redkale.util.StringWrapper;
 
 /**
  *
@@ -24,54 +24,35 @@ public class Service extends AbstractService {
 
     private static final byte[] helloBytes = "Hello, world!".getBytes();
 
-    private final Random random = new Random();
+    private final ThreadLocal<Random> localRandom = ThreadLocal.withInitial(Random::new);
 
     @Resource
     private DataSource source;
 
-
-    @RestMapping(name = "json")
-    public Message getHelloMessage() {
-        return new Message("Hello, World!");
-    }
-
     @RestMapping(name = "plaintext")
     public byte[] getHelloBytes() {
         return helloBytes;
     }
 
-    @RestMapping(name = "cached-worlds")
-    public CachedWorld[] cachedWorlds(int q) {
-        final int size = Math.min(500, Math.max(1, q));
-        final CachedWorld[] worlds = new CachedWorld[size];
-        for (int i = 0; i < size; i++) {
-            worlds[i] = source.find(CachedWorld.class, randomId());
-        }
-        return worlds;
+    @RestMapping(name = "json")
+    public Message getHelloMessage() {
+        return new Message("Hello, World!");
     }
 
     @RestMapping(name = "db")
     public CompletableFuture<World> findWorldAsync() {
         return source.findAsync(World.class, randomId());
     }
 
-    @RestMapping(name = "fortunes")
-    public CompletableFuture<HttpResult<String>> queryFortunes() {
-        return source.queryListAsync(Fortune.class).thenApply((fortunes) -> {
-            fortunes.add(new Fortune(0, "Additional fortune added at request time."));
-            Collections.sort(fortunes);
-            String html = FortunesTemplate.template(fortunes).render().toString();
-            return new HttpResult("text/html; charset=UTF-8", html);
-        });
-    }
-
     @RestMapping(name = "queries")
     public CompletableFuture<World[]> queryWorldAsync(int q) {
         final int size = Math.min(500, Math.max(1, q));
+        final Random random = localRandom.get();
         final World[] worlds = new World[size];
+
         final AtomicInteger index = new AtomicInteger();
-        final Function<?, CompletableFuture> func = f -> source.findAsync(World.class, randomId())
-            .thenAccept((World v) -> worlds[index.getAndIncrement()] = v);
+        final Function<?, CompletableFuture> func = f -> source.findAsync(World.class, randomId(random))
+            .thenAccept(v -> worlds[index.getAndIncrement()] = v);
         CompletableFuture future = func.apply(null);
         for (int i = 1; i < size; i++) {
             future = future.thenCompose(func);
@@ -82,25 +63,54 @@ public CompletableFuture<World[]> queryWorldAsync(int q) {
     @RestMapping(name = "updates")
     public CompletableFuture<World[]> updateWorldAsync(int q) {
         final int size = Math.min(500, Math.max(1, q));
+        final Random random = localRandom.get();
         final World[] worlds = new World[size];
+
         final AtomicInteger index = new AtomicInteger();
-        final Function<?, CompletableFuture> func = f -> source.findAsync(World.class, randomId())
-            .thenApply((World v) -> {
-                worlds[index.getAndIncrement()] = v;
-                v.setRandomNumber(randomId());
-                return v;
-            });
+        final Function<?, CompletableFuture> func = f -> source.findAsync(World.class, randomId(random))
+            .thenAccept(v -> worlds[index.getAndIncrement()] = v.randomNumber(randomId(random)));
         CompletableFuture future = func.apply(null);
         for (int i = 1; i < size; i++) {
             future = future.thenCompose(func);
         }
-        return future.thenCompose(v -> {
-            Arrays.sort(worlds);
-            return source.updateAsync(worlds);
-        }).thenApply(v -> worlds);
+        return future.thenCompose(v -> source.updateAsync(sort(worlds))).thenApply(v -> worlds);
+    }
+
+    @RestMapping(name = "fortunes")
+    public CompletableFuture<HttpResult<String>> queryFortunes() {
+        return source.queryListAsync(Fortune.class).thenApply((fortunes) -> {
+            fortunes.add(new Fortune(0, "Additional fortune added at request time."));
+            String html = FortunesTemplate.template(sort(fortunes)).render().toString();
+            return new HttpResult("text/html; charset=utf-8", html);
+        });
+    }
+
+    @RestMapping(name = "cached-worlds")
+    public CachedWorld[] cachedWorlds(int q) {
+        final int size = Math.min(500, Math.max(1, q));
+        final Random random = localRandom.get();
+        final CachedWorld[] worlds = new CachedWorld[size];
+        for (int i = 0; i < size; i++) {
+            worlds[i] = source.find(CachedWorld.class, randomId(random));
+        }
+        return worlds;
+    }
+
+    private World[] sort(World[] words) {
+        Arrays.sort(words);
+        return words;
+    }
+
+    private List<Fortune> sort(List<Fortune> fortunes) {
+        Collections.sort(fortunes);
+        return fortunes;
     }
 
     private int randomId() {
+        return 1 + localRandom.get().nextInt(10000);
+    }
+
+    private int randomId(Random random) {
         return 1 + random.nextInt(10000);
     }
 }

frameworks/Java/redkale/src/main/java/org/redkalex/benchmark/World.java

@@ -19,6 +19,11 @@ public class World implements Comparable<World> {
 
     private int randomNumber;
 
+    public World randomNumber(int randomNumber) {
+        this.randomNumber = randomNumber;
+        return this;
+    }
+
     public int getId() {
         return id;
     }

frameworks/PHP/kumbiaphp/benchmark_config.json

@@ -65,7 +65,7 @@
         "webserver": "None",
         "os": "Linux",
         "database_os": "Linux",
-        "display_name": "kumbiaphp-worker",
+        "display_name": "kumbiaphp-workerman",
         "notes": "",
         "versus": "workerman"
       },
@@ -86,7 +86,7 @@
         "webserver": "None",
         "os": "Linux",
         "database_os": "Linux",
-        "display_name": "kumbiaphp-worker",
+        "display_name": "kumbiaphp-workerman-mysql",
         "notes": "",
         "versus": "workerman"
       }