一键在 Manus 中运行任何 Skill

shiguredo-http2

星标3

分支0

更新时间2026年6月10日 00:39

時雨堂の Sans I/O HTTP/2 ライブラリ shiguredo_http2 と関連クレートの機能・API リファレンス。HTTP/2 フレーム処理、HPACK 圧縮、フロー制御、ストリーム管理、WebTransport over HTTP/2、Tokio 統合、nghttp2 バインディングに関する質問時に使用。

安装

用 Codex 或 Claude 帮你安装复制这段 Prompt，粘贴到 Codex、Claude 或其他助手里，让它检查 Skill 页面并帮你完成安装。

在 Manus 中运行

来源

shiguredo

shiguredo/http2-rs

打开 GitHub 仓库查看创作者相关仓库

下载

在 Manus 中运行

shiguredo_http2

Sans I/O 設計に基づく HTTP/2 と WebTransport over HTTP/2 のライブラリ。

特徴

依存なし: 外部依存ゼロ (std のみ)
Sans I/O: I/O を完全に分離した設計 (Tokio, async-std, 同期 I/O など任意の環境で使用可能)
RFC 準拠: RFC 9113 (HTTP/2), RFC 7541 (HPACK), RFC 9218 (Extensible Priorities) に対応
WebTransport over HTTP/2: draft-ietf-webtrans-http2-15 に対応
HPACK: 静的/動的テーブル、Huffman 符号化、サイズ更新対応
フロー制御: 接続レベル/ストリームレベル両対応
DoS 対策: Limits による各種上限設定

バージョン情報

crate 名: shiguredo_http2
バージョン: 2026.1.0-canary.6
Rust Edition: 2024
最小 Rust バージョン: 1.88
ライセンス: Apache-2.0

クレート構成

クレート	説明
`shiguredo_http2`	ルートクレート。Sans I/O な HTTP/2 と WebTransport over HTTP/2 の本体実装
`nghttp2-sys`	nghttp2 C ライブラリへの低レベル FFI バインディング (ビルド時に `cmake` で静的リンク)
`shiguredo_nghttp2`	nghttp2 の Rust バインディング (`Session` を中心とした安全な API)
`tokio-http2`	shiguredo_http2 を Tokio + Rustls (aws-lc-rs) で非同期化。`Client` / `Server` / `WtServerSession` を提供
`tokio-nghttp2`	shiguredo_nghttp2 を Tokio + Rustls (aws-lc-rs) で非同期化。`Client` / `Server` を提供

コア API (shiguredo_http2)

Connection

Connection は HTTP/2 接続の状態機械を表す。Sans I/O なので I/O は呼び出し側が行う。

メソッド	戻り値	説明
`Connection::new(Role, Limits)`	`Self`	新規接続を作成 (役割と制限を指定)
`Connection::client(Limits)`	`Self`	クライアント接続を作成
`Connection::server(Limits)`	`Self`	サーバー接続を作成
`role()`	`Role`	役割 (`Client` / `Server`) を返す
`state()`	`ConnectionState`	接続状態を返す
`is_active()` / `is_closed()`	`bool`	状態判定
`local_settings()` / `remote_settings()`	`&Settings`	自分側 / 相手側の SETTINGS 値を取得
`initiate()`	`Result<()>`	プリフェイスと初期 SETTINGS をキューに積む
`send_settings()`	`Result<()>`	SETTINGS を送信
`mark_preface_sent()` / `mark_preface_received()`	`()`	プリフェイスの送受信完了をマーク (I/O 層からの通知用)
`feed(&[u8])`	`Result<usize>`	受信バイトを内部バッファに投入し、消費バイト数を返す
`process()`	`Result<()>`	内部バッファを処理してイベントを発生させる
`poll_event()`	`Option<Event>`	発生したイベントを 1 つ取り出す
`poll_output()`	`Option<Vec<u8>>`	送信すべきバイト列を 1 つ取り出す
`has_output()`	`bool`	送信待ちがあるか判定
`start_stream(Vec<HeaderField>, end_stream)`	`Result<StreamId>`	リクエストを送信し新しい `StreamId` を返す (クライアント用)
`send_response(StreamId, Vec<HeaderField>, end_stream)`	`Result<()>`	レスポンスヘッダーを送信 (サーバー用)
`send_data(StreamId, Vec<u8>, end_stream)`	`Result<()>`	DATA フレームを送信
`send_trailers(StreamId, Vec<HeaderField>)`	`Result<()>`	トレーラーを END_STREAM 付きで送信
`reset_stream(StreamId, ErrorCode)`	`Result<()>`	RST_STREAM を送信
`send_ping([u8; 8])`	`Result<()>`	PING を送信
`send_goaway(ErrorCode, Vec<u8>)`	`Result<()>`	GOAWAY を送信
`send_window_update(StreamId, increment: u32)`	`Result<()>`	WINDOW_UPDATE を送信

Role / ConnectionState

型	バリアント
`Role`	`Client`, `Server`
`ConnectionState`	`Idle`, `Open`, `Closing`, `Closed`

Event (Sans I/O イベント)

Connection::poll_event() で取得する HTTP/2 イベント。

バリアント	フィールド
`ConnectionPreface`	(なし) クライアントから接続プリフェイスを受信した
`SettingsReceived`	`ack: bool`
`HeadersReceived`	`stream_id`, `headers: Vec<HeaderField>`, `end_stream: bool`, `protocol: Option<Vec<u8>>` (Extended CONNECT の `:protocol` 値、WebTransport では `Some(b"webtransport")`)
`DataReceived`	`stream_id`, `data: Vec<u8>`, `end_stream: bool`
`TrailersReceived`	`stream_id`, `trailers: Vec<HeaderField>`
`StreamReset`	`stream_id`, `error_code: ErrorCode`
`StreamClosed`	`stream_id`
`PingReceived`	`opaque_data: [u8; 8]`, `ack: bool`
`GoawayReceived`	`last_stream_id`, `error_code`, `debug_data: Vec<u8>`
`WindowUpdateReceived`	`stream_id`, `increment: u32` (`stream_id == 0` で接続レベル)
`PriorityUpdateReceived`	`stream_id`, `priority_field_value: Vec<u8>` (RFC 9218)
`ConnectionError`	`error_code`, `reason: String`

Event::stream_id() -> Option<StreamId> と Event::is_connection_level() -> bool で分類できる。

HPACK

型	説明	主要メソッド
`HpackEncoder`	HPACK エンコーダー (`hpack::Encoder` のエイリアス)	`new(max_table_size: usize)`, `set_huffman(bool)`, `set_max_table_size(usize)`, `encode(&mut Vec<u8>, &[HeaderField])`, `encode_header(&mut Vec<u8>, name, value, indexing)`, `encode_header_sensitive(&Vec<u8>, name, value)`, `encode_size_update(&Vec<u8>, new_size)`, `dynamic_table()`
`HpackDecoder`	HPACK デコーダー (`hpack::Decoder` のエイリアス)	`new(max_table_size: usize)`, `set_max_header_list_size(Option<usize>)`, `set_max_table_size(usize)`, `decode(&[u8]) -> Result<Vec<HeaderField>>`, `dynamic_table()`
`HeaderField`	HTTP/2 ヘッダーフィールド (HPACK 用、CRLF/NUL を構築時バリデーション)	`new(name, value) -> Result<Self, HeaderFieldError>`, `name() -> &[u8]`, `value() -> &[u8]`
`HeaderFieldError`	`HeaderField` の構築エラー	不正なヘッダー名・値のバリデーション失敗

Limits / Settings

型	説明
`Limits`	HTTP/2 接続の上限設定 (`max_concurrent_streams`, `initial_window_size`, `max_frame_size`, `max_header_list_size`, `header_table_size`, `connection_window_size`, `enable_connect_protocol`, `no_rfc7540_priorities`, `wt_initial_max_*`)
`LimitsBuilder`	`Limits` のビルダー。`builder()` で取得し、各メソッドで設定後 `build()`
`LimitsError`	`Limits` 構築時の値域エラー
`Settings`	受信した SETTINGS パラメータの値ホルダー
`Setting`	個別の SETTINGS パラメータ (`HeaderTableSize`, `EnablePush`, `MaxConcurrentStreams`, `InitialWindowSize`, `MaxFrameSize`, `MaxHeaderListSize`, `EnableConnectProtocol`, `NoRfc7540Priorities`, `WtInitialMaxData`, `WtInitialMaxStreamDataUni`, `WtInitialMaxStreamDataBidiLocal`, `WtInitialMaxStreamsUni`, `WtInitialMaxStreamsBidi`, `WtInitialMaxStreamDataBidiRemote`)
`SettingError`	SETTINGS の値検証エラー
`WindowSize`	フロー制御ウィンドウサイズ (`from_static(u32)` const + 動的 `try_new`)
`MaxFrameSize`	フレームサイズ上限 (16384..=16777215, RFC 9113 §6.5.2)

Limits のデフォルト値 (Limits::default()):

項目	値
`max_concurrent_streams`	`Some(100)`
`initial_window_size`	65535 (RFC 9113 §6.9.2)
`max_frame_size`	16384 (RFC 9113 §6.5.2)
`max_header_list_size`	`Some(16384)`
`header_table_size`	4096 (RFC 7541)

Stream / StreamId

型	説明
`StreamId`	ストリーム ID。`Connection` バリアントは 0、それ以外は非ゼロ。クライアント発行は奇数、サーバー発行は偶数
`NonZeroStreamId`	非ゼロのストリーム ID (1..=2^31-1)
`ClientStreamId` / `ServerStreamId`	パリティ付きストリーム ID
`Parity`	`Odd` (Client) / `Even` (Server)
`StreamIdError`	ストリーム ID 構築時のエラー
`Stream`	ストリームの状態ホルダー
`StreamState`	RFC 9113 §5.1 のストリーム状態 (`Idle`, `Open`, `HalfClosedLocal`, `HalfClosedRemote`, `Closed`, etc.)

フロー制御

型	説明
`FlowControl`	フロー制御ウィンドウ
`MAX_WINDOW_SIZE`	最大ウィンドウサイズ (`2^31 - 1`)

フレーム型

型	説明
`Frame`	全フレーム型を統合する enum (`Data`, `Headers`, `Priority`, `RstStream`, `Settings`, `PushPromise`, `Ping`, `Goaway`, `WindowUpdate`, `Continuation`, `PriorityUpdate`, `Unknown`)
`FrameType`	フレーム種別 (`Data` = 0x00, `Headers` = 0x01, `Priority` = 0x02, `RstStream` = 0x03, `Settings` = 0x04, `PushPromise` = 0x05, `Ping` = 0x06, `Goaway` = 0x07, `WindowUpdate` = 0x08, `Continuation` = 0x09, `PriorityUpdate` = 0x10)
`FrameHeader`	9 バイトフレームヘッダー (length, type, flags, stream_id)
`FrameFlags`	フレームフラグ (`END_STREAM`, `END_HEADERS`, `PADDED`, `PRIORITY`, `ACK`)
`FRAME_HEADER_SIZE`	フレームヘッダーサイズ定数 (9)
`DataFrame` / `HeadersFrame` / `RstStreamFrame` / `SettingsFrame` / `PingFrame` / `GoawayFrame` / `WindowUpdateFrame` / `ContinuationFrame` / `PriorityUpdateFrame`	各種フレーム構造体
`LastStreamId`	GOAWAY の `last_stream_id`
`Weight`	PRIORITY の重み (RFC 9113 では非推奨、受信のみ)
`WindowIncrement`	WINDOW_UPDATE の増分値 (1..=2^31-1)
`FrameDecoder` / `FrameEncoder`	低レベルなフレームのデコーダー/エンコーダー (`Connection` の内部で使用)
`FrameError`	フレーム処理エラー

CONNECTION_PREFACE: b"PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n" (24 バイト) CONNECTION_PREFACE_LEN: 24

WebTransport over HTTP/2

webtransport モジュール。Sans I/O の WtSession を中心に、Capsule Protocol (RFC 9297) と WebTransport Capsule (draft-ietf-webtrans-http2-15) を扱う。

WtSession

メソッド	戻り値	説明
`WtSession::client(WtConfig)` / `WtSession::server(WtConfig)`	`Self`	セッションを作成
`role()` / `state()` / `is_active()` / `is_closed()`	(各種)	セッション状態を返す
`initiate()`	`WtResult<()>`	初期 SETTINGS を送信
`feed(&[u8])`	`WtResult<usize>`	受信バイトを投入
`process()`	`WtResult<()>`	内部状態を進める
`poll_output()`	`Option<Vec<u8>>`	送信すべきバイト列を取得
`poll_event()`	`Option<WtEvent>`	イベントを取得
`has_output()`	`bool`	送信待ちがあるか
`open_bidi_stream()` / `open_uni_stream()`	`WtResult<WtStreamId>`	ストリームを開く
`send_stream_data(WtStreamId, &[u8], fin: bool)`	`WtResult<()>`	ストリームに WT_STREAM Capsule でデータ送信
`reset_stream(WtStreamId, error_code: u64)`	`WtResult<()>`	WT_RESET_STREAM を送信
`stop_sending(WtStreamId, error_code: u64)`	`WtResult<()>`	WT_STOP_SENDING を送信
`send_datagram(&[u8])`	`WtResult<()>`	DATAGRAM Capsule (RFC 9297) を送信
`close(error_code: u32, reason: &str)`	`WtResult<()>`	WT_CLOSE_SESSION を送信してセッション終了
`drain()`	`WtResult<()>`	WT_DRAIN_SESSION を送信
`send_max_data(maximum: u64)`	`WtResult<()>`	WT_MAX_DATA を送信
`send_max_stream_data(WtStreamId, maximum: u64)`	`WtResult<()>`	WT_MAX_STREAM_DATA を送信
`send_max_streams(maximum: u64, bidirectional: bool)`	`WtResult<()>`	WT_MAX_STREAMS を送信
`flow_control()` / `flow_control_mut()`	`&WtFlowControl` / `&mut WtFlowControl`	フロー制御状態
`stream(WtStreamId)`	`Option<&WtStream>`	ストリーム参照取得
`grow_recv_window(increment: u64)`	`WtResult<()>`	接続受信ウィンドウを拡張
`grow_stream_recv_window(WtStreamId, increment: u64)`	`WtResult<()>`	ストリーム受信ウィンドウを拡張
`grow_max_streams(increment: u64, bidirectional: bool)`	`WtResult<()>`	最大ストリーム数を拡張
`config()`	`&WtConfig`	設定参照

WtConfig / WtInit

WtConfig は初期フロー制御値や上限を保持する。apply_init(&WtInit) で WebTransport-Init ヘッダー値を反映できる。

WtEvent / WtSessionState

`WtEvent` バリアント	説明
`SessionReady`	セッション確立
`BidiStreamOpened` / `UniStreamOpened`	ストリームが開かれた
`StreamData`	ストリームに WT_STREAM Capsule が到着
`StreamReset` / `StreamStopSending`	リセット/停止要求
`Datagram`	DATAGRAM を受信
`MaxData` / `MaxStreamData` / `MaxStreams`	フロー制御上限の更新
`DataBlocked` / `StreamDataBlocked` / `StreamsBlocked`	フロー制御ブロック通知
`CloseSession` / `DrainSession`	セッション終了/排他要求

`WtSessionState`	説明
`Initial` / `Active` / `Draining` / `Closed`	セッション状態遷移

Capsule (draft-ietf-webtrans-http2-15 Section 6)

Capsule	Type コード
`WT_RESET_STREAM`	`0x190B4D39`
`WT_STOP_SENDING`	`0x190B4D3A`
`WT_STREAM` (FIN=0)	`0x190B4D3B`
`WT_STREAM` (FIN=1)	`0x190B4D3C`
`WT_MAX_DATA`	`0x190B4D3D`
`WT_MAX_STREAM_DATA`	`0x190B4D3E`
`WT_MAX_STREAMS_BIDI`	`0x190B4D3F`
`WT_MAX_STREAMS_UNI`	`0x190B4D40`
`WT_DATA_BLOCKED`	`0x190B4D41`
`WT_STREAM_DATA_BLOCKED`	`0x190B4D42`
`WT_STREAMS_BLOCKED_BIDI`	`0x190B4D43`
`WT_STREAMS_BLOCKED_UNI`	`0x190B4D44`
`WT_CLOSE_SESSION`	`0x2843`
`WT_DRAIN_SESSION`	`0x78AE`

WebTransport SETTINGS

パラメータ	Identifier
`SETTINGS_WT_INITIAL_MAX_DATA`	`0x2b61`
`SETTINGS_WT_INITIAL_MAX_STREAM_DATA_UNI`	`0x2b62`
`SETTINGS_WT_INITIAL_MAX_STREAM_DATA_BIDI_LOCAL`	`0x2b63`
`SETTINGS_WT_INITIAL_MAX_STREAMS_UNI`	`0x2b64`
`SETTINGS_WT_INITIAL_MAX_STREAMS_BIDI`	`0x2b65`
`SETTINGS_WT_INITIAL_MAX_STREAM_DATA_BIDI_REMOTE`	`0x2b66`

コード例

クライアント (Sans I/O)

use shiguredo_http2::{Connection, Event, HeaderField, Limits};

let limits = Limits::builder()
    .max_concurrent_streams(Some(100))
    .build()?;
let mut conn = Connection::client(limits);

// 接続を開始 (プリフェイスと SETTINGS をキューに積む)
conn.initiate()?;

// 送信バイトを取り出してネットワークに書き込む
while let Some(output) = conn.poll_output() {
    // stream.write_all(&output)?;
}

// リクエストを送信
let headers = vec![
    HeaderField::new(":method", "GET")?,
    HeaderField::new(":scheme", "https")?,
    HeaderField::new(":path", "/")?,
    HeaderField::new(":authority", "example.com")?,
];
let stream_id = conn.start_stream(headers, true)?;

// 受信バイトを投入してイベントを処理
// conn.feed(&received_data)?;
// conn.process()?;
// while let Some(event) = conn.poll_event() {
//     match event {
//         Event::HeadersReceived { stream_id, headers, end_stream, .. } => { /* ... */ }
//         Event::DataReceived { stream_id, data, end_stream } => { /* ... */ }
//         _ => {}
//     }
// }

サーバー (Sans I/O)

use shiguredo_http2::{Connection, Event, HeaderField, Limits};

let mut conn = Connection::server(Limits::default());

// 接続を開始 (SETTINGS を送信)
conn.initiate()?;

// 受信バイトを投入して処理
// conn.feed(&received_data)?;
// conn.process()?;

while let Some(event) = conn.poll_event() {
    match event {
        Event::HeadersReceived { stream_id, headers, end_stream, .. } => {
            let response_headers = vec![
                HeaderField::new(":status", "200")?,
                HeaderField::new("content-type", "text/plain")?,
            ];
            conn.send_response(stream_id, response_headers, false)?;
            conn.send_data(stream_id, b"Hello, HTTP/2!".to_vec(), true)?;
        }
        _ => {}
    }
}

HPACK エンコード/デコード

use shiguredo_http2::{HpackDecoder, HpackEncoder, HeaderField};

let mut encoder = HpackEncoder::new(4096);
let headers = vec![
    HeaderField::new(":status", "200")?,
    HeaderField::new("content-type", "text/plain")?,
];
let mut encoded = Vec::new();
encoder.encode(&mut encoded, &headers);

let mut decoder = HpackDecoder::new(4096);
let decoded = decoder.decode(&encoded)?;

WebTransport over HTTP/2 (Sans I/O)

use shiguredo_http2::webtransport::{WtConfig, WtSession};

let mut session = WtSession::client(WtConfig::default());
session.initiate()?;

let stream_id = session.open_bidi_stream()?;
session.send_stream_data(stream_id, b"Hello", false)?;
session.send_datagram(b"Datagram")?;

// session.feed(&received_data)?;
// session.process()?;
// while let Some(event) = session.poll_event() { /* ... */ }

Tokio 統合 (tokio-http2 / tokio-nghttp2)

Sans I/O 本体を Tokio + Rustls (aws-lc-rs) で非同期化する 2 系統のクレートを提供する。

クレート	内部	提供型
`tokio-http2`	shiguredo_http2 (純 Rust)	`Client`, `Server`, `ServerConnection`, `Connection<S>`, `TlsClientConfig`, `TlsServerConfig`, `webtransport::*`
`tokio-nghttp2`	shiguredo_nghttp2 (nghttp2 C ライブラリ)	`Client`, `Server`, `ServerConnection`, `Connection<S>`, `TlsClientConfig`, `TlsServerConfig`

両者とも ALPN は h2、TLS は Rustls (aws-lc-rs バックエンド)。Extended CONNECT (RFC 8441) と WebTransport は tokio-http2 のみ対応する。

TLS 設定

use tokio_http2::{TlsClientConfig, TlsServerConfig};

// クライアント
let tls = TlsClientConfig::with_platform_verifier()?;  // OS の証明書ストア
let tls = TlsClientConfig::with_custom_ca(ca_pem)?;    // カスタム CA
let tls = TlsClientConfig::insecure()?;                // テスト用 (検証なし)

// サーバー
let tls = TlsServerConfig::new(cert_pem, key_pem)?;
let tls = TlsServerConfig::from_der(certs, key)?;

tokio-http2 クライアント

use tokio_http2::{Client, Event, HeaderField, Limits, TlsClientConfig};

let mut client = Client::connect(addr, "example.com", TlsClientConfig::with_platform_verifier()?, Limits::default()).await?;
let stream_id = client.send_request(headers, true).await?;
match client.next_event().await? {
    Event::HeadersReceived { .. } => { /* ... */ }
    Event::DataReceived { .. } => { /* ... */ }
    _ => {}
}

tokio-http2 WebTransport サーバー

ServerConnection::next_event() で Extended CONNECT (:method=CONNECT かつ :protocol=webtransport) を検出したら WtServerRequest::from_connection() で要求を組み立てて accept(WtConfig, allowed_origin: Option<&[u8]>) する。

use shiguredo_http2::webtransport::WtConfig;
use tokio_http2::webtransport::{WEBTRANSPORT_PROTOCOL, WtServerRequest};

let request = WtServerRequest::from_connection(conn, stream_id, headers);
let mut session = request.accept(WtConfig::default(), Some(b"https://example.com")).await?;
while let Some(mut bidi) = session.accept_bidi().await {
    let data = bidi.recv().await?;
    bidi.send(b"hello".to_vec(), true).await?;
}

WebTransport 関連型: WtServerRequest, WtServerSession, WtSessionHandle, WtSessionParts, WtBidiStream, WtUniRecvStream, WtUniSendStream, 定数 WEBTRANSPORT_PROTOCOL = b"webtransport"。

accept() は draft-ietf-webtrans-http2-15 Section 7 (TLS 1.3 必須) と Section 3.2 (Origin 検証) を実施する。第 2 引数に None を渡すと Origin 検証はスキップする (非 Web context 向け)。

nghttp2 系 (tokio-nghttp2 / shiguredo_nghttp2)

nghttp2 C ライブラリを使う系統。shiguredo_nghttp2::Session を中心に以下の API を提供する。

型	説明
`Session`	nghttp2 セッション。`client()` / `server()` / `client_with_options(&SessionOptions)` / `server_with_options(&SessionOptions)`
`SessionOptions`	DoS 対策・フロー制御挙動のオプション Builder (`no_auto_window_update`, `peer_max_concurrent_streams`, `no_auto_ping_ack`, `max_send_header_block_length`, `max_deflate_dynamic_table_size`, `max_outbound_ack`, `max_settings`, `stream_reset_rate_limit`, `max_continuations`, `glitch_rate_limit`)
`Http2Event`	nghttp2 由来のイベント (`HeadersReceived`, `DataReceived`, `StreamClosed`, `GoawayReceived`, `PingReceived`, `SettingsReceived`, `WindowUpdateReceived`, `FrameSent`, `FrameNotSent`, `InvalidFrameReceived`, `InvalidHeaderReceived`)
`Header`	nghttp2 用ヘッダー (擬似ヘッダーのヘルパー `method()` / `scheme()` / `authority()` / `path()` / `status()` / `sensitive()`)
`ErrorCode` / `FrameType` / `SettingsId` / `StreamId`	HTTP/2 各種定数

Session の主要メソッド: recv(), send(), poll_event(), want_read() / want_write(), submit_settings(), submit_request(headers, data: Option<&[u8]>, end_stream), submit_response(), submit_data(), submit_data_for_trailer(), submit_trailer(), submit_headers(), submit_rst_stream(), submit_goaway(), submit_ping(), submit_window_update(), submit_shutdown_notice(), terminate_session(), get_*_settings(), get_*_window_size(), set_local_window_size(), consume() / consume_connection() / consume_stream(), last_error_message()。

tokio-nghttp2 の Client / Server / ServerConnection はこれを Tokio で非同期化する薄いラッパー。

エラー型

`Error` (HTTP/2 接続エラー)

Error は ErrorKind を内包する。Error::connection_error(ErrorCode, reason) / Error::stream_error(ErrorCode, reason) / Error::hpack_error(reason) / Error::protocol_error(reason) / Error::frame_size_error(reason) で作成する。is_connection_error() / is_stream_error() / error_code() で分類できる。

`ErrorKind` バリアント	説明
`Connection { code, reason }`	接続レベルエラー (GOAWAY 送信対象)
`Stream { code, reason }`	ストリームレベルエラー (RST_STREAM 送信対象)
`Hpack { reason }`	HPACK デコードエラー (RFC 7541)
`Protocol { reason }`	プロトコル違反
`FrameSize { reason }`	フレームサイズ違反
`Io { source }`	I/O エラー

`ErrorCode` (HTTP/2 エラーコード)

RFC 9113 §7 の HTTP/2 エラーコード。as_u32() / from_u32(u32) で変換可能。

バリアント	コード
`NoError`	`0x00`
`ProtocolError`	`0x01`
`InternalError`	`0x02`
`FlowControlError`	`0x03`
`SettingsTimeout`	`0x04`
`StreamClosed`	`0x05`
`FrameSizeError`	`0x06`
`RefusedStream`	`0x07`
`Cancel`	`0x08`
`CompressionError`	`0x09`
`ConnectError`	`0x0a`
`EnhanceYourCalm`	`0x0b`
`InadequateSecurity`	`0x0c`
`Http11Required`	`0x0d`

その他

DecodeError: フレームデコード時のバイト列エラー
SendError: 送信側 API のエラー (フロー制御不足、ストリーム状態違反など)
FrameError: フレーム構造エラー
SettingError: SETTINGS 値検証エラー
LimitsError: Limits 構築時の値域エラー
StreamIdError: ストリーム ID 構築エラー
HeaderFieldError: HPACK ヘッダー構築エラー (CRLF/NUL 拒否)

対応仕様

RFC / draft	名称	対応機能
RFC 7541	HPACK: Header Compression for HTTP/2	静的/動的テーブル、Huffman、整数符号化
RFC 8441	Bootstrapping WebSockets with HTTP/2	Extended CONNECT (`:protocol` 擬似ヘッダー)
RFC 9113	HTTP/2	フレーム、フロー制御、ストリーム状態遷移、CONNECT、エラー処理
RFC 9218	Extensible Prioritization Scheme for HTTP	PRIORITY_UPDATE フレーム、`urgency` / `incremental`
RFC 9297	HTTP Datagrams and the Capsule Protocol	Capsule, DATAGRAM, PADDING
draft-ietf-webtrans-http2-15	WebTransport over HTTP/2	WT_* Capsule, WebTransport SETTINGS, Extended CONNECT (`webtransport`), TLS 1.3 要件, Origin 検証

既知の未対応 / 制限

サーバープッシュ (PUSH_PROMISE): 主要ブラウザ (Chrome / Firefox / Safari) が削除済みのため未対応。受信した場合は PROTOCOL_ERROR で GOAWAY する (src/connection/mod.rs:926)。
WebSocket over HTTP/2: Extended CONNECT (RFC 8441) は対応しているが、WebSocket フレーム層は未実装。
PRIORITY フレーム: RFC 9113 で非推奨。受信は処理する (優先度情報は無視) が、送信はしない。
HEADERS の優先度フィールド: RFC 9113 で非推奨。
tokio-nghttp2 と Extended CONNECT / WebTransport: tokio-nghttp2 側は Extended CONNECT と WebTransport を提供しない (tokio-http2 のみ)。
tokio-http2 の WebTransport accept は TLS 1.3 必須: rustls 0.23 が TLS 1.2 + extended master secret のネゴシエーション状態を外部公開していないため、安全側に倒して TLS 1.3 のみを許可する (draft-ietf-webtrans-http2-15 Section 7 の要件より厳しい)。

name	shiguredo-http2
description	時雨堂の Sans I/O HTTP/2 ライブラリ shiguredo_http2 と関連クレートの機能・API リファレンス。HTTP/2 フレーム処理、HPACK 圧縮、フロー制御、ストリーム管理、WebTransport over HTTP/2、Tokio 統合、nghttp2 バインディングに関する質問時に使用。

shiguredo_http2

Sans I/O 設計に基づく HTTP/2 と WebTransport over HTTP/2 のライブラリ。

特徴

依存なし: 外部依存ゼロ (std のみ)
Sans I/O: I/O を完全に分離した設計 (Tokio, async-std, 同期 I/O など任意の環境で使用可能)
RFC 準拠: RFC 9113 (HTTP/2), RFC 7541 (HPACK), RFC 9218 (Extensible Priorities) に対応
WebTransport over HTTP/2: draft-ietf-webtrans-http2-15 に対応
HPACK: 静的/動的テーブル、Huffman 符号化、サイズ更新対応
フロー制御: 接続レベル/ストリームレベル両対応
DoS 対策: Limits による各種上限設定

バージョン情報

crate 名: shiguredo_http2
バージョン: 2026.1.0-canary.6
Rust Edition: 2024
最小 Rust バージョン: 1.88
ライセンス: Apache-2.0

クレート構成

クレート	説明
`shiguredo_http2`	ルートクレート。Sans I/O な HTTP/2 と WebTransport over HTTP/2 の本体実装
`nghttp2-sys`	nghttp2 C ライブラリへの低レベル FFI バインディング (ビルド時に `cmake` で静的リンク)
`shiguredo_nghttp2`	nghttp2 の Rust バインディング (`Session` を中心とした安全な API)
`tokio-http2`	shiguredo_http2 を Tokio + Rustls (aws-lc-rs) で非同期化。`Client` / `Server` / `WtServerSession` を提供
`tokio-nghttp2`	shiguredo_nghttp2 を Tokio + Rustls (aws-lc-rs) で非同期化。`Client` / `Server` を提供

コア API (shiguredo_http2)

Connection

Connection は HTTP/2 接続の状態機械を表す。Sans I/O なので I/O は呼び出し側が行う。

メソッド	戻り値	説明
`Connection::new(Role, Limits)`	`Self`	新規接続を作成 (役割と制限を指定)
`Connection::client(Limits)`	`Self`	クライアント接続を作成
`Connection::server(Limits)`	`Self`	サーバー接続を作成
`role()`	`Role`	役割 (`Client` / `Server`) を返す
`state()`	`ConnectionState`	接続状態を返す
`is_active()` / `is_closed()`	`bool`	状態判定
`local_settings()` / `remote_settings()`	`&Settings`	自分側 / 相手側の SETTINGS 値を取得
`initiate()`	`Result<()>`	プリフェイスと初期 SETTINGS をキューに積む
`send_settings()`	`Result<()>`	SETTINGS を送信
`mark_preface_sent()` / `mark_preface_received()`	`()`	プリフェイスの送受信完了をマーク (I/O 層からの通知用)
`feed(&[u8])`	`Result<usize>`	受信バイトを内部バッファに投入し、消費バイト数を返す
`process()`	`Result<()>`	内部バッファを処理してイベントを発生させる
`poll_event()`	`Option<Event>`	発生したイベントを 1 つ取り出す
`poll_output()`	`Option<Vec<u8>>`	送信すべきバイト列を 1 つ取り出す
`has_output()`	`bool`	送信待ちがあるか判定
`start_stream(Vec<HeaderField>, end_stream)`	`Result<StreamId>`	リクエストを送信し新しい `StreamId` を返す (クライアント用)
`send_response(StreamId, Vec<HeaderField>, end_stream)`	`Result<()>`	レスポンスヘッダーを送信 (サーバー用)
`send_data(StreamId, Vec<u8>, end_stream)`	`Result<()>`	DATA フレームを送信
`send_trailers(StreamId, Vec<HeaderField>)`	`Result<()>`	トレーラーを END_STREAM 付きで送信
`reset_stream(StreamId, ErrorCode)`	`Result<()>`	RST_STREAM を送信
`send_ping([u8; 8])`	`Result<()>`	PING を送信
`send_goaway(ErrorCode, Vec<u8>)`	`Result<()>`	GOAWAY を送信
`send_window_update(StreamId, increment: u32)`	`Result<()>`	WINDOW_UPDATE を送信

Role / ConnectionState

型	バリアント
`Role`	`Client`, `Server`
`ConnectionState`	`Idle`, `Open`, `Closing`, `Closed`

Event (Sans I/O イベント)

Connection::poll_event() で取得する HTTP/2 イベント。

バリアント	フィールド
`ConnectionPreface`	(なし) クライアントから接続プリフェイスを受信した
`SettingsReceived`	`ack: bool`
`HeadersReceived`	`stream_id`, `headers: Vec<HeaderField>`, `end_stream: bool`, `protocol: Option<Vec<u8>>` (Extended CONNECT の `:protocol` 値、WebTransport では `Some(b"webtransport")`)
`DataReceived`	`stream_id`, `data: Vec<u8>`, `end_stream: bool`
`TrailersReceived`	`stream_id`, `trailers: Vec<HeaderField>`
`StreamReset`	`stream_id`, `error_code: ErrorCode`
`StreamClosed`	`stream_id`
`PingReceived`	`opaque_data: [u8; 8]`, `ack: bool`
`GoawayReceived`	`last_stream_id`, `error_code`, `debug_data: Vec<u8>`
`WindowUpdateReceived`	`stream_id`, `increment: u32` (`stream_id == 0` で接続レベル)
`PriorityUpdateReceived`	`stream_id`, `priority_field_value: Vec<u8>` (RFC 9218)
`ConnectionError`	`error_code`, `reason: String`

Event::stream_id() -> Option<StreamId> と Event::is_connection_level() -> bool で分類できる。

HPACK

型	説明	主要メソッド
`HpackEncoder`	HPACK エンコーダー (`hpack::Encoder` のエイリアス)	`new(max_table_size: usize)`, `set_huffman(bool)`, `set_max_table_size(usize)`, `encode(&mut Vec<u8>, &[HeaderField])`, `encode_header(&mut Vec<u8>, name, value, indexing)`, `encode_header_sensitive(&Vec<u8>, name, value)`, `encode_size_update(&Vec<u8>, new_size)`, `dynamic_table()`
`HpackDecoder`	HPACK デコーダー (`hpack::Decoder` のエイリアス)	`new(max_table_size: usize)`, `set_max_header_list_size(Option<usize>)`, `set_max_table_size(usize)`, `decode(&[u8]) -> Result<Vec<HeaderField>>`, `dynamic_table()`
`HeaderField`	HTTP/2 ヘッダーフィールド (HPACK 用、CRLF/NUL を構築時バリデーション)	`new(name, value) -> Result<Self, HeaderFieldError>`, `name() -> &[u8]`, `value() -> &[u8]`
`HeaderFieldError`	`HeaderField` の構築エラー	不正なヘッダー名・値のバリデーション失敗

Limits / Settings

型	説明
`Limits`	HTTP/2 接続の上限設定 (`max_concurrent_streams`, `initial_window_size`, `max_frame_size`, `max_header_list_size`, `header_table_size`, `connection_window_size`, `enable_connect_protocol`, `no_rfc7540_priorities`, `wt_initial_max_*`)
`LimitsBuilder`	`Limits` のビルダー。`builder()` で取得し、各メソッドで設定後 `build()`
`LimitsError`	`Limits` 構築時の値域エラー
`Settings`	受信した SETTINGS パラメータの値ホルダー
`Setting`	個別の SETTINGS パラメータ (`HeaderTableSize`, `EnablePush`, `MaxConcurrentStreams`, `InitialWindowSize`, `MaxFrameSize`, `MaxHeaderListSize`, `EnableConnectProtocol`, `NoRfc7540Priorities`, `WtInitialMaxData`, `WtInitialMaxStreamDataUni`, `WtInitialMaxStreamDataBidiLocal`, `WtInitialMaxStreamsUni`, `WtInitialMaxStreamsBidi`, `WtInitialMaxStreamDataBidiRemote`)
`SettingError`	SETTINGS の値検証エラー
`WindowSize`	フロー制御ウィンドウサイズ (`from_static(u32)` const + 動的 `try_new`)
`MaxFrameSize`	フレームサイズ上限 (16384..=16777215, RFC 9113 §6.5.2)

Limits のデフォルト値 (Limits::default()):

項目	値
`max_concurrent_streams`	`Some(100)`
`initial_window_size`	65535 (RFC 9113 §6.9.2)
`max_frame_size`	16384 (RFC 9113 §6.5.2)
`max_header_list_size`	`Some(16384)`
`header_table_size`	4096 (RFC 7541)

Stream / StreamId

型	説明
`StreamId`	ストリーム ID。`Connection` バリアントは 0、それ以外は非ゼロ。クライアント発行は奇数、サーバー発行は偶数
`NonZeroStreamId`	非ゼロのストリーム ID (1..=2^31-1)
`ClientStreamId` / `ServerStreamId`	パリティ付きストリーム ID
`Parity`	`Odd` (Client) / `Even` (Server)
`StreamIdError`	ストリーム ID 構築時のエラー
`Stream`	ストリームの状態ホルダー
`StreamState`	RFC 9113 §5.1 のストリーム状態 (`Idle`, `Open`, `HalfClosedLocal`, `HalfClosedRemote`, `Closed`, etc.)

フロー制御

型	説明
`FlowControl`	フロー制御ウィンドウ
`MAX_WINDOW_SIZE`	最大ウィンドウサイズ (`2^31 - 1`)

フレーム型

型	説明
`Frame`	全フレーム型を統合する enum (`Data`, `Headers`, `Priority`, `RstStream`, `Settings`, `PushPromise`, `Ping`, `Goaway`, `WindowUpdate`, `Continuation`, `PriorityUpdate`, `Unknown`)
`FrameType`	フレーム種別 (`Data` = 0x00, `Headers` = 0x01, `Priority` = 0x02, `RstStream` = 0x03, `Settings` = 0x04, `PushPromise` = 0x05, `Ping` = 0x06, `Goaway` = 0x07, `WindowUpdate` = 0x08, `Continuation` = 0x09, `PriorityUpdate` = 0x10)
`FrameHeader`	9 バイトフレームヘッダー (length, type, flags, stream_id)
`FrameFlags`	フレームフラグ (`END_STREAM`, `END_HEADERS`, `PADDED`, `PRIORITY`, `ACK`)
`FRAME_HEADER_SIZE`	フレームヘッダーサイズ定数 (9)
`DataFrame` / `HeadersFrame` / `RstStreamFrame` / `SettingsFrame` / `PingFrame` / `GoawayFrame` / `WindowUpdateFrame` / `ContinuationFrame` / `PriorityUpdateFrame`	各種フレーム構造体
`LastStreamId`	GOAWAY の `last_stream_id`
`Weight`	PRIORITY の重み (RFC 9113 では非推奨、受信のみ)
`WindowIncrement`	WINDOW_UPDATE の増分値 (1..=2^31-1)
`FrameDecoder` / `FrameEncoder`	低レベルなフレームのデコーダー/エンコーダー (`Connection` の内部で使用)
`FrameError`	フレーム処理エラー

CONNECTION_PREFACE: b"PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n" (24 バイト) CONNECTION_PREFACE_LEN: 24

WebTransport over HTTP/2

webtransport モジュール。Sans I/O の WtSession を中心に、Capsule Protocol (RFC 9297) と WebTransport Capsule (draft-ietf-webtrans-http2-15) を扱う。

WtSession

メソッド	戻り値	説明
`WtSession::client(WtConfig)` / `WtSession::server(WtConfig)`	`Self`	セッションを作成
`role()` / `state()` / `is_active()` / `is_closed()`	(各種)	セッション状態を返す
`initiate()`	`WtResult<()>`	初期 SETTINGS を送信
`feed(&[u8])`	`WtResult<usize>`	受信バイトを投入
`process()`	`WtResult<()>`	内部状態を進める
`poll_output()`	`Option<Vec<u8>>`	送信すべきバイト列を取得
`poll_event()`	`Option<WtEvent>`	イベントを取得
`has_output()`	`bool`	送信待ちがあるか
`open_bidi_stream()` / `open_uni_stream()`	`WtResult<WtStreamId>`	ストリームを開く
`send_stream_data(WtStreamId, &[u8], fin: bool)`	`WtResult<()>`	ストリームに WT_STREAM Capsule でデータ送信
`reset_stream(WtStreamId, error_code: u64)`	`WtResult<()>`	WT_RESET_STREAM を送信
`stop_sending(WtStreamId, error_code: u64)`	`WtResult<()>`	WT_STOP_SENDING を送信
`send_datagram(&[u8])`	`WtResult<()>`	DATAGRAM Capsule (RFC 9297) を送信
`close(error_code: u32, reason: &str)`	`WtResult<()>`	WT_CLOSE_SESSION を送信してセッション終了
`drain()`	`WtResult<()>`	WT_DRAIN_SESSION を送信
`send_max_data(maximum: u64)`	`WtResult<()>`	WT_MAX_DATA を送信
`send_max_stream_data(WtStreamId, maximum: u64)`	`WtResult<()>`	WT_MAX_STREAM_DATA を送信
`send_max_streams(maximum: u64, bidirectional: bool)`	`WtResult<()>`	WT_MAX_STREAMS を送信
`flow_control()` / `flow_control_mut()`	`&WtFlowControl` / `&mut WtFlowControl`	フロー制御状態
`stream(WtStreamId)`	`Option<&WtStream>`	ストリーム参照取得
`grow_recv_window(increment: u64)`	`WtResult<()>`	接続受信ウィンドウを拡張
`grow_stream_recv_window(WtStreamId, increment: u64)`	`WtResult<()>`	ストリーム受信ウィンドウを拡張
`grow_max_streams(increment: u64, bidirectional: bool)`	`WtResult<()>`	最大ストリーム数を拡張
`config()`	`&WtConfig`	設定参照

WtConfig / WtInit

WtConfig は初期フロー制御値や上限を保持する。apply_init(&WtInit) で WebTransport-Init ヘッダー値を反映できる。

WtEvent / WtSessionState

`WtEvent` バリアント	説明
`SessionReady`	セッション確立
`BidiStreamOpened` / `UniStreamOpened`	ストリームが開かれた
`StreamData`	ストリームに WT_STREAM Capsule が到着
`StreamReset` / `StreamStopSending`	リセット/停止要求
`Datagram`	DATAGRAM を受信
`MaxData` / `MaxStreamData` / `MaxStreams`	フロー制御上限の更新
`DataBlocked` / `StreamDataBlocked` / `StreamsBlocked`	フロー制御ブロック通知
`CloseSession` / `DrainSession`	セッション終了/排他要求

`WtSessionState`	説明
`Initial` / `Active` / `Draining` / `Closed`	セッション状態遷移

Capsule (draft-ietf-webtrans-http2-15 Section 6)

Capsule	Type コード
`WT_RESET_STREAM`	`0x190B4D39`
`WT_STOP_SENDING`	`0x190B4D3A`
`WT_STREAM` (FIN=0)	`0x190B4D3B`
`WT_STREAM` (FIN=1)	`0x190B4D3C`
`WT_MAX_DATA`	`0x190B4D3D`
`WT_MAX_STREAM_DATA`	`0x190B4D3E`
`WT_MAX_STREAMS_BIDI`	`0x190B4D3F`
`WT_MAX_STREAMS_UNI`	`0x190B4D40`
`WT_DATA_BLOCKED`	`0x190B4D41`
`WT_STREAM_DATA_BLOCKED`	`0x190B4D42`
`WT_STREAMS_BLOCKED_BIDI`	`0x190B4D43`
`WT_STREAMS_BLOCKED_UNI`	`0x190B4D44`
`WT_CLOSE_SESSION`	`0x2843`
`WT_DRAIN_SESSION`	`0x78AE`

WebTransport SETTINGS

パラメータ	Identifier
`SETTINGS_WT_INITIAL_MAX_DATA`	`0x2b61`
`SETTINGS_WT_INITIAL_MAX_STREAM_DATA_UNI`	`0x2b62`
`SETTINGS_WT_INITIAL_MAX_STREAM_DATA_BIDI_LOCAL`	`0x2b63`
`SETTINGS_WT_INITIAL_MAX_STREAMS_UNI`	`0x2b64`
`SETTINGS_WT_INITIAL_MAX_STREAMS_BIDI`	`0x2b65`
`SETTINGS_WT_INITIAL_MAX_STREAM_DATA_BIDI_REMOTE`	`0x2b66`

コード例

クライアント (Sans I/O)

use shiguredo_http2::{Connection, Event, HeaderField, Limits};

let limits = Limits::builder()
    .max_concurrent_streams(Some(100))
    .build()?;
let mut conn = Connection::client(limits);

// 接続を開始 (プリフェイスと SETTINGS をキューに積む)
conn.initiate()?;

// 送信バイトを取り出してネットワークに書き込む
while let Some(output) = conn.poll_output() {
    // stream.write_all(&output)?;
}

// リクエストを送信
let headers = vec![
    HeaderField::new(":method", "GET")?,
    HeaderField::new(":scheme", "https")?,
    HeaderField::new(":path", "/")?,
    HeaderField::new(":authority", "example.com")?,
];
let stream_id = conn.start_stream(headers, true)?;

// 受信バイトを投入してイベントを処理
// conn.feed(&received_data)?;
// conn.process()?;
// while let Some(event) = conn.poll_event() {
//     match event {
//         Event::HeadersReceived { stream_id, headers, end_stream, .. } => { /* ... */ }
//         Event::DataReceived { stream_id, data, end_stream } => { /* ... */ }
//         _ => {}
//     }
// }

サーバー (Sans I/O)

use shiguredo_http2::{Connection, Event, HeaderField, Limits};

let mut conn = Connection::server(Limits::default());

// 接続を開始 (SETTINGS を送信)
conn.initiate()?;

// 受信バイトを投入して処理
// conn.feed(&received_data)?;
// conn.process()?;

while let Some(event) = conn.poll_event() {
    match event {
        Event::HeadersReceived { stream_id, headers, end_stream, .. } => {
            let response_headers = vec![
                HeaderField::new(":status", "200")?,
                HeaderField::new("content-type", "text/plain")?,
            ];
            conn.send_response(stream_id, response_headers, false)?;
            conn.send_data(stream_id, b"Hello, HTTP/2!".to_vec(), true)?;
        }
        _ => {}
    }
}

HPACK エンコード/デコード

use shiguredo_http2::{HpackDecoder, HpackEncoder, HeaderField};

let mut encoder = HpackEncoder::new(4096);
let headers = vec![
    HeaderField::new(":status", "200")?,
    HeaderField::new("content-type", "text/plain")?,
];
let mut encoded = Vec::new();
encoder.encode(&mut encoded, &headers);

let mut decoder = HpackDecoder::new(4096);
let decoded = decoder.decode(&encoded)?;

WebTransport over HTTP/2 (Sans I/O)

use shiguredo_http2::webtransport::{WtConfig, WtSession};

let mut session = WtSession::client(WtConfig::default());
session.initiate()?;

let stream_id = session.open_bidi_stream()?;
session.send_stream_data(stream_id, b"Hello", false)?;
session.send_datagram(b"Datagram")?;

// session.feed(&received_data)?;
// session.process()?;
// while let Some(event) = session.poll_event() { /* ... */ }

Tokio 統合 (tokio-http2 / tokio-nghttp2)

Sans I/O 本体を Tokio + Rustls (aws-lc-rs) で非同期化する 2 系統のクレートを提供する。

クレート	内部	提供型
`tokio-http2`	shiguredo_http2 (純 Rust)	`Client`, `Server`, `ServerConnection`, `Connection<S>`, `TlsClientConfig`, `TlsServerConfig`, `webtransport::*`
`tokio-nghttp2`	shiguredo_nghttp2 (nghttp2 C ライブラリ)	`Client`, `Server`, `ServerConnection`, `Connection<S>`, `TlsClientConfig`, `TlsServerConfig`

両者とも ALPN は h2、TLS は Rustls (aws-lc-rs バックエンド)。Extended CONNECT (RFC 8441) と WebTransport は tokio-http2 のみ対応する。

TLS 設定

use tokio_http2::{TlsClientConfig, TlsServerConfig};

// クライアント
let tls = TlsClientConfig::with_platform_verifier()?;  // OS の証明書ストア
let tls = TlsClientConfig::with_custom_ca(ca_pem)?;    // カスタム CA
let tls = TlsClientConfig::insecure()?;                // テスト用 (検証なし)

// サーバー
let tls = TlsServerConfig::new(cert_pem, key_pem)?;
let tls = TlsServerConfig::from_der(certs, key)?;

tokio-http2 クライアント

use tokio_http2::{Client, Event, HeaderField, Limits, TlsClientConfig};

let mut client = Client::connect(addr, "example.com", TlsClientConfig::with_platform_verifier()?, Limits::default()).await?;
let stream_id = client.send_request(headers, true).await?;
match client.next_event().await? {
    Event::HeadersReceived { .. } => { /* ... */ }
    Event::DataReceived { .. } => { /* ... */ }
    _ => {}
}

tokio-http2 WebTransport サーバー

use shiguredo_http2::webtransport::WtConfig;
use tokio_http2::webtransport::{WEBTRANSPORT_PROTOCOL, WtServerRequest};

let request = WtServerRequest::from_connection(conn, stream_id, headers);
let mut session = request.accept(WtConfig::default(), Some(b"https://example.com")).await?;
while let Some(mut bidi) = session.accept_bidi().await {
    let data = bidi.recv().await?;
    bidi.send(b"hello".to_vec(), true).await?;
}

nghttp2 系 (tokio-nghttp2 / shiguredo_nghttp2)

nghttp2 C ライブラリを使う系統。shiguredo_nghttp2::Session を中心に以下の API を提供する。

型	説明
`Session`	nghttp2 セッション。`client()` / `server()` / `client_with_options(&SessionOptions)` / `server_with_options(&SessionOptions)`
`SessionOptions`	DoS 対策・フロー制御挙動のオプション Builder (`no_auto_window_update`, `peer_max_concurrent_streams`, `no_auto_ping_ack`, `max_send_header_block_length`, `max_deflate_dynamic_table_size`, `max_outbound_ack`, `max_settings`, `stream_reset_rate_limit`, `max_continuations`, `glitch_rate_limit`)
`Http2Event`	nghttp2 由来のイベント (`HeadersReceived`, `DataReceived`, `StreamClosed`, `GoawayReceived`, `PingReceived`, `SettingsReceived`, `WindowUpdateReceived`, `FrameSent`, `FrameNotSent`, `InvalidFrameReceived`, `InvalidHeaderReceived`)
`Header`	nghttp2 用ヘッダー (擬似ヘッダーのヘルパー `method()` / `scheme()` / `authority()` / `path()` / `status()` / `sensitive()`)
`ErrorCode` / `FrameType` / `SettingsId` / `StreamId`	HTTP/2 各種定数

tokio-nghttp2 の Client / Server / ServerConnection はこれを Tokio で非同期化する薄いラッパー。

エラー型

`Error` (HTTP/2 接続エラー)

`ErrorKind` バリアント	説明
`Connection { code, reason }`	接続レベルエラー (GOAWAY 送信対象)
`Stream { code, reason }`	ストリームレベルエラー (RST_STREAM 送信対象)
`Hpack { reason }`	HPACK デコードエラー (RFC 7541)
`Protocol { reason }`	プロトコル違反
`FrameSize { reason }`	フレームサイズ違反
`Io { source }`	I/O エラー

`ErrorCode` (HTTP/2 エラーコード)

RFC 9113 §7 の HTTP/2 エラーコード。as_u32() / from_u32(u32) で変換可能。

バリアント	コード
`NoError`	`0x00`
`ProtocolError`	`0x01`
`InternalError`	`0x02`
`FlowControlError`	`0x03`
`SettingsTimeout`	`0x04`
`StreamClosed`	`0x05`
`FrameSizeError`	`0x06`
`RefusedStream`	`0x07`
`Cancel`	`0x08`
`CompressionError`	`0x09`
`ConnectError`	`0x0a`
`EnhanceYourCalm`	`0x0b`
`InadequateSecurity`	`0x0c`
`Http11Required`	`0x0d`

その他

DecodeError: フレームデコード時のバイト列エラー
SendError: 送信側 API のエラー (フロー制御不足、ストリーム状態違反など)
FrameError: フレーム構造エラー
SettingError: SETTINGS 値検証エラー
LimitsError: Limits 構築時の値域エラー
StreamIdError: ストリーム ID 構築エラー
HeaderFieldError: HPACK ヘッダー構築エラー (CRLF/NUL 拒否)

対応仕様

RFC / draft	名称	対応機能
RFC 7541	HPACK: Header Compression for HTTP/2	静的/動的テーブル、Huffman、整数符号化
RFC 8441	Bootstrapping WebSockets with HTTP/2	Extended CONNECT (`:protocol` 擬似ヘッダー)
RFC 9113	HTTP/2	フレーム、フロー制御、ストリーム状態遷移、CONNECT、エラー処理
RFC 9218	Extensible Prioritization Scheme for HTTP	PRIORITY_UPDATE フレーム、`urgency` / `incremental`
RFC 9297	HTTP Datagrams and the Capsule Protocol	Capsule, DATAGRAM, PADDING
draft-ietf-webtrans-http2-15	WebTransport over HTTP/2	WT_* Capsule, WebTransport SETTINGS, Extended CONNECT (`webtransport`), TLS 1.3 要件, Origin 検証

既知の未対応 / 制限

サーバープッシュ (PUSH_PROMISE): 主要ブラウザ (Chrome / Firefox / Safari) が削除済みのため未対応。受信した場合は PROTOCOL_ERROR で GOAWAY する (src/connection/mod.rs:926)。
WebSocket over HTTP/2: Extended CONNECT (RFC 8441) は対応しているが、WebSocket フレーム層は未実装。
PRIORITY フレーム: RFC 9113 で非推奨。受信は処理する (優先度情報は無視) が、送信はしない。
HEADERS の優先度フィールド: RFC 9113 で非推奨。
tokio-nghttp2 と Extended CONNECT / WebTransport: tokio-nghttp2 側は Extended CONNECT と WebTransport を提供しない (tokio-http2 のみ)。
tokio-http2 の WebTransport accept は TLS 1.3 必須: rustls 0.23 が TLS 1.2 + extended master secret のネゴシエーション状態を外部公開していないため、安全側に倒して TLS 1.3 のみを許可する (draft-ietf-webtrans-http2-15 Section 7 の要件より厳しい)。

shiguredo-http2

shiguredo_http2

特徴

バージョン情報

クレート構成

コア API (shiguredo_http2)

Connection

Role / ConnectionState

Event (Sans I/O イベント)

HPACK

Limits / Settings

Stream / StreamId

フロー制御

フレーム型

WebTransport over HTTP/2

WtSession

WtConfig / WtInit

WtEvent / WtSessionState

Capsule (draft-ietf-webtrans-http2-15 Section 6)

WebTransport SETTINGS

コード例

クライアント (Sans I/O)

サーバー (Sans I/O)

HPACK エンコード/デコード

WebTransport over HTTP/2 (Sans I/O)

Tokio 統合 (tokio-http2 / tokio-nghttp2)

TLS 設定

tokio-http2 クライアント

tokio-http2 WebTransport サーバー

nghttp2 系 (tokio-nghttp2 / shiguredo_nghttp2)

エラー型

Error (HTTP/2 接続エラー)

ErrorCode (HTTP/2 エラーコード)

その他

対応仕様

既知の未対応 / 制限

shiguredo_http2

特徴

バージョン情報

クレート構成

コア API (shiguredo_http2)

Connection

Role / ConnectionState

Event (Sans I/O イベント)

HPACK

Limits / Settings

Stream / StreamId

フロー制御

フレーム型

WebTransport over HTTP/2

WtSession

WtConfig / WtInit

WtEvent / WtSessionState

Capsule (draft-ietf-webtrans-http2-15 Section 6)

WebTransport SETTINGS

コード例

クライアント (Sans I/O)

サーバー (Sans I/O)

HPACK エンコード/デコード

WebTransport over HTTP/2 (Sans I/O)

Tokio 統合 (tokio-http2 / tokio-nghttp2)

TLS 設定

tokio-http2 クライアント

tokio-http2 WebTransport サーバー

nghttp2 系 (tokio-nghttp2 / shiguredo_nghttp2)

エラー型

Error (HTTP/2 接続エラー)

ErrorCode (HTTP/2 エラーコード)

その他

対応仕様

既知の未対応 / 制限

`Error` (HTTP/2 接続エラー)

`ErrorCode` (HTTP/2 エラーコード)

`Error` (HTTP/2 接続エラー)

`ErrorCode` (HTTP/2 エラーコード)