4 releases
0.1.0-alpha.3 | May 7, 2023 |
---|---|
0.1.0-alpha.2 | May 1, 2023 |
0.1.0-alpha.1 | Mar 27, 2023 |
0.1.0-alpha | Feb 18, 2023 |
#1419 in HTTP server
Used in micro-web
69KB
1.5K
SLoC
Micro http
yet another async http server
Example
use http::{Request, Response, StatusCode};
use http_body_util::BodyExt;
use std::error::Error;
use std::sync::Arc;
use tokio::net::TcpListener;
use tracing::{error, info, warn, Level};
use tracing_subscriber::FmtSubscriber;
use micro_http::connection::HttpConnection;
use micro_http::handler::make_handler;
use micro_http::protocol::body::ReqBody;
#[tokio::main]
async fn main() {
let subscriber = FmtSubscriber::builder().with_max_level(Level::INFO).finish();
tracing::subscriber::set_global_default(subscriber).expect("setting default subscriber failed");
info!(port = 8080, "start listening");
let tcp_listener = match TcpListener::bind("127.0.0.1:8080").await {
Ok(tcp_listener) => tcp_listener,
Err(e) => {
error!(cause = %e, "bind server error");
return;
}
};
let handler = make_handler(simple_handler);
let handler = Arc::new(handler);
loop {
let (tcp_stream, _remote_addr) = match tcp_listener.accept().await {
Ok(stream_and_addr) => stream_and_addr,
Err(e) => {
warn!(cause = %e, "failed to accept");
continue;
}
};
let handler = handler.clone();
tokio::spawn(async move {
let (reader, writer) = tcp_stream.into_split();
let connection = HttpConnection::new(reader, writer);
match connection.process(handler).await {
Ok(_) => {
info!("finished process, connection shutdown");
}
Err(e) => {
error!("service has error, cause {}, connection shutdown", e);
}
}
});
}
}
async fn simple_handler(request: Request<ReqBody>) -> Result<Response<String>, Box<dyn Error + Send + Sync>> {
let path = request.uri().path().to_string();
info!("request path {}", path);
let (_header, body) = request.into_parts();
let body_bytes = body.collect().await?.to_bytes();
info!(body = std::str::from_utf8(&body_bytes[..]).unwrap(), "receiving request body");
let response_body = "Hello World!\r\n";
let response = Response::builder()
.status(StatusCode::OK)
.header(http::header::CONTENT_LENGTH, response_body.len())
.body(response_body.to_string())
.unwrap();
Ok(response)
}
Dependencies
~5–14MB
~163K SLoC