Servlin

A modular HTTP server library in Rust.

Features

• forbid(unsafe_code)
• Threaded request handlers:
  FnOnce(Request) -> Response + 'static + Clone + Send + Sync
• Uses async code internally for excellent performance under load
• JSON
• Server-Sent Events (SSE)
• Saves large request bodies to temp files
• Sends 100-Continue
• Limits number of threads and connections
• Modular: roll your own logging, write custom versions of internal methods, etc.
• No macros or complicated type params
• Good test coverage (63%)

Limitations

• New, not proven in production.
• To do:
  • Request timeouts
  • chunked transfer-encoding for request bodies
  • gzip
  • brotli
  • TLS
  • automatically getting TLS certs via ACME
  • Drop idle connections when approaching connection limit.
  • Denial-of-Service mitigation: source throttling, minimum throughput
  • Complete functional test suite
  • Missing load tests
  • Disk space usage limits

Examples

Complete examples: examples/.

Simple example:

use serde::Deserialize;
use serde_json::json;
use servlin::{
    socket_addr_127_0_0_1,
    Error,
    HttpServerBuilder,
    Request,
    Response
};
use servlin::log::log_request_and_response;
use std::sync::Arc;
use temp_dir::TempDir;

struct State {}

fn hello(_state: Arc<State>, req: Request) -> Result<Response, Error> {
    #[derive(Deserialize)]
    struct Input {
        name: String,
    }
    let input: Input = req.json()?;
    Ok(Response::json(200, json!({"message": format!("Hello, {}!", input.name)}))?)
}

fn handle_req(state: Arc<State>, req: Request) -> Result<Response, Error> {
    match (req.method(), req.url().path()) {
        ("GET", "/ping") => Ok(Response::text(200, "ok")),
        ("POST", "/hello") => hello(state, req),
        _ => Ok(Response::text(404, "Not found")),
    }
}

let state = Arc::new(State {});
let request_handler = move |req: Request| {
    log_request_and_response(req, |req| handle_req(state, req)).unwrap()
};
let cache_dir = TempDir::new().unwrap();
safina::timer::start_timer_thread();
let executor = safina::executor::Executor::new(1, 9).unwrap();
executor.block_on(
    HttpServerBuilder::new()
        .listen_addr(socket_addr_127_0_0_1(8271))
        .max_conns(1000)
        .small_body_len(64 * 1024)
        .receive_large_bodies(cache_dir.path())
        .spawn_and_join(request_handler)
).unwrap();

Cargo Geiger Safety Report

Metric output format: x/y
    x = unsafe code used by the build
    y = total unsafe code found in the crate

Symbols: 
    🔒  = No `unsafe` usage found, declares #![forbid(unsafe_code)]
    ❓  = No `unsafe` usage found, missing #![forbid(unsafe_code)]
    ☢️  = `unsafe` usage found

Functions  Expressions  Impls  Traits  Methods  Dependency

0/0        0/0          0/0    0/0     0/0      🔒  servlin 0.6.0
0/0        0/0          0/0    0/0     0/0      🔒  ├── safina 0.6.0
0/0        0/0          0/0    0/0     0/0      🔒  │   └── safina-macros 0.1.3
0/0        0/0          0/0    0/0     0/0      🔒  │       ├── safe-proc-macro2 1.0.67
0/0        4/4          0/0    0/0     0/0      ☢️  │       │   └── unicode-ident 1.0.13
0/0        0/0          0/0    0/0     0/0      🔒  │       └── safe-quote 1.0.15
0/0        0/0          0/0    0/0     0/0      🔒  │           └── safe-proc-macro2 1.0.67
0/0        0/0          0/0    0/0     0/0      🔒  ├── async-fs 2.1.2
4/4        222/222      40/40  0/0     13/13    ☢️  │   ├── async-lock 3.4.0
0/0        2/2          0/0    0/0     0/0      ☢️  │   │   ├── event-listener-strategy 0.5.2
0/0        39/49        8/12   0/0     2/2      ☢️  │   │   │   ├── event-listener 5.3.1
0/0        183/183      2/2    0/0     1/1      ☢️  │   │   │   │   ├── concurrent-queue 2.5.0
4/4        12/75        4/16   0/0     0/3      ☢️  │   │   │   │   │   └── crossbeam-utils 0.8.20
0/0        0/0          0/0    0/0     0/0      🔒  │   │   │   │   ├── parking 2.2.1
0/0        11/191       0/0    0/0     2/2      ☢️  │   │   │   │   └── pin-project-lite 0.2.14
0/0        11/191       0/0    0/0     2/2      ☢️  │   │   │   └── pin-project-lite 0.2.14
0/0        39/49        8/12   0/0     2/2      ☢️  │   │   ├── event-listener 5.3.1
0/0        11/191       0/0    0/0     2/2      ☢️  │   │   └── pin-project-lite 0.2.14
0/0        0/0          0/0    0/0     0/0      🔒  │   ├── blocking 1.6.1
0/0        0/0          0/0    0/0     0/0      🔒  │   │   ├── async-channel 2.3.1
0/0        183/183      2/2    0/0     1/1      ☢️  │   │   │   ├── concurrent-queue 2.5.0
0/0        2/2          0/0    0/0     0/0      ☢️  │   │   │   ├── event-listener-strategy 0.5.2
0/0        36/36        2/2    0/0     0/0      ☢️  │   │   │   ├── futures-core 0.3.31
0/0        11/191       0/0    0/0     2/2      ☢️  │   │   │   └── pin-project-lite 0.2.14
1/1        860/866      4/4    0/0     13/13    ☢️  │   │   ├── async-task 4.7.1
0/0        0/0          0/0    0/0     0/0      ❓  │   │   ├── futures-io 0.3.31
0/0        0/0          0/0    0/0     0/0      ❓  │   │   ├── futures-lite 2.3.0
0/0        0/0          0/0    0/0     0/0      🔒  │   │   │   ├── fastrand 2.1.1
0/0        36/36        2/2    0/0     0/0      ☢️  │   │   │   ├── futures-core 0.3.31
0/0        0/0          0/0    0/0     0/0      ❓  │   │   │   ├── futures-io 0.3.31
27/41      1973/2421    2/2    0/0     109/147  ☢️  │   │   │   ├── memchr 2.7.4
0/0        0/0          0/0    0/0     0/0      🔒  │   │   │   ├── parking 2.2.1
0/0        11/191       0/0    0/0     2/2      ☢️  │   │   │   └── pin-project-lite 0.2.14
0/0        28/28        2/2    0/0     0/0      ☢️  │   │   ├── piper 0.2.4
0/0        32/32        2/2    0/0     0/0      ☢️  │   │   │   ├── atomic-waker 1.1.2
0/0        0/0          0/0    0/0     0/0      🔒  │   │   │   ├── fastrand 2.1.1
0/0        0/0          0/0    0/0     0/0      ❓  │   │   │   └── futures-io 0.3.31
0/0        14/14        1/1    0/0     0/0      ☢️  │   │   └── tracing 0.1.40
0/0        11/191       0/0    0/0     2/2      ☢️  │   │       ├── pin-project-lite 0.2.14
0/0        96/96        5/5    0/0     2/2      ☢️  │   │       └── tracing-core 0.1.32
0/0        0/0          0/0    0/0     0/0      ❓  │   └── futures-lite 2.3.0
0/0        0/0          0/0    0/0     0/0      🔒  ├── async-net 2.0.0
0/0        68/114       19/22  1/1     4/8      ☢️  │   ├── async-io 2.3.4
4/4        222/222      40/40  0/0     13/13    ☢️  │   │   ├── async-lock 3.4.0
0/0        0/0          0/0    0/0     0/0      ❓  │   │   ├── cfg-if 1.0.0
0/0        183/183      2/2    0/0     1/1      ☢️  │   │   ├── concurrent-queue 2.5.0
0/0        0/0          0/0    0/0     0/0      ❓  │   │   ├── futures-io 0.3.31
0/0        0/0          0/0    0/0     0/0      ❓  │   │   ├── futures-lite 2.3.0
0/0        0/0          0/0    0/0     0/0      🔒  │   │   ├── parking 2.2.1
0/2        34/420       5/20   1/4     5/14     ☢️  │   │   ├── polling 3.7.3
0/0        0/0          0/0    0/0     0/0      ❓  │   │   │   ├── cfg-if 1.0.0
53/389     2527/7252    6/8    1/1     20/35    ☢️  │   │   │   ├── rustix 0.38.37
0/0        0/0          0/0    0/0     0/0      ❓  │   │   │   │   ├── bitflags 2.6.0
0/0        5/5          0/0    0/0     0/0      ☢️  │   │   │   │   │   └── serde 1.0.210
0/0        0/0          0/0    0/0     0/0      ❓  │   │   │   │   │       └── serde_derive 1.0.210
0/0        15/15        0/0    0/0     3/3      ☢️  │   │   │   │   │           ├── proc-macro2 1.0.88
0/0        4/4          0/0    0/0     0/0      ☢️  │   │   │   │   │           │   └── unicode-ident 1.0.13
0/0        0/0          0/0    0/0     0/0      ❓  │   │   │   │   │           ├── quote 1.0.37
0/0        15/15        0/0    0/0     3/3      ☢️  │   │   │   │   │           │   └── proc-macro2 1.0.88
0/0        88/88        3/3    0/0     2/2      ☢️  │   │   │   │   │           └── syn 2.0.82
0/0        15/15        0/0    0/0     3/3      ☢️  │   │   │   │   │               ├── proc-macro2 1.0.88
0/0        0/0          0/0    0/0     0/0      ❓  │   │   │   │   │               ├── quote 1.0.37
0/0        4/4          0/0    0/0     0/0      ☢️  │   │   │   │   │               └── unicode-ident 1.0.13
0/0        35/103       0/0    0/0     0/0      ☢️  │   │   │   │   ├── errno 0.3.9
1/90       10/596       0/2    0/0     5/69     ☢️  │   │   │   │   │   └── libc 0.2.161
0/0        7/7          0/0    0/0     0/0      ☢️  │   │   │   │   ├── itoa 1.0.11
1/90       10/596       0/2    0/0     5/69     ☢️  │   │   │   │   └── libc 0.2.161
0/0        14/14        1/1    0/0     0/0      ☢️  │   │   │   └── tracing 0.1.40
53/389     2527/7252    6/8    1/1     20/35    ☢️  │   │   ├── rustix 0.38.37
0/0        23/23        0/0    0/0     3/3      ☢️  │   │   ├── slab 0.4.9
0/0        5/5          0/0    0/0     0/0      ☢️  │   │   │   └── serde 1.0.210
0/0        14/14        1/1    0/0     0/0      ☢️  │   │   └── tracing 0.1.40
0/0        0/0          0/0    0/0     0/0      🔒  │   ├── blocking 1.6.1
0/0        0/0          0/0    0/0     0/0      ❓  │   └── futures-lite 2.3.0
0/0        0/0          0/0    0/0     0/0      🔒  ├── fixed-buffer 1.0.0
0/0        0/0          0/0    0/0     0/0      ❓  │   └── futures-io 0.3.31
0/0        0/0          0/0    0/0     0/0      ❓  ├── futures-io 0.3.31
0/0        0/0          0/0    0/0     0/0      ❓  ├── futures-lite 2.3.0
0/0        0/0          0/0    0/0     0/0      ❓  ├── include_dir 0.7.4
0/0        0/0          0/0    0/0     0/0      ❓  │   └── include_dir_macros 0.7.4
0/0        15/15        0/0    0/0     3/3      ☢️  │       ├── proc-macro2 1.0.88
0/0        0/0          0/0    0/0     0/0      ❓  │       └── quote 1.0.37
0/0        0/0          0/0    0/0     0/0      🔒  ├── permit 0.2.1
0/0        32/32        0/0    0/0     0/0      ☢️  ├── rand 0.8.5
1/90       10/596       0/2    0/0     5/69     ☢️  │   ├── libc 0.2.161
0/0        0/0          0/0    0/0     0/0      ❓  │   ├── rand_chacha 0.3.1
2/2        632/680      0/0    0/0     17/25    ☢️  │   │   ├── ppv-lite86 0.2.20
2/2        116/116      7/7    8/8     8/8      ☢️  │   │   │   └── zerocopy 0.7.35
0/1        162/179      0/0    0/0     0/0      ☢️  │   │   │       ├── byteorder 1.5.0
0/0        0/0          0/0    0/0     0/0      ❓  │   │   │       └── zerocopy-derive 0.7.35
0/0        15/15        0/0    0/0     3/3      ☢️  │   │   │           ├── proc-macro2 1.0.88
0/0        0/0          0/0    0/0     0/0      ❓  │   │   │           ├── quote 1.0.37
0/0        88/88        3/3    0/0     2/2      ☢️  │   │   │           └── syn 2.0.82
0/0        2/2          0/0    0/0     0/0      ☢️  │   │   ├── rand_core 0.6.4
3/6        51/192       0/1    0/0     1/3      ☢️  │   │   │   ├── getrandom 0.2.15
0/0        0/0          0/0    0/0     0/0      ❓  │   │   │   │   ├── cfg-if 1.0.0
1/90       10/596       0/2    0/0     5/69     ☢️  │   │   │   │   └── libc 0.2.161
0/0        5/5          0/0    0/0     0/0      ☢️  │   │   │   └── serde 1.0.210
0/0        5/5          0/0    0/0     0/0      ☢️  │   │   └── serde 1.0.210
0/0        2/2          0/0    0/0     0/0      ☢️  │   ├── rand_core 0.6.4
0/0        5/5          0/0    0/0     0/0      ☢️  │   └── serde 1.0.210
0/0        0/0          0/0    0/0     0/0      🔒  ├── safe-regex 0.3.0
0/0        0/0          0/0    0/0     0/0      🔒  │   └── safe-regex-macro 0.3.0
0/0        0/0          0/0    0/0     0/0      🔒  │       ├── safe-proc-macro2 1.0.67
0/0        0/0          0/0    0/0     0/0      🔒  │       └── safe-regex-compiler 0.3.0
0/0        0/0          0/0    0/0     0/0      🔒  │           ├── safe-proc-macro2 1.0.67
0/0        0/0          0/0    0/0     0/0      🔒  │           └── safe-quote 1.0.15
0/0        5/5          0/0    0/0     0/0      ☢️  ├── serde 1.0.210
0/0        66/69        0/0    0/0     0/0      ☢️  ├── serde_json 1.0.132
0/0        7/7          0/0    0/0     0/0      ☢️  │   ├── itoa 1.0.11
27/41      1973/2421    2/2    0/0     109/147  ☢️  │   ├── memchr 2.7.4
7/9        572/702      0/0    0/0     2/2      ☢️  │   ├── ryu 1.0.18
0/0        5/5          0/0    0/0     0/0      ☢️  │   └── serde 1.0.210
0/0        0/0          0/0    0/0     0/0      🔒  ├── serde_urlencoded 0.7.1
0/0        2/2          0/0    0/0     0/0      ☢️  │   ├── form_urlencoded 1.2.1
0/0        8/8          0/0    0/0     0/0      ☢️  │   │   └── percent-encoding 2.3.1
0/0        7/7          0/0    0/0     0/0      ☢️  │   ├── itoa 1.0.11
7/9        572/702      0/0    0/0     2/2      ☢️  │   ├── ryu 1.0.18
0/0        5/5          0/0    0/0     0/0      ☢️  │   └── serde 1.0.210
0/0        0/0          0/0    0/0     0/0      🔒  ├── temp-dir 0.1.14
0/0        0/0          0/0    0/0     0/0      🔒  ├── temp-file 0.1.9
0/0        0/0          0/0    0/0     0/0      ❓  └── url 2.5.2
0/0        2/2          0/0    0/0     0/0      ☢️      ├── form_urlencoded 1.2.1
0/0        0/0          0/0    0/0     0/0      ❓      ├── idna 0.5.0
0/0        5/5          0/0    0/0     0/0      ☢️      │   ├── unicode-bidi 0.3.17
0/0        5/5          0/0    0/0     0/0      ☢️      │   │   └── serde 1.0.210
1/1        24/24        0/0    0/0     0/0      ☢️      │   └── unicode-normalization 0.1.24
0/0        0/0          0/0    0/0     0/0      🔒      │       └── tinyvec 1.8.0
0/0        5/5          0/0    0/0     0/0      ☢️      │           ├── serde 1.0.210
0/0        0/0          0/0    0/0     0/0      🔒      │           └── tinyvec_macros 0.1.1
0/0        8/8          0/0    0/0     0/0      ☢️      ├── percent-encoding 2.3.1
0/0        5/5          0/0    0/0     0/0      ☢️      └── serde 1.0.210

105/552    7996/14853   112/151 11/14   212/355

Alternatives

See rust-webserver-comparison.md.

Changelog

• v0.6.0 2024-11-02
  • Remove servlin::reexports module.
  • Use safina v0.6.0.
• v0.5.1 2024-10-26 - Remove dependency on once_cell.
• v0.5.0 2024-10-21 - Remove LogFileWriterBuilder.
• v0.4.3 - Implement From<Cow<'_, str>> and From<&Path> for TagValue.
• v0.4.2 - Implement Seek for BodyReader.
• v0.4.1
  • Add Request::opt_json.
  • Implement From<LoggerStoppedError> for Error.
• v0.4.0
  • Changed Response::json to return Result<Response, Error>.
  • Changed log_request_and_response to return Result.
  • Added Response::unprocessable_entity_422.
• v0.3.2 - Fix bug in Response::include_dir redirects.
• v0.3.1
  • Add Response::redirect_301
  • Response::include_dir to redirect from /somedir to /somedir/ so relative URLs will work.
• v0.3.0 - Changed Response::include_dir to take &Request and look for index.html in dirs.
• v0.2.0
  • Added:
    • log_request_and_response and other logging tooling
    • Response::ok_200()
    • Response::unauthorized_401()
    • Response::forbidden_403()
    • Response::internal_server_errror_500()
    • Response::not_implemented_501()
    • Response::service_unavailable_503()
    • EventSender::is_connected()
    • PORT_env()
  • Removed print_log_response and RequestBody::length_is_known
  • Changed RequestBody::len and is_empty to return Option.
  • Bugfixes
• v0.1.1 - Add EventSender::unconnected.
• v0.1.0 - Rename library to Servlin.

TO DO

• Fix limitations above
• Support HEAD responses that have Content-Length set and no body.
• Add a server-wide limit on upload body size.
• Limit disk usage for caching uploads.
• Update rust-webserver-comparison.md
  • Add missing data
  • Add other servers from https://www.arewewebyet.org/topics/frameworks/
  • Rearrange
  • Generate geiger reports for each web server

License: MIT OR Apache-2.0