Struct salvo_core::server::Server

pub struct Server<A> { /* private fields */ }

Available on crate feature server only.

HTTP Server

A Server is created to listen on a port, parse HTTP requests, and hand them off to a Service.

Implementations

impl<A: Acceptor + Send> Server<A>

pub fn new(acceptor: A) -> Self

Create new Server with Acceptor.

Example

use salvo_core::prelude::*;

#[tokio::main]
async fn main() {
    let acceptor = TcpListener::new("127.0.0.1:5800").bind().await;
    Server::new(acceptor);
}

pub fn with_http_builder(acceptor: A, builder: HttpBuilder) -> Self

Create new Server with Acceptor and [HttpBuilder].

pub fn fuse_factory<F>(self, factory: F) -> Self

where F: FuseFactory + Send + Sync + 'static,

Set the fuse factory.

pub fn handle(&self) -> ServerHandle

Get a ServerHandle to stop server.

pub fn stop_forcible(&self)

Force stop server.

Call this function will stop server immediately.

pub fn stop_graceful(&self, timeout: impl Into<Option<Duration>>)

Graceful stop server.

Call this function will stop server after all connections are closed. You can specify a timeout to force stop server. If timeout is None, it will wait util all connections are closed.

pub fn holdings(&self) -> &[Holding]

Get holding information of this server.

pub fn http1_mut(&mut self) -> &mut Builder

Available on crate feature http1 only.

Use this function to set http1 protocol.

pub fn http2_mut(&mut self) -> &mut Builder<TokioExecutor>

Available on crate feature http2 only.

Use this function to set http2 protocol.

pub fn quinn_mut(&mut self) -> &mut Builder

Available on crate feature quinn only.

Use this function to set http3 protocol.

pub async fn serve<S>(self, service: S)

where S: Into<Service> + Send,

Serve a Service.

Example

use salvo_core::prelude::*;
#[handler]
async fn hello() -> &'static str {
    "Hello World"
}

#[tokio::main]
async fn main() {
    let acceptor = TcpListener::new("0.0.0.0:5800").bind().await;
    let router = Router::new().get(hello);
    Server::new(acceptor).serve(router).await;
}

pub async fn try_serve<S>(self, service: S) -> IoResult<()>

where S: Into<Service> + Send,

Try to serve a Service.