erlang_quic
Pure Erlang QUIC implementation (RFC 9000/9001).
Features
- TLS 1.3 handshake (RFC 8446)
- Stream multiplexing (bidirectional and unidirectional)
- Key update support (RFC 9001 Section 6)
- Connection migration with active path migration API (RFC 9000 Section 9)
- 0-RTT early data support with session resumption (RFC 9001 Section 4.6)
- DATAGRAM frame support for unreliable data (RFC 9221)
- QUIC v2 support (RFC 9369)
- Server mode with listener and pooled listeners (SO_REUSEPORT)
- Retry packet handling for address validation (RFC 9000 Section 8.1)
- Stateless reset support (RFC 9000 Section 10.3)
- Flow control (connection and stream level)
- Congestion control (NewReno with ECN support)
- Loss detection and packet retransmission (RFC 9002)
Requirements
- Erlang/OTP 26.0 or later
- rebar3
Installation
Add to your rebar.config dependencies:
{deps, [
{quic, {git, "https://github.com/benoitc/erlang_quic.git", {branch, "main"}}}
]}.Quick Start
Client
%% Connect to a QUIC server
{ok, ConnRef} = quic:connect(<<"example.com">>, 443, #{
alpn => [<<"h3">>],
verify => false
}, self()),
%% Wait for connection
receive
{quic, ConnRef, {connected, Info}} ->
io:format("Connected: ~p~n", [Info])
end,
%% Open a bidirectional stream
{ok, StreamId} = quic:open_stream(ConnRef),
%% Send data on the stream
ok = quic:send_data(ConnRef, StreamId, <<"Hello, QUIC!">>, true),
%% Receive data
receive
{quic, ConnRef, {stream_data, StreamId, Data, _Fin}} ->
io:format("Received: ~p~n", [Data])
end,
%% Close connection
quic:close(ConnRef, normal).Server
%% Load certificate and key
{ok, CertDer} = file:read_file("server.crt"),
{ok, KeyDer} = file:read_file("server.key"),
%% Start listener
{ok, Listener} = quic_listener:start_link(4433, #{
cert => CertDer,
key => KeyDer,
alpn => [<<"h3">>]
}),
%% Get the port (useful if 0 was specified)
Port = quic_listener:get_port(Listener),
io:format("Listening on port ~p~n", [Port]),
%% Incoming connections are handled automatically
%% The listener spawns quic_connection processes for each clientMessages
The owner process receives messages in the format {quic, ConnRef, Event}:
| Event | Description |
|---|---|
{connected, Info} | Connection established |
{stream_opened, StreamId} | New stream opened by peer |
{stream_data, StreamId, Data, Fin} | Data received on stream |
{stream_reset, StreamId, ErrorCode} | Stream reset by peer |
{closed, Reason} | Connection closed |
{transport_error, Code, Reason} | Transport error |
{session_ticket, Ticket} | Session ticket for 0-RTT resumption |
{datagram, Data} | Datagram received (RFC 9221) |
{stop_sending, StreamId, ErrorCode} | Stop sending requested by peer |
{send_ready, StreamId} | Stream ready for writing |
API Reference
Connection
quic:connect/4- Connect to a QUIC serverquic:close/2- Close a connectionquic:peername/1- Get remote addressquic:sockname/1- Get local addressquic:peercert/1- Get peer certificate (DER-encoded)quic:set_owner/2- Transfer connection ownership (like gen_tcp:controlling_process/2)quic:migrate/1- Trigger connection migration to new local addressquic:setopts/2- Set connection options
Streams
quic:open_stream/1- Open bidirectional streamquic:open_unidirectional_stream/1- Open unidirectional streamquic:send_data/4- Send data on streamquic:reset_stream/3- Reset a stream
Datagrams (RFC 9221)
quic:send_datagram/2- Send unreliable datagram
Server
quic_listener:start_link/2- Start a QUIC listenerquic_listener:start/2- Start unlinked listenerquic_listener:stop/1- Stop listenerquic_listener:get_port/1- Get listening portquic_listener:get_connections/1- List active connectionsquic_listener_sup:start_link/2- Start pooled listeners (SO_REUSEPORT)quic_listener_sup:get_listeners/1- Get listener PIDs in pool
Building
rebar3 compileTesting
# Run unit tests
rebar3 eunit
# Run property-based tests
rebar3 proper
# Run all tests
rebar3 eunit && rebar3 properInteroperability
This implementation passes all 10 QUIC Interop Runner test cases:
| Test Case | Status | Description |
|---|---|---|
| handshake | ✓ | Basic QUIC handshake |
| transfer | ✓ | File download with flow control |
| retry | ✓ | Retry packet handling |
| keyupdate | ✓ | Key rotation during transfer |
| chacha20 | ✓ | ChaCha20-Poly1305 cipher |
| multiconnect | ✓ | Multiple connections |
| v2 | ✓ | QUIC v2 support |
| resumption | ✓ | Session resumption with PSK |
| zerortt | ✓ | 0-RTT early data |
| connectionmigration | ✓ | Active path migration |
See interop/README.md for details on running interop tests.
Documentation
Generate documentation with:
rebar3 ex_docLicense
Apache License 2.0
Author
Benoit Chesneau