Http3 support 5.x

vertx-core/pom.xml

@@ -97,6 +97,10 @@
       <artifactId>netty-transport-classes-kqueue</artifactId>
       <optional>true</optional>
     </dependency>
+    <dependency>
+      <groupId>io.netty</groupId>
+      <artifactId>netty-codec-http3</artifactId>
+    </dependency>
 
     <!-- Jackson -->
     <dependency>

vertx-core/src/main/generated/io/vertx/core/http/Http3SettingsConverter.java

@@ -0,0 +1,61 @@
+package io.vertx.core.http;
+
+import io.vertx.core.json.JsonObject;
+import io.vertx.core.json.JsonArray;
+
+/**
+ * Converter and mapper for {@link io.vertx.core.http.Http3Settings}.
+ * NOTE: This class has been automatically generated from the {@link io.vertx.core.http.Http3Settings} original class using Vert.x codegen.
+ */
+public class Http3SettingsConverter {
+
+   static void fromJson(Iterable<java.util.Map.Entry<String, Object>> json, Http3Settings obj) {
+    for (java.util.Map.Entry<String, Object> member : json) {
+      switch (member.getKey()) {
+        case "qpackMaxTableCapacity":
+          if (member.getValue() instanceof Number) {
+            obj.setQpackMaxTableCapacity(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "maxFieldSectionSize":
+          if (member.getValue() instanceof Number) {
+            obj.setMaxFieldSectionSize(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "qpackMaxBlockedStreams":
+          if (member.getValue() instanceof Number) {
+            obj.setQpackMaxBlockedStreams(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "enableConnectProtocol":
+          if (member.getValue() instanceof Number) {
+            obj.setEnableConnectProtocol(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "h3Datagram":
+          if (member.getValue() instanceof Number) {
+            obj.setH3Datagram(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "enableMetadata":
+          if (member.getValue() instanceof Number) {
+            obj.setEnableMetadata(((Number)member.getValue()).longValue());
+          }
+          break;
+      }
+    }
+  }
+
+   static void toJson(Http3Settings obj, JsonObject json) {
+    toJson(obj, json.getMap());
+  }
+
+   static void toJson(Http3Settings obj, java.util.Map<String, Object> json) {
+    json.put("qpackMaxTableCapacity", obj.getQpackMaxTableCapacity());
+    json.put("maxFieldSectionSize", obj.getMaxFieldSectionSize());
+    json.put("qpackMaxBlockedStreams", obj.getQpackMaxBlockedStreams());
+    json.put("enableConnectProtocol", obj.getEnableConnectProtocol());
+    json.put("h3Datagram", obj.getH3Datagram());
+    json.put("enableMetadata", obj.getEnableMetadata());
+  }
+}

vertx-core/src/main/generated/io/vertx/core/http/HttpClientOptionsConverter.java

@@ -102,6 +102,11 @@ static void fromJson(Iterable<java.util.Map.Entry<String, Object>> json, HttpCli
             obj.setInitialSettings(new io.vertx.core.http.Http2Settings((io.vertx.core.json.JsonObject)member.getValue()));
           }
           break;
+        case "initialHttp3Settings":
+          if (member.getValue() instanceof JsonObject) {
+            obj.setInitialHttp3Settings(new io.vertx.core.http.Http3Settings((io.vertx.core.json.JsonObject)member.getValue()));
+          }
+          break;
         case "alpnVersions":
           if (member.getValue() instanceof JsonArray) {
             java.util.ArrayList<io.vertx.core.http.HttpVersion> list =  new java.util.ArrayList<>();
@@ -185,6 +190,9 @@ static void toJson(HttpClientOptions obj, java.util.Map<String, Object> json) {
     if (obj.getInitialSettings() != null) {
       json.put("initialSettings", obj.getInitialSettings().toJson());
     }
+    if (obj.getInitialHttp3Settings() != null) {
+      json.put("initialHttp3Settings", obj.getInitialHttp3Settings().toJson());
+    }
     if (obj.getAlpnVersions() != null) {
       JsonArray array = new JsonArray();
       obj.getAlpnVersions().forEach(item -> array.add(item.name()));

vertx-core/src/main/generated/io/vertx/core/http/HttpServerOptionsConverter.java

@@ -92,6 +92,11 @@ static void fromJson(Iterable<java.util.Map.Entry<String, Object>> json, HttpSer
             obj.setInitialSettings(new io.vertx.core.http.Http2Settings((io.vertx.core.json.JsonObject)member.getValue()));
           }
           break;
+        case "initialHttp3Settings":
+          if (member.getValue() instanceof JsonObject) {
+            obj.setInitialHttp3Settings(new io.vertx.core.http.Http3Settings((io.vertx.core.json.JsonObject)member.getValue()));
+          }
+          break;
         case "alpnVersions":
           if (member.getValue() instanceof JsonArray) {
             java.util.ArrayList<io.vertx.core.http.HttpVersion> list =  new java.util.ArrayList<>();
@@ -217,6 +222,9 @@ static void toJson(HttpServerOptions obj, java.util.Map<String, Object> json) {
     if (obj.getInitialSettings() != null) {
       json.put("initialSettings", obj.getInitialSettings().toJson());
     }
+    if (obj.getInitialHttp3Settings() != null) {
+      json.put("initialHttp3Settings", obj.getInitialHttp3Settings().toJson());
+    }
     if (obj.getAlpnVersions() != null) {
       JsonArray array = new JsonArray();
       obj.getAlpnVersions().forEach(item -> array.add(item.name()));

vertx-core/src/main/generated/io/vertx/core/net/ClientOptionsBaseConverter.java

@@ -47,6 +47,11 @@ static void fromJson(Iterable<java.util.Map.Entry<String, Object>> json, ClientO
             obj.setLocalAddress((String)member.getValue());
           }
           break;
+        case "quicOptions":
+          if (member.getValue() instanceof JsonObject) {
+            obj.setQuicOptions(new io.vertx.core.net.QuicOptions((io.vertx.core.json.JsonObject)member.getValue()));
+          }
+          break;
       }
     }
   }
@@ -72,5 +77,8 @@ static void toJson(ClientOptionsBase obj, java.util.Map<String, Object> json) {
     if (obj.getLocalAddress() != null) {
       json.put("localAddress", obj.getLocalAddress());
     }
+    if (obj.getQuicOptions() != null) {
+      json.put("quicOptions", obj.getQuicOptions().toJson());
+    }
   }
 }

vertx-core/src/main/generated/io/vertx/core/net/NetServerOptionsConverter.java

@@ -62,6 +62,11 @@ static void fromJson(Iterable<java.util.Map.Entry<String, Object>> json, NetServ
             obj.setRegisterWriteHandler((Boolean)member.getValue());
           }
           break;
+        case "quicOptions":
+          if (member.getValue() instanceof JsonObject) {
+            obj.setQuicOptions(new io.vertx.core.net.QuicOptions((io.vertx.core.json.JsonObject)member.getValue()));
+          }
+          break;
       }
     }
   }
@@ -89,5 +94,8 @@ static void toJson(NetServerOptions obj, java.util.Map<String, Object> json) {
       json.put("trafficShapingOptions", obj.getTrafficShapingOptions().toJson());
     }
     json.put("registerWriteHandler", obj.isRegisterWriteHandler());
+    if (obj.getQuicOptions() != null) {
+      json.put("quicOptions", obj.getQuicOptions().toJson());
+    }
   }
 }

vertx-core/src/main/generated/io/vertx/core/net/QuicOptionsConverter.java

@@ -0,0 +1,75 @@
+package io.vertx.core.net;
+
+import io.vertx.core.json.JsonObject;
+import io.vertx.core.json.JsonArray;
+
+/**
+ * Converter and mapper for {@link io.vertx.core.net.QuicOptions}.
+ * NOTE: This class has been automatically generated from the {@link io.vertx.core.net.QuicOptions} original class using Vert.x codegen.
+ */
+public class QuicOptionsConverter {
+
+   static void fromJson(Iterable<java.util.Map.Entry<String, Object>> json, QuicOptions obj) {
+    for (java.util.Map.Entry<String, Object> member : json) {
+      switch (member.getKey()) {
+        case "http3InitialMaxStreamsBidirectional":
+          if (member.getValue() instanceof Number) {
+            obj.setHttp3InitialMaxStreamsBidirectional(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "http3InitialMaxData":
+          if (member.getValue() instanceof Number) {
+            obj.setHttp3InitialMaxData(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "http3InitialMaxStreamDataBidirectionalLocal":
+          if (member.getValue() instanceof Number) {
+            obj.setHttp3InitialMaxStreamDataBidirectionalLocal(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "http3InitialMaxStreamDataBidirectionalRemote":
+          if (member.getValue() instanceof Number) {
+            obj.setHttp3InitialMaxStreamDataBidirectionalRemote(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "http3InitialMaxStreamDataUnidirectional":
+          if (member.getValue() instanceof Number) {
+            obj.setHttp3InitialMaxStreamDataUnidirectional(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "http3InitialMaxStreamsUnidirectional":
+          if (member.getValue() instanceof Number) {
+            obj.setHttp3InitialMaxStreamsUnidirectional(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "sslHandshakeTimeout":
+          if (member.getValue() instanceof Number) {
+            obj.setSslHandshakeTimeout(((Number)member.getValue()).longValue());
+          }
+          break;
+        case "sslHandshakeTimeoutUnit":
+          if (member.getValue() instanceof String) {
+            obj.setSslHandshakeTimeoutUnit(java.util.concurrent.TimeUnit.valueOf((String)member.getValue()));
+          }
+          break;
+      }
+    }
+  }
+
+   static void toJson(QuicOptions obj, JsonObject json) {
+    toJson(obj, json.getMap());
+  }
+
+   static void toJson(QuicOptions obj, java.util.Map<String, Object> json) {
+    json.put("http3InitialMaxStreamsBidirectional", obj.getHttp3InitialMaxStreamsBidirectional());
+    json.put("http3InitialMaxData", obj.getHttp3InitialMaxData());
+    json.put("http3InitialMaxStreamDataBidirectionalLocal", obj.getHttp3InitialMaxStreamDataBidirectionalLocal());
+    json.put("http3InitialMaxStreamDataBidirectionalRemote", obj.getHttp3InitialMaxStreamDataBidirectionalRemote());
+    json.put("http3InitialMaxStreamDataUnidirectional", obj.getHttp3InitialMaxStreamDataUnidirectional());
+    json.put("http3InitialMaxStreamsUnidirectional", obj.getHttp3InitialMaxStreamsUnidirectional());
+    json.put("sslHandshakeTimeout", obj.getSslHandshakeTimeout());
+    if (obj.getSslHandshakeTimeoutUnit() != null) {
+      json.put("sslHandshakeTimeoutUnit", obj.getSslHandshakeTimeoutUnit().name());
+    }
+  }
+}

vertx-core/src/main/java/examples/HTTP2Examples.java

@@ -230,7 +230,7 @@ public void example21(HttpConnection connection) {
   }
 
   public void example22(HttpConnection connection) {
-    connection.remoteSettingsHandler(settings -> {
+    connection.remoteHttp3SettingsHandler(settings -> {
       System.out.println("Received new settings");
     });
   }

vertx-core/src/main/java/examples/h3devexamples/HTTP2ClientExamplesVertxHandler.java

@@ -0,0 +1,124 @@
+/*
+ * Copyright (c) 2011-2019 Contributors to the Eclipse Foundation
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License 2.0 which is available at
+ * http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
+ * which is available at https://www.apache.org/licenses/LICENSE-2.0.
+ *
+ * SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
+ */
+
+package examples.h3devexamples;
+
+import io.netty.buffer.ByteBuf;
+import io.vertx.core.Vertx;
+import io.vertx.core.VertxOptions;
+import io.vertx.core.buffer.Buffer;
+import io.vertx.core.internal.net.NetSocketInternal;
+import io.vertx.core.net.JdkSSLEngineOptions;
+import io.vertx.core.net.NetClient;
+import io.vertx.core.net.NetClientOptions;
+import io.vertx.core.net.SocketAddress;
+
+/**
+ * @author <a href="mailto:zolfaghari19@gmail.com">Iman Zolfaghari</a>
+ */
+public class HTTP2ClientExamplesVertxHandler {
+  protected NetClientOptions createNetClientOptions() {
+    NetClientOptions options = new NetClientOptions();
+    options
+      .setSslEngineOptions(new JdkSSLEngineOptions())
+      .setUseAlpn(true)
+      .setSsl(true)
+      .setTrustAll(true)
+//      .setHostnameVerificationAlgorithm("HTTPS")
+      .setHostnameVerificationAlgorithm("")
+//      .setTrustOptions(Trust.SERVER_JKS.get())
+      ;
+
+    return options;
+  }
+
+  public void example02Local(Vertx vertx) {
+    String path = "/";
+    int port = 8090;
+    String host = "localhost";
+
+/*
+    AtomicInteger requests = new AtomicInteger();
+
+    int n = 5;
+
+    for (int i = 0; i < n; i++) {
+      int counter = i + 1;
+      client.request(HttpMethod.GET, port, host, path)
+        .compose(req -> req.send("Msg " + counter))
+        .compose(HttpClientResponse::body)
+        .onSuccess(body -> System.out.println(
+          "Msg" + counter + " response body is: " + body))
+        .onComplete(event -> requests.incrementAndGet())
+        .onFailure(Throwable::printStackTrace)
+      ;
+    }
+*/
+
+    NetClient client = vertx.createNetClient(createNetClientOptions().setConnectTimeout(1000));
+
+    client.connect(SocketAddress.inetSocketAddress(8090, "localhost")).onSuccess(so -> {
+      NetSocketInternal soi = (NetSocketInternal) so;
+      StringBuilder part1 = new StringBuilder();
+      part1.append("1".repeat(1200));
+      part1.append("2".repeat(1200));
+      part1.append("3".repeat(1200));
+      part1.append("4".repeat(1200));
+
+      StringBuilder part2 = new StringBuilder();
+      part2.append("3".repeat(1200));
+      part2.append("4".repeat(1200));
+
+      soi.write(Buffer.buffer(part1.toString()));
+//      soi.write(Buffer.buffer(part2.toString()));
+      // soi.messageHandler(msg -> fail("Unexpected"));
+      soi.messageHandler(msg -> {
+        ByteBuf byteBuf = (ByteBuf) msg;
+
+        byte[]arr = new byte[byteBuf.readableBytes()];
+        byteBuf.copy().readBytes(arr);
+        System.out.println("received ByteBuf is: " + new String(arr));
+
+
+        if(!byteBuf.isDirect()) throw new RuntimeException();
+        if(1 != byteBuf.refCnt()) throw new RuntimeException();
+//        if(!"Hello World".equals(byteBuf.toString(StandardCharsets.UTF_8))) throw new RuntimeException();
+        if(!byteBuf.release()) throw new RuntimeException();
+        if(0 != byteBuf.refCnt()) throw new RuntimeException();
+        System.out.println("OK");
+      });
+    }).onFailure(Throwable::printStackTrace);
+
+
+
+
+
+
+    int n = 10000;
+    int i = 0;
+    while (i != n) {
+      i++;
+      try {
+        Thread.sleep(100);
+      } catch (InterruptedException e) {
+        throw new RuntimeException(e);
+      }
+    }
+    vertx.close();
+
+  }
+
+  public static void main(String[] args) {
+    Vertx vertx =
+      Vertx.vertx(new VertxOptions().setBlockedThreadCheckInterval(1_000_000_000));
+    new HTTP2ClientExamplesVertxHandler().example02Local(vertx);
+  }
+}