WebTransport
WebTransport — это сетевой протокол передачи данных на основе HTTP/3, который обеспечивает двустороннюю связь между клиентом и сервером, сочетая в себе низкую задержку, высокую пропускную способность и безопасность.
Применение
WebTransport особенно подходит для следующих сценариев:
- Приложения реального времени: онлайн-игры, инструменты для совместной работы, видеоконференции и другие приложения, требующие низкой задержки связи
- Передача больших файлов: поддержка высокоскоростной передачи данных, идеально подходит для потоковой передачи медиа и загрузки/выгрузки больших файлов
- Мультиплексированная связь: возможность одновременного установления нескольких двунаправленных и однонаправленных потоков данных
- Передача датаграмм: поддержка передачи данных без гарантии порядка и надежности, что идеально для сценариев с критически важной задержкой
По сравнению с WebSocket, WebTransport обеспечивает меньшую задержку и более гибкие режимы связи, особенно хорошо проявляя себя в нестабильных сетевых условиях.
Реализация в Salvo
Фреймворк Salvo предоставляет встроенную поддержку WebTransport, позволяя разработчикам легко создавать приложения на его основе. Основные возможности включают:
- Поддержку установления сессий WebTransport
- Поддержку двунаправленных потоков (Bidirectional Streams)
- Поддержку однонаправленных потоков (Unidirectional Streams)
- Поддержку передачи датаграмм (Datagrams)
- Возможность инициации потоков связи сервером
Простой пример
Ниже приведен упрощенный пример реализации сервера WebTransport с использованием Salvo:
#[handler]
async fn connect(req: &mut Request) -> Result<(), salvo::Error> {
let session = req.web_transport_mut().await.unwrap();
// Обработка датаграмм
if let Ok(Some((_, datagram))) = session.accept_datagram().await {
// Обработка полученных датаграмм
let mut resp = BytesMut::from(&b"Response: "[..]);
resp.put(datagram);
session.send_datagram(resp.freeze())?;
}
// Обработка двунаправленных потоков
if let Ok(Some(webtransport::server::AcceptedBi::BidiStream(_, stream))) = session.accept_bi().await {
let (send, recv) = salvo::proto::quic::BidiStream::split(stream);
// Обработка данных двунаправленного потока
}
Ok(())
}
Настройка и запуск
Для запуска приложения Salvo с поддержкой WebTransport необходимо настроить TLS-сертификат и QUIC-листенер:
let cert = include_bytes!("../certs/cert.pem").to_vec();
let key = include_bytes!("../certs/key.pem").to_vec();
// Настройка маршрутизации
let router = Router::new().push(Router::with_path("counter").goal(connect));
// Настройка TLS
let config = RustlsConfig::new(Keycert::new().cert(cert.as_slice()).key(key.as_slice()));
// Настройка листенера
let listener = TcpListener::new(("0.0.0.0", 5800)).rustls(config.clone());
let acceptor = QuinnListener::new(config, ("0.0.0.0", 5800))
.join(listener)
.bind()
.await;
// Запуск сервера
Server::new(acceptor).serve(router).await;
Полный пример
Чтобы узнать больше об использовании WebTransport в Salvo, ознакомьтесь с полным примером на GitHub:
https://github.com/salvo-rs/salvo/blob/main/examples/webtransport
Этот пример включает полную реализацию как серверной, так и клиентской части, демонстрируя обработку различных типов связи через WebTransport.