2017-04-17 02:48:59 +00:00
|
|
|
# Overview
|
|
|
|
|
2018-10-22 21:47:35 +00:00
|
|
|
Rocket provides primitives to build web servers and applications with Rust:
|
|
|
|
Rocket provides routing, pre-processing of requests, and post-processing of
|
|
|
|
responses; the rest is up to you. Your application code instructs Rocket on what
|
|
|
|
to pre-process and post-process and fills the gaps between pre-processing and
|
|
|
|
post-processing.
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
## Lifecycle
|
|
|
|
|
|
|
|
Rocket's main task is to listen for incoming web requests, dispatch the request
|
|
|
|
to the application code, and return a response to the client. We call the
|
2017-07-03 05:51:24 +00:00
|
|
|
process that goes from request to response the "lifecycle". We summarize the
|
|
|
|
lifecycle as the following sequence of steps:
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
1. **Routing**
|
|
|
|
|
2017-07-03 05:51:24 +00:00
|
|
|
Rocket parses an incoming HTTP request into native structures that your
|
|
|
|
code operates on indirectly. Rocket determines which request handler to
|
|
|
|
invoke by matching against route attributes declared in your application.
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
2. **Validation**
|
|
|
|
|
2017-07-03 05:51:24 +00:00
|
|
|
Rocket validates the incoming request against types and guards present in
|
|
|
|
the matched route. If validation fails, Rocket _forwards_ the request to
|
|
|
|
the next matching route or calls an _error handler_.
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
3. **Processing**
|
|
|
|
|
2017-07-03 05:51:24 +00:00
|
|
|
The request handler associated with the route is invoked with validated
|
|
|
|
arguments. This is the main business logic of an application. Processing
|
|
|
|
completes by returning a `Response`.
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
4. **Response**
|
|
|
|
|
2017-07-03 05:51:24 +00:00
|
|
|
The returned `Response` is processed. Rocket generates the appropriate HTTP
|
|
|
|
response and sends it to the client. This completes the lifecycle. Rocket
|
|
|
|
continues listening for requests, restarting the lifecycle for each
|
|
|
|
incoming request.
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
The remainder of this section details the _routing_ phase as well as additional
|
|
|
|
components needed for Rocket to begin dispatching requests to request handlers.
|
2017-07-10 11:59:55 +00:00
|
|
|
The sections following describe the request and response phases as well as other
|
|
|
|
components of Rocket.
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
## Routing
|
|
|
|
|
2017-07-03 05:51:24 +00:00
|
|
|
Rocket applications are centered around routes and handlers. A _route_ is a
|
|
|
|
combination of:
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
* A set of parameters to match an incoming request against.
|
|
|
|
* A handler to process the request and return a response.
|
|
|
|
|
2017-07-03 05:51:24 +00:00
|
|
|
A _handler_ is simply a function that takes an arbitrary number of arguments and
|
|
|
|
returns any arbitrary type.
|
|
|
|
|
2017-04-17 02:48:59 +00:00
|
|
|
The parameters to match against include static paths, dynamic paths, path
|
|
|
|
segments, forms, query strings, request format specifiers, and body data. Rocket
|
|
|
|
uses attributes, which look like function decorators in other languages, to make
|
|
|
|
declaring routes easy. Routes are declared by annotating a function, the
|
|
|
|
handler, with the set of parameters to match against. A complete route
|
|
|
|
declaration looks like this:
|
|
|
|
|
|
|
|
```rust
|
2020-02-15 11:43:47 +00:00
|
|
|
# #[macro_use] extern crate rocket;
|
|
|
|
|
2017-04-17 02:48:59 +00:00
|
|
|
#[get("/world")] // <- route attribute
|
|
|
|
fn world() -> &'static str { // <- request handler
|
2020-02-15 11:43:47 +00:00
|
|
|
"hello, world!"
|
2017-04-17 02:48:59 +00:00
|
|
|
}
|
|
|
|
```
|
|
|
|
|
|
|
|
This declares the `world` route to match against the static path `"/world"` on
|
2020-06-12 03:41:10 +00:00
|
|
|
incoming `GET` requests. Instead of `#[get]`, we could have used `#[post]` or
|
|
|
|
`#[put]` for other HTTP methods, or `#[catch]` for serving [custom error
|
|
|
|
pages](../requests/#error-catchers). Additionally, other route parameters may be
|
|
|
|
necessary when building more interesting applications. The
|
|
|
|
[Requests](../requests) chapter, which follows this one, has further details on
|
|
|
|
routing and error handling.
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
## Mounting
|
|
|
|
|
2018-10-22 21:47:35 +00:00
|
|
|
Before Rocket can dispatch requests to a route, the route needs to be _mounted_:
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
```rust
|
2020-02-15 11:43:47 +00:00
|
|
|
# #[macro_use] extern crate rocket;
|
|
|
|
|
|
|
|
# #[get("/world")]
|
|
|
|
# fn world() -> &'static str {
|
|
|
|
# "hello, world!"
|
|
|
|
# }
|
|
|
|
|
2018-10-22 21:47:35 +00:00
|
|
|
fn main() {
|
|
|
|
rocket::ignite().mount("/hello", routes![world]);
|
|
|
|
}
|
2017-04-17 02:48:59 +00:00
|
|
|
```
|
|
|
|
|
2018-10-22 21:47:35 +00:00
|
|
|
The `mount` method takes as input:
|
|
|
|
|
2019-05-11 02:39:38 +00:00
|
|
|
1. A _base_ path to namespace a list of routes under, here, `"/hello"`.
|
|
|
|
2. A list of routes via the `routes!` macro: here, `routes![world]`, with
|
|
|
|
multiple routes: `routes![a, b, c]`.
|
2018-10-22 21:47:35 +00:00
|
|
|
|
2017-07-03 05:51:24 +00:00
|
|
|
This creates a new `Rocket` instance via the `ignite` function and mounts the
|
2018-10-22 21:47:35 +00:00
|
|
|
`world` route to the `"/hello"` path, making Rocket aware of the route. `GET`
|
|
|
|
requests to `"/hello/world"` will be directed to the `world` function.
|
|
|
|
|
|
|
|
! note: In many cases, the base path will simply be `"/"`.
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
### Namespacing
|
|
|
|
|
|
|
|
When a route is declared inside a module other than the root, you may find
|
|
|
|
yourself with unexpected errors when mounting:
|
|
|
|
|
2020-02-15 11:43:47 +00:00
|
|
|
```rust,compile_fail
|
|
|
|
# #[macro_use] extern crate rocket;
|
|
|
|
|
2017-04-17 02:48:59 +00:00
|
|
|
mod other {
|
|
|
|
#[get("/world")]
|
|
|
|
pub fn world() -> &'static str {
|
|
|
|
"Hello, world!"
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2019-05-11 02:39:38 +00:00
|
|
|
#[get("/hello")]
|
|
|
|
pub fn hello() -> &'static str {
|
|
|
|
"Hello, outside world!"
|
|
|
|
}
|
|
|
|
|
2017-04-17 02:48:59 +00:00
|
|
|
use other::world;
|
|
|
|
|
|
|
|
fn main() {
|
2020-02-15 11:43:47 +00:00
|
|
|
// error[E0425]: cannot find value `static_rocket_route_info_for_world` in this scope
|
|
|
|
rocket::ignite().mount("/hello", routes![hello, world]);
|
2017-04-17 02:48:59 +00:00
|
|
|
}
|
|
|
|
```
|
|
|
|
|
|
|
|
This occurs because the `routes!` macro implicitly converts the route's name
|
|
|
|
into the name of a structure generated by Rocket's code generation. The solution
|
2018-10-22 21:47:35 +00:00
|
|
|
is to refer to the route using a namespaced path instead:
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
```rust
|
2020-02-15 11:43:47 +00:00
|
|
|
# #[macro_use] extern crate rocket;
|
|
|
|
|
|
|
|
# #[get("/")] pub fn hello() {}
|
|
|
|
# mod other { #[get("/world")] pub fn world() {} }
|
|
|
|
|
2019-05-11 02:39:38 +00:00
|
|
|
rocket::ignite().mount("/hello", routes![hello, other::world]);
|
2017-04-17 02:48:59 +00:00
|
|
|
```
|
|
|
|
|
|
|
|
## Launching
|
|
|
|
|
|
|
|
Now that Rocket knows about the route, you can tell Rocket to start accepting
|
|
|
|
requests via the `launch` method. The method starts up the server and waits for
|
|
|
|
incoming requests. When a request arrives, Rocket finds the matching route and
|
|
|
|
dispatches the request to the route's handler.
|
|
|
|
|
2020-07-11 16:42:05 +00:00
|
|
|
We typically use `#[rocket::launch]`, which generates a `main` function.
|
|
|
|
Our complete _Hello, world!_ application thus looks like:
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
```rust
|
2018-10-05 04:44:42 +00:00
|
|
|
#[macro_use] extern crate rocket;
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
#[get("/world")]
|
|
|
|
fn world() -> &'static str {
|
|
|
|
"Hello, world!"
|
|
|
|
}
|
|
|
|
|
2020-07-11 16:42:05 +00:00
|
|
|
#[rocket::launch]
|
|
|
|
fn rocket() -> rocket::Rocket {
|
|
|
|
rocket::ignite().mount("/hello", routes![world])
|
2017-04-17 02:48:59 +00:00
|
|
|
}
|
|
|
|
```
|
|
|
|
|
2020-07-11 17:31:42 +00:00
|
|
|
We've imported the `rocket` crate and all of its macros into our namespace via
|
|
|
|
`#[macro_use] extern crate rocket`. Finally, we call the `launch` method in the
|
|
|
|
`main` function.
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
Running the application, the console shows:
|
|
|
|
|
|
|
|
```sh
|
|
|
|
🔧 Configured for development.
|
|
|
|
=> address: localhost
|
|
|
|
=> port: 8000
|
|
|
|
=> log: normal
|
2018-10-23 08:22:46 +00:00
|
|
|
=> workers: [logical cores * 2]
|
2017-07-03 05:51:24 +00:00
|
|
|
=> secret key: generated
|
|
|
|
=> limits: forms = 32KiB
|
2018-10-22 21:47:35 +00:00
|
|
|
=> keep-alive: 5s
|
2017-07-03 05:51:24 +00:00
|
|
|
=> tls: disabled
|
2018-11-04 10:25:51 +00:00
|
|
|
🛰 Mounting '/hello':
|
|
|
|
=> GET /hello/world (world)
|
2017-07-03 05:51:24 +00:00
|
|
|
🚀 Rocket has launched from http://localhost:8000
|
2017-04-17 02:48:59 +00:00
|
|
|
```
|
|
|
|
|
2018-10-22 21:47:35 +00:00
|
|
|
If we visit `localhost:8000/hello/world`, we see `Hello, world!`, exactly as we
|
|
|
|
expected.
|
2017-04-17 02:48:59 +00:00
|
|
|
|
|
|
|
A version of this example's complete crate, ready to `cargo run`, can be found
|
2018-10-22 21:47:35 +00:00
|
|
|
on [GitHub](@example/hello_world). You can find dozens of other complete
|
|
|
|
examples, spanning all of Rocket's features, in the [GitHub examples
|
2018-10-16 05:50:35 +00:00
|
|
|
directory](@example/).
|
2020-01-16 00:12:44 +00:00
|
|
|
|
|
|
|
## Futures and Async
|
|
|
|
|
|
|
|
Rocket uses Rust `Future`s for concurrency. Asynchronous programming with
|
|
|
|
`Future`s and `async/await` allows route handlers to perform wait-heavy I/O such
|
|
|
|
as filesystem and network access while still allowing other requests to be
|
|
|
|
processed. For an overview of Rust `Future`s, see [Asynchronous Programming in
|
|
|
|
Rust](https://rust-lang.github.io/async-book/).
|
|
|
|
|
|
|
|
In general, you should prefer to use async-ready libraries instead of
|
|
|
|
synchronous equivalents inside Rocket applications.
|
|
|
|
|
|
|
|
`async` appears in several places in Rocket:
|
|
|
|
|
|
|
|
* [Routes](../requests) and [Error Catchers](../requests#error-catchers) can be
|
|
|
|
`async fn`s. Inside an `async fn`, you can `.await` `Future`s from Rocket or
|
|
|
|
other libraries
|
|
|
|
* Several of Rocket's traits, such as [`FromData`](../requests#body-data) and
|
2020-01-31 09:34:15 +00:00
|
|
|
[`FromRequest`](../requests#request-guards), have methods that return
|
2020-01-16 00:12:44 +00:00
|
|
|
`Future`s.
|
|
|
|
* `Data` and `DataStream` (incoming request data) and `Response` and `Body`
|
|
|
|
(outgoing response data) are based on `tokio::io::AsyncRead` instead of
|
|
|
|
`std::io::Read`.
|
|
|
|
|
|
|
|
You can find async-ready libraries on [crates.io](https://crates.io) with the
|
|
|
|
`async` tag.
|
|
|
|
|
|
|
|
! note
|
|
|
|
|
2020-06-16 12:01:26 +00:00
|
|
|
Rocket 0.5 uses the tokio (0.2) runtime. The runtime is started for you if you
|
|
|
|
use `#[rocket::launch]` or `#[rocket::main]`, but you can still `launch()` a
|
|
|
|
rocket instance on a custom-built `Runtime`.
|
2020-01-16 00:12:44 +00:00
|
|
|
|
|
|
|
### Cooperative Multitasking
|
|
|
|
|
|
|
|
Rust's `Future`s are a form of *cooperative multitasking*. In general, `Future`s
|
|
|
|
and `async fn`s should only `.await` on other operations and never block. Some
|
|
|
|
common examples of blocking include locking mutexes, joining threads, or using
|
|
|
|
non-`async` library functions (including those in `std`) that perform I/O.
|
|
|
|
|
|
|
|
If a `Future` or `async fn` blocks the thread, inefficient resource usage,
|
|
|
|
stalls, or sometimes even deadlocks can occur.
|
|
|
|
|
|
|
|
! note
|
|
|
|
|
|
|
|
Sometimes there is no good async alternative for a library or operation. If
|
|
|
|
necessary, you can convert a synchronous operation to an async one with
|
|
|
|
`tokio::task::spawn_blocking`:
|
|
|
|
|
|
|
|
```rust
|
2020-07-11 16:41:53 +00:00
|
|
|
# #[macro_use] extern crate rocket;
|
2020-07-21 18:53:45 +00:00
|
|
|
use std::io;
|
2020-07-11 16:41:53 +00:00
|
|
|
use rocket::tokio::task::spawn_blocking;
|
2020-07-21 18:53:45 +00:00
|
|
|
use rocket::response::Debug;
|
2020-07-11 16:41:53 +00:00
|
|
|
|
2020-01-16 00:12:44 +00:00
|
|
|
#[get("/blocking_task")]
|
2020-07-21 18:53:45 +00:00
|
|
|
async fn blocking_task() -> Result<Vec<u8>, Debug<io::Error>> {
|
|
|
|
// In a real app, we'd use rocket::response::NamedFile or tokio::fs::File.
|
|
|
|
let io_result = spawn_blocking(|| std::fs::read("data.txt")).await
|
|
|
|
.map_err(|join_err| io::Error::new(io::ErrorKind::Interrupted, join_err))?;
|
|
|
|
|
|
|
|
Ok(io_result?)
|
2020-01-16 00:12:44 +00:00
|
|
|
}
|
|
|
|
```
|