Quic API and implementation - this is a work in progress.

Author: vietj

vertx-core/pom.xml

@@ -98,6 +98,16 @@
       <artifactId>netty-transport-classes-kqueue</artifactId>
       <optional>true</optional>
     </dependency>
+    <dependency>
+      <groupId>io.netty</groupId>
+      <artifactId>netty-codec-classes-quic</artifactId>
+      <optional>true</optional>
+    </dependency>
+    <dependency>
+      <groupId>io.netty</groupId>
+      <artifactId>netty-codec-native-quic</artifactId>
+      <optional>true</optional>
+    </dependency>
 
     <!-- Jackson -->
     <dependency>
@@ -989,6 +999,12 @@
           <classifier>osx-aarch_64</classifier>
           <scope>test</scope>
         </dependency>
+        <dependency>
+          <groupId>io.netty</groupId>
+          <artifactId>netty-codec-native-quic</artifactId>
+          <classifier>osx-aarch_64</classifier>
+          <scope>test</scope>
+        </dependency>
       </dependencies>
     </profile>
 

vertx-core/src/main/java/io/vertx/core/internal/net/SslChannelProvider.java

@@ -83,7 +83,7 @@ private SslHandler createServerSslHandler(boolean useAlpn, long sslHandshakeTime
 
   private SniHandler createSniHandler(boolean useAlpn, long sslHandshakeTimeout, TimeUnit sslHandshakeTimeoutUnit, HostAndPort remoteAddress) {
     Executor delegatedTaskExec = sslContextProvider.useWorkerPool() ? workerPool : ImmediateExecutor.INSTANCE;
-    return new VertxSniHandler(sslContextProvider.serverNameMapping(delegatedTaskExec, useAlpn), sslHandshakeTimeoutUnit.toMillis(sslHandshakeTimeout), delegatedTaskExec, remoteAddress);
+    return new VertxSniHandler(sslContextProvider.serverNameAsyncMapping(delegatedTaskExec, useAlpn), sslHandshakeTimeoutUnit.toMillis(sslHandshakeTimeout), delegatedTaskExec, remoteAddress);
   }
 
 }

vertx-core/src/main/java/io/vertx/core/internal/tls/SslContextProvider.java

@@ -13,6 +13,7 @@
 import io.netty.handler.ssl.SniHandler;
 import io.netty.handler.ssl.SslContext;
 import io.netty.util.AsyncMapping;
+import io.netty.util.Mapping;
 import io.vertx.core.VertxException;
 import io.vertx.core.http.ClientAuth;
 import io.vertx.core.spi.tls.SslContextFactory;
@@ -147,12 +148,28 @@ public SslContext sslServerContext(boolean useAlpn) {
     }
   }
 
+  /**
+   *
+   * @param useAlpn
+   * @return
+   */
+  public Mapping<? super String, ? extends SslContext> serverNameMapping(boolean useAlpn) {
+    return (Mapping<String, SslContext>) serverName -> {
+      try {
+        return sslContext(serverName, useAlpn, true);
+      } catch (Exception e) {
+        // Log this
+        return null;
+      }
+    };
+  }
+
   /**
    * Server name {@link AsyncMapping} for {@link SniHandler}, mapping happens on a Vert.x worker thread.
    *
    * @return the {@link AsyncMapping}
    */
-  public AsyncMapping<? super String, ? extends SslContext> serverNameMapping(Executor workerPool, boolean useAlpn) {
+  public AsyncMapping<? super String, ? extends SslContext> serverNameAsyncMapping(Executor workerPool, boolean useAlpn) {
     return (AsyncMapping<String, SslContext>) (serverName, promise) -> {
       workerPool.execute(() -> {
         SslContext sslContext;

vertx-core/src/main/java/io/vertx/core/net/TcpOptions.java

@@ -54,7 +54,7 @@ void init() {
   }
 
   @Override
-  TcpOptions copy() {
+  protected TcpOptions copy() {
     return new TcpOptions(this);
   }
 

vertx-core/src/main/java/io/vertx/core/net/TransportOptions.java

@@ -15,6 +15,6 @@
  */
 public abstract class TransportOptions {
 
-  abstract TransportOptions copy();
+  protected abstract TransportOptions copy();
 
 }

vertx-core/src/main/java/io/vertx/core/quic/ConnectionClose.java

@@ -0,0 +1,40 @@
+/*
+ * Copyright (c) 2011-2025 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 io.vertx.core.quic;
+
+import io.vertx.core.buffer.Buffer;
+
+/**
+ * @author <a href="mailto:[email protected]">Julien Viet</a>
+ */
+public class ConnectionClose {
+
+  private int error;
+  private Buffer reason;
+
+  public int getError() {
+    return error;
+  }
+
+  public ConnectionClose setError(int error) {
+    this.error = error;
+    return this;
+  }
+
+  public Buffer getReason() {
+    return reason;
+  }
+
+  public ConnectionClose setReason(Buffer reason) {
+    this.reason = reason;
+    return this;
+  }
+}

vertx-core/src/main/java/io/vertx/core/quic/QuicClient.java

@@ -0,0 +1,31 @@
+/*
+ * Copyright (c) 2011-2025 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 io.vertx.core.quic;
+
+import io.vertx.core.Future;
+import io.vertx.core.Vertx;
+import io.vertx.core.internal.VertxInternal;
+import io.vertx.core.net.SocketAddress;
+import io.vertx.core.quic.impl.QuicClientImpl;
+import io.vertx.core.quic.impl.QuicServerImpl;
+
+/**
+ * @author <a href="mailto:[email protected]">Julien Viet</a>
+ */
+public interface QuicClient extends QuicEndpoint {
+
+  static QuicClient create(Vertx vertx, QuicClientOptions options) {
+    return QuicClientImpl.create((VertxInternal) vertx, options);
+  }
+
+  Future<QuicConnection> connect(SocketAddress remotePeer);
+
+}

vertx-core/src/main/java/io/vertx/core/quic/QuicClientOptions.java

@@ -0,0 +1,36 @@
+/*
+ * Copyright (c) 2011-2025 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 io.vertx.core.quic;
+
+import io.vertx.core.net.ClientSSLOptions;
+
+/**
+ * @author <a href="mailto:[email protected]">Julien Viet</a>
+ */
+public class QuicClientOptions extends QuicEndpointOptions {
+
+  public QuicClientOptions() {
+  }
+
+  public QuicClientOptions(QuicClientOptions other) {
+    super(other);
+  }
+
+  @Override
+  public ClientSSLOptions getSslOptions() {
+    return (ClientSSLOptions) super.getSslOptions();
+  }
+
+  @Override
+  protected ClientSSLOptions getOrCreateSSLOptions() {
+    return new ClientSSLOptions();
+  }
+}

vertx-core/src/main/java/io/vertx/core/quic/QuicConnection.java

@@ -0,0 +1,49 @@
+/*
+ * Copyright (c) 2011-2025 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 io.vertx.core.quic;
+
+import io.vertx.codegen.annotations.GenIgnore;
+import io.vertx.core.Future;
+import io.vertx.core.Handler;
+
+import javax.net.ssl.SSLSession;
+
+/**
+ * @author <a href="mailto:[email protected]">Julien Viet</a>
+ */
+public interface QuicConnection {
+
+  QuicConnection handler(Handler<QuicStream> handler);
+
+  QuicConnection closeHandler(Handler<Void> handler);
+
+  Future<QuicStream> createStream();
+
+  Future<Void> close();
+
+  Future<Void> close(ConnectionClose payload);
+
+  /**
+   * @return the application-level protocol negotiated during the TLS handshake
+   */
+  String applicationLayerProtocol();
+
+  /**
+   * @return SSLSession associated with the underlying socket. Returns null if connection is
+   *         not SSL.
+   * @see javax.net.ssl.SSLSession
+   */
+  @GenIgnore(GenIgnore.PERMITTED_TYPE)
+  SSLSession sslSession();
+
+  ConnectionClose closePayload();
+
+}

vertx-core/src/main/java/io/vertx/core/quic/QuicEndpoint.java

@@ -0,0 +1,25 @@
+/*
+ * Copyright (c) 2011-2025 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 io.vertx.core.quic;
+
+import io.vertx.core.Future;
+import io.vertx.core.net.SocketAddress;
+
+/**
+ * @author <a href="mailto:[email protected]">Julien Viet</a>
+ */
+public interface QuicEndpoint {
+
+  Future<Void> bind(SocketAddress address);
+
+  Future<Void> close();
+
+}