Add cached query tests (#9680)

* Add new framework Java/today

* change build config

* ⬆️ 升级版本 4.0.0-Draft.6

* 更新 /updates API

* 打开日志

* 🔥 删除 /updates API

偶尔会出错，目前尚未找到原因

* 🎨 更新 /updates API

* 🎨 添加 epoll 支持

* 🔥 remove all of the files that aren't necessary for the tests

* 🎨 .gitignore

* 🎨 优化构建

* ✨ 更新框架，新增 cached_query_url

* 🎨 优化使用方式

* 🎨 优化使用方式

* 🎨

* 🎨

* 🎨 修改 cached queries 地址

Author: TAKETODAY

frameworks/Java/today/.gitignore

@@ -6,4 +6,5 @@ build
 
 .idea
 today.properties
-gradle
+gradle
+gradlew

frameworks/Java/today/README.md

@@ -17,6 +17,10 @@ http://localhost:8080/db
 
 http://localhost:8080/queries?queries=
 
+### Caching QUERY
+
+http://localhost:8080/cached-queries?count=10
+
 ### UPDATE
 
 http://localhost:8080/update?queries=

frameworks/Java/today/benchmark_config.json

@@ -9,6 +9,7 @@
         "query_url": "/queries?queries=",
         "fortune_url": "/fortunes",
         "update_url": "/updates?queries=",
+        "cached_query_url": "/cached-queries?count=",
         "port": 8080,
         "approach": "Realistic",
         "classification": "Fullstack",
@@ -21,7 +22,7 @@
         "webserver": "None",
         "os": "Linux",
         "database_os": "Linux",
-        "display_name": "Today",
+        "display_name": "TODAY",
         "notes": "",
         "versus": "None"
       }

frameworks/Java/today/build.gradle

@@ -1,16 +1,16 @@
 description = "benchmark"
 
-apply plugin: "java"
-apply plugin: "application"
-apply plugin: 'cn.taketoday.application'
-apply plugin: 'io.spring.dependency-management'
+apply plugin: 'java'
+apply plugin: 'application'
+apply plugin: 'infra.application'
 
 configure(allprojects) {
   group = "cn.taketoday.benchmark"
 
   repositories {
+    mavenLocal()
     mavenCentral()
-    maven { url "https://oss.sonatype.org/content/repositories/snapshots/" }
+    maven { url = "https://oss.sonatype.org/content/repositories/snapshots/" }
   }
 }
 
@@ -24,13 +24,20 @@ dependencies {
   implementation 'mysql:mysql-connector-java'
 
   implementation 'ch.qos.logback:logback-classic'
+  implementation 'com.github.ben-manes.caffeine:caffeine'
 
   implementation('io.netty:netty-transport-native-epoll') {
     artifact {
       classifier = 'linux-x86_64'
     }
   }
 
+  implementation('io.netty.incubator:netty-incubator-transport-native-io_uring:0.0.21.Final') {
+    artifact {
+      classifier = 'linux-x86_64'
+    }
+  }
+
 //  implementation('io.netty:netty-transport-native-kqueue') {
 //    artifact {
 //      classifier = 'osx-aarch_64'
@@ -40,23 +47,24 @@ dependencies {
 }
 
 java {
-  sourceCompatibility = JavaVersion.VERSION_17
-  targetCompatibility = JavaVersion.VERSION_17
+  sourceCompatibility = JavaVersion.VERSION_21
+  targetCompatibility = JavaVersion.VERSION_21
 }
 
 application {
   mainClass = 'cn.taketoday.benchmark.BenchmarkApplication'
   applicationDefaultJvmArgs = [
       "-server",
+      "-Xms2G",
+      "-Xmx2G",
       "-XX:+UseNUMA",
-      "-XX:+UseG1GC",
-      "-XX:+DisableExplicitGC",
-      "-XX:-StackTraceInThrowable",
       "-XX:+UseStringDeduplication",
       "-Dinfra.profiles.active=test",
       "-Dio.netty.buffer.checkBounds=false",
       "-Dio.netty.buffer.checkAccessible=false",
       "-Dio.netty.leakDetection.level=disabled",
+      "-Dio.netty.iouring.iosqeAsyncThreshold=32000",
+      "-Djava.lang.Integer.IntegerCache.high=10000",
       "--add-opens=java.base/java.nio=ALL-UNNAMED",
       "--add-opens=java.base/sun.nio.ch=ALL-UNNAMED"
   ]

frameworks/Java/today/config.toml

@@ -8,6 +8,7 @@ urls.db = "/db"
 urls.query = "/queries?queries="
 urls.update = "/updates?queries="
 urls.fortune = "/fortunes"
+urls.cached_query = "/cached-queries?count="
 approach = "Realistic"
 classification = "Fullstack"
 database = "mysql"

frameworks/Java/today/gradle.properties

@@ -1,6 +1,6 @@
-version=1.0.0
-#infraVersion=4.0.0-Draft.6-SNAPSHOT
-infraVersion=4.0.0-Draft.6
+version=1.1.0
+#infraVersion=5.0-Draft.2
+infraVersion=5.0-Draft.2-SNAPSHOT
 
 org.gradle.caching=true
 org.gradle.jvmargs=-Xmx2048m

frameworks/Java/today/src/main/java/cn/taketoday/benchmark/AppConfig.java

@@ -4,21 +4,26 @@
 
 import javax.sql.DataSource;
 
-import cn.taketoday.beans.factory.annotation.DisableAllDependencyInjection;
-import cn.taketoday.beans.factory.config.BeanDefinition;
-import cn.taketoday.context.annotation.Configuration;
-import cn.taketoday.context.annotation.Role;
-import cn.taketoday.framework.web.netty.NettyRequestConfig;
-import cn.taketoday.framework.web.netty.SendErrorHandler;
-import cn.taketoday.jdbc.RepositoryManager;
-import cn.taketoday.jdbc.persistence.EntityManager;
-import cn.taketoday.stereotype.Component;
-import io.netty.handler.codec.http.DefaultHttpHeadersFactory;
+import infra.beans.factory.annotation.DisableAllDependencyInjection;
+import infra.beans.factory.config.BeanDefinition;
+import infra.context.annotation.Configuration;
+import infra.context.annotation.Role;
+import infra.jdbc.RepositoryManager;
+import infra.persistence.EntityManager;
+import infra.stereotype.Component;
+import infra.web.server.WebServerFactoryCustomizer;
+import infra.web.server.error.SendErrorHandler;
+import infra.web.server.support.NettyRequestConfig;
+import infra.web.server.support.NettyWebServerFactory;
+import io.netty.handler.codec.http.DefaultHttpHeaders;
 import io.netty.handler.codec.http.HttpHeaders;
 import io.netty.handler.codec.http.HttpHeadersFactory;
 import io.netty.handler.codec.http.multipart.DefaultHttpDataFactory;
+import io.netty.incubator.channel.uring.IOUring;
+import io.netty.incubator.channel.uring.IOUringEventLoopGroup;
+import io.netty.incubator.channel.uring.IOUringServerSocketChannel;
 
-import static cn.taketoday.http.HttpHeaders.DATE_FORMATTER;
+import static infra.http.HttpHeaders.DATE_FORMATTER;
 
 /**
  * @author <a href="https://github.com/TAKETODAY">Harry Yang</a>
@@ -29,42 +34,60 @@
 @Configuration(proxyBeanMethods = false)
 class AppConfig {
 
-  private static final DefaultHttpHeadersFactory headersFactory = DefaultHttpHeadersFactory.headersFactory();
-
   @Component
-  static RepositoryManager repositoryManager(DataSource dataSource) {
+  public static RepositoryManager repositoryManager(DataSource dataSource) {
     return new RepositoryManager(dataSource);
   }
 
   @Component
-  static EntityManager entityManager(RepositoryManager repositoryManager) {
+  public static EntityManager entityManager(RepositoryManager repositoryManager) {
     return repositoryManager.getEntityManager();
   }
 
+  @Component
+  public static WebServerFactoryCustomizer<NettyWebServerFactory> factoryWebServerFactoryCustomizer() {
+    return factory -> {
+      if (IOUring.isAvailable()) {
+        IOUringEventLoopGroup loopGroup = new IOUringEventLoopGroup();
+        factory.setAcceptorGroup(loopGroup);
+        factory.setWorkerGroup(loopGroup);
+        factory.setSocketChannel(IOUringServerSocketChannel.class);
+      }
+    };
+  }
+
   @Component
   @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
-  static NettyRequestConfig nettyRequestConfig(SendErrorHandler sendErrorHandler) {
+  public static NettyRequestConfig nettyRequestConfig(SendErrorHandler sendErrorHandler) {
     var factory = new DefaultHttpDataFactory(false);
-    return NettyRequestConfig.forBuilder()
+
+    return NettyRequestConfig.forBuilder(false)
             .httpDataFactory(factory)
             .sendErrorHandler(sendErrorHandler)
             .headersFactory(new HttpHeadersFactory() {
 
               @Override
               public HttpHeaders newHeaders() {
-                HttpHeaders headers = headersFactory.newHeaders();
+                HttpHeaders headers = new ResponseHeaders();
                 headers.set("Server", "TODAY");
                 headers.set("Date", DATE_FORMATTER.format(ZonedDateTime.now()));
                 return headers;
               }
 
               @Override
               public HttpHeaders newEmptyHeaders() {
-                return headersFactory.newEmptyHeaders();
+                return new ResponseHeaders();
               }
             })
-            .secure(false)
             .build();
   }
 
+  static class ResponseHeaders extends DefaultHttpHeaders {
+
+    public ResponseHeaders() {
+      super(name -> { }, v -> { });
+    }
+
+  }
+
 }

frameworks/Java/today/src/main/java/cn/taketoday/benchmark/BenchmarkApplication.java

@@ -1,7 +1,7 @@
 package cn.taketoday.benchmark;
 
-import cn.taketoday.framework.Application;
-import cn.taketoday.framework.InfraApplication;
+import infra.app.Application;
+import infra.app.InfraApplication;
 
 @InfraApplication
 public class BenchmarkApplication {

frameworks/Java/today/src/main/java/cn/taketoday/benchmark/http/BenchmarkHttpHandler.java

@@ -2,21 +2,21 @@
 
 import java.util.Comparator;
 import java.util.List;
-import java.util.Map;
-import java.util.Objects;
 import java.util.concurrent.ThreadLocalRandom;
 import java.util.stream.IntStream;
 
 import cn.taketoday.benchmark.model.Fortune;
+import cn.taketoday.benchmark.model.Message;
 import cn.taketoday.benchmark.model.World;
-import cn.taketoday.http.MediaType;
-import cn.taketoday.http.ResponseEntity;
-import cn.taketoday.jdbc.persistence.EntityManager;
-import cn.taketoday.lang.Nullable;
-import cn.taketoday.ui.Model;
-import cn.taketoday.web.annotation.GET;
-import cn.taketoday.web.annotation.RestController;
-import cn.taketoday.web.view.ViewRef;
+import infra.http.MediaType;
+import infra.http.ResponseEntity;
+import infra.lang.Nullable;
+import infra.persistence.EntityManager;
+import infra.ui.Model;
+import infra.util.concurrent.Future;
+import infra.web.annotation.GET;
+import infra.web.annotation.RestController;
+import infra.web.view.ViewRef;
 
 /**
  * @author <a href="https://github.com/TAKETODAY">Harry Yang</a>
@@ -26,50 +26,57 @@
 final class BenchmarkHttpHandler {
 
   private static final int MIN_WORLD_NUMBER = 1;
+
   private static final int MAX_WORLD_NUMBER = 10_000;
 
   private final EntityManager entityManager;
 
+  private final WorldCache worldCache;
+
   BenchmarkHttpHandler(EntityManager entityManager) {
     this.entityManager = entityManager;
+    this.worldCache = new WorldCache(entityManager.find(World.class));
   }
 
   @GET("/json")
-  public ResponseEntity<Map<String, String>> json() {
+  public ResponseEntity<Message> json() {
     return ResponseEntity.ok()
             .contentType(MediaType.APPLICATION_JSON)
-            .body(Map.of("message", "Hello, World!"));
+            .body(new Message("Hello, World!"));
   }
 
   @GET("/plaintext")
   public String plaintext() {
     return "Hello, World!";
   }
 
+  @Nullable
   @GET("/db")
   public World db() {
     return entityManager.findById(World.class, nextInt());
   }
 
   @GET("/queries")
-  public List<World> queries(@Nullable String queries) {
-    return randomNumbers()
-            .mapToObj(this::findWorldById)
-            .limit(parseQueryCount(queries))
-            .toList();
+  public Future<List<World>> queries(@Nullable String queries) {
+    return Future.combine(randomNumbers().limit(parseQueryCount(queries)).mapToObj(this::findWorldByIdFuture))
+            .asList();
+  }
+
+  @GET("/cached-queries")
+  public List<World> cachedQueries(@Nullable String count) {
+    return worldCache.getCachedWorld(parseQueryCount(count));
   }
 
   @GET("/updates")
-  public List<World> updates(@Nullable String queries) {
-    return randomNumbers()
-            .mapToObj(this::findWorldById)
-            .filter(Objects::nonNull)
-            .peek(world -> {
+  public Future<List<World>> updates(@Nullable String queries) {
+    return Future.combine(randomNumbers()
+            .limit(parseQueryCount(queries))
+            .mapToObj(this::findWorldByIdFuture)
+            .map(worldFuture -> worldFuture.map(world -> {
               world.setRandomNumber(nextInt());
               entityManager.updateById(world);
-            })
-            .limit(parseQueryCount(queries))
-            .toList();
+              return world;
+            }))).asList();
   }
 
   @GET("/fortunes")
@@ -82,9 +89,13 @@ public ViewRef fortunes(Model model) {
     return ViewRef.forViewName("fortunes");
   }
 
+  private Future<World> findWorldByIdFuture(int id) {
+    return Future.run(() -> findWorldById(id));
+  }
+
   @Nullable
   private World findWorldById(int id) {
-    return entityManager.findById(World.class, boxed[id]);
+    return entityManager.findById(World.class, id);
   }
 
   //
@@ -95,12 +106,8 @@ private static IntStream randomNumbers() {
             .distinct();
   }
 
-  private static final Integer[] boxed = IntStream.range(MIN_WORLD_NUMBER, MAX_WORLD_NUMBER + 1)
-          .boxed()
-          .toArray(Integer[]::new);
-
-  private static Integer nextInt() {
-    return boxed[ThreadLocalRandom.current().nextInt(MIN_WORLD_NUMBER, MAX_WORLD_NUMBER)];
+  private static int nextInt() {
+    return ThreadLocalRandom.current().nextInt(MIN_WORLD_NUMBER, MAX_WORLD_NUMBER);
   }
 
   private static int parseQueryCount(@Nullable String textValue) {