🎨 优化使用方式

Author: TAKETODAY

frameworks/Java/today/build.gradle

@@ -8,6 +8,7 @@ configure(allprojects) {
   group = "cn.taketoday.benchmark"
 
   repositories {
+    mavenLocal()
     mavenCentral()
     maven { url = "https://oss.sonatype.org/content/repositories/snapshots/" }
   }
@@ -57,15 +58,13 @@ application {
       "-Xms2G",
       "-Xmx2G",
       "-XX:+UseNUMA",
-      "-XX:+UseParallelGC",
-      "-XX:+AggressiveOpts",
-      "-Djava.lang.Integer.IntegerCache.high=10000",
-      "-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/src/main/java/cn/taketoday/benchmark/AppConfig.java

@@ -11,12 +11,17 @@
 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 infra.http.HttpHeaders.DATE_FORMATTER;
 
@@ -39,10 +44,23 @@ 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)
   public static NettyRequestConfig nettyRequestConfig(SendErrorHandler sendErrorHandler) {
     var factory = new DefaultHttpDataFactory(false);
+
     return NettyRequestConfig.forBuilder(false)
             .httpDataFactory(factory)
             .sendErrorHandler(sendErrorHandler)

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

@@ -50,6 +50,7 @@ public String plaintext() {
     return "Hello, World!";
   }
 
+  @Nullable
   @GET("/db")
   public World db() {
     return entityManager.findById(World.class, nextInt());

frameworks/Java/today/src/main/java/cn/taketoday/benchmark/http/package-info.java

@@ -0,0 +1,6 @@
+@NonNullApi
+@NonNullFields
+package cn.taketoday.benchmark.http;
+
+import infra.lang.NonNullApi;
+import infra.lang.NonNullFields;

frameworks/Java/today/src/main/java/cn/taketoday/benchmark/model/package-info.java

@@ -0,0 +1,6 @@
+@NonNullApi
+@NonNullFields
+package cn.taketoday.benchmark.model;
+
+import infra.lang.NonNullApi;
+import infra.lang.NonNullFields;

frameworks/Java/today/src/main/java/cn/taketoday/benchmark/package-info.java

@@ -0,0 +1,6 @@
+@NonNullApi
+@NonNullFields
+package cn.taketoday.benchmark;
+
+import infra.lang.NonNullApi;
+import infra.lang.NonNullFields;