17 releases
new 0.2.4 | Nov 6, 2024 |
---|---|
0.2.2 | Sep 15, 2024 |
0.2.0 | Mar 23, 2024 |
0.2.0-alpha.3 | Dec 7, 2023 |
0.1.2 | Nov 3, 2021 |
#33 in HTTP client
1,469 downloads per month
Used in 5 crates
135KB
3K
SLoC
OxHTTP
OxHTTP is a simple and naive synchronous implementation of HTTP 1.1 in Rust. It provides both a client and a server. It does not aim to be a fully-working-in-all-cases HTTP implementation but to be only a simple one to be use in simple usecases.
Client
OxHTTP provides a client. It aims at following the basic concepts of the Web Fetch standard without the bits specific to web browsers (context, CORS...).
HTTPS is supported behind the disabled by default features. To enable it you need to enable one of the following features:
native-tls
to use the current system native implementation.rustls-ring-platform-verifier
to use Rustls with the Ring cryptographic library and the host verifier or platform certificates.rustls-ring-webpki
to use Rustls with the Ring cryptographic library and the Common CA Database.rustls-ring-native
to use Rustls with the Ring cryptographic library and the host certificates.rustls-aws-lc-platform-verifier
to use Rustls with the AWS Libcrypto for Rust and the host verifier or platform certificates.rustls-aws-lc-webpki
to use Rustls with the AWS Libcrypto for Rust and the Common CA Database.rustls-aws-lc-native
to use Rustls with the AWS Libcrypto for Rust and the host certificates.
Example:
use oxhttp::Client;
use oxhttp::model::{Request, Method, Status, HeaderName};
use std::io::Read;
let client = Client::new();
let response = client.request(Request::builder(Method::GET, "http://example.com".parse().unwrap()).build()).unwrap();
assert_eq!(response.status(), Status::OK);
assert_eq!(response.header(&HeaderName::CONTENT_TYPE).unwrap().as_ref(), b"text/html; charset=UTF-8");
let body = response.into_body().to_string().unwrap();
Server
OxHTTP provides a threaded HTTP server. It is still a work in progress. Use at your own risks behind a reverse proxy!
Example:
use std::net::{Ipv4Addr, Ipv6Addr};
use oxhttp::Server;
use oxhttp::model::{Response, Status};
use std::time::Duration;
// Builds a new server that returns a 404 everywhere except for "/" where it returns the body 'home'
let mut server = Server::new( | request| {
if request.url().path() == "/" {
Response::builder(Status::OK).with_body("home")
} else {
Response::builder(Status::NOT_FOUND).build()
}
});
// We bind the server to localhost on both IPv4 and v6
server = server.bind((Ipv4Addr::LOCALHOST, 8080)).bind((Ipv6Addr::LOCALHOST, 8080));
// Raise a timeout error if the client does not respond after 10s.
server = server.with_global_timeout(Duration::from_secs(10));
// Limits the max number of concurrent connections to 128.
server = server.with_max_concurrent_connections(128);
// We spawn the server and block on it
server.spawn().unwrap().join().unwrap();
License
This project is licensed under either of
- Apache License, Version 2.0, (LICENSE-APACHE or
<http://www.apache.org/licenses/LICENSE-2.0>
) - MIT license (LICENSE-MIT or
<http://opensource.org/licenses/MIT>
)
at your option.
Contribution
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in OxHTTP by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.
Dependencies
~2–21MB
~401K SLoC