14 unstable releases (5 breaking)

new 0.6.0 Nov 3, 2024
0.4.3 Jan 11, 2024
0.4.2 Dec 30, 2023
0.4.0 Nov 4, 2023
0.1.1 Jun 27, 2022

#82 in HTTP server

Download history 2/week @ 2024-08-31 6/week @ 2024-09-21 33/week @ 2024-09-28 2/week @ 2024-10-05 2/week @ 2024-10-12 176/week @ 2024-10-19 140/week @ 2024-10-26

321 downloads per month
Used in applin

MIT/Apache

205KB
4.5K SLoC

Servlin

crates.io version license: Apache 2.0 unsafe forbidden pipeline status

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

License: MIT OR Apache-2.0

Dependencies

~5–14MB
~198K SLoC