Struct Server

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

HTTP Server.

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

Implementations

impl<A> Server<A>

where A: Acceptor + Send,

pub fn new(acceptor: A) -> Server<A>

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) -> Server<A>

Create new Server with Acceptor and [HttpBuilder].

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

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

Use this function to set http1 protocol.

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

Use this function to set http2 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 fn try_serve<S>( self, service: S, ) -> impl Future<Output = Result<(), Error>> + Send

where S: Into<Service> + Send,

Try to serve a Service.