1 unstable release
0.1.0 | Nov 6, 2023 |
---|
#16 in #h3
29 downloads per month
660KB
15K
SLoC
h3
An async HTTP/3 implementation.
This crate provides an HTTP/3 implementation that is generic over a provided QUIC transport. This allows the project to focus on just HTTP/3, while letting users pick their QUIC implementation based on their specific needs. It includes client and server APIs. Check the original design for more details.
Status
The h3
crate is still very experimental. While the client and servers do work, there may still be bugs. And the API could change as we continue to explore. That said, we eagerly welcome contributions, trying it out in test environments, and using at your own risk.
The eventual goal is to use h3
as an internal dependency of hyper.
Duvet
This create uses the duvet crate to check compliance of the spec.
The generated report displays the current status of the requirements of the spec.
Get more information about this tool in the contributing document.
Features
- HTTP/3 client and server implementation
- Async only API
- QUIC transport abstraction via traits in the
quic
module - Runtime independent (h3 does not spawn tasks and works with any runtime)
- Supported QUIC implementations to date are Quinn (h3-quinn) and s2n-quic (s2n-quic-h3)
Overview
- h3 HTTP/3 implementation
- h3-quinn QUIC transport implementation based on Quinn
Getting Started
The examples directory can help get started in two ways:
- There are ready-to-use
client
andserver
binaries to interact with other HTTP/3 peers. Check the README in that directory. - The source code of those examples can help teach how to use
h3
as either a client or a server.
Server
let (endpoint, mut incoming) = h3_quinn::quinn::Endpoint::server(server_config, "[::]:443".parse()?)?;
while let Some((req, stream)) = h3_conn.accept().await? {
loop {
match h3_conn.accept().await {
Ok(Some((req, mut stream))) => {
let resp = http::Response::builder().status(Status::OK).body(())?;
stream.send_response(resp).await?;
stream.send_data(Bytes::new("It works!")).await?;
stream.finish().await?;
}
Ok(None) => {
break;
}
Err(err) => {
match err.get_error_level() {
ErrorLevel::ConnectionError => break,
ErrorLevel::StreamError => continue,
}
}
}
}
}
endpoint.wait_idle();
You can find a full server example in examples/server.rs
Client
let addr: SocketAddr = "[::1]:443".parse()?;
let quic = h3_quinn::Connection::new(client_endpoint.connect(addr, "server")?.await?);
let (mut driver, mut send_request) = h3::client::new(quinn_conn).await?;
let drive = async move {
future::poll_fn(|cx| driver.poll_close(cx)).await?;
Ok::<(), Box<dyn std::error::Error>>(())
};
let request = async move {
let req = http::Request::builder().uri(dest).body(())?;
let mut stream = send_request.send_request(req).await?;
stream.finish().await?;
let resp = stream.recv_response().await?;
while let Some(mut chunk) = stream.recv_data().await? {
let mut out = tokio::io::stdout();
out.write_all_buf(&mut chunk).await?;
out.flush().await?;
}
Ok::<_, Box<dyn std::error::Error>>(())
};
let (req_res, drive_res) = tokio::join!(request, drive);
req_res?;
drive_res?;
client_endpoint.wait_idle().await;
You can find a full client example in examples/client.rs
QUIC Generic
As mentioned, the goal of this library is to be generic over a QUIC implementation. To that effect, integrations with QUIC libraries exist:
h3-quinn
: in this same repository.s2n-quic-h3
Interoperability
This crate as well as the quic implementations are tested (quinn, s2n-quic) for interoperability and performance in the quic-interop-runner. You can see the results at (https://interop.seemann.io/).
License
h3 is provided under the MIT license. See LICENSE.
lib.rs
:
Provides the client and server support for WebTransport sessions.
Relevant Links
WebTransport: https://www.w3.org/TR/webtransport/#biblio-web-transport-http3 WebTransport over HTTP/3: https://datatracker.ietf.org/doc/html/draft-ietf-webtrans-http3/
Dependencies
~3.5–9.5MB
~78K SLoC