如何 return 来自 Rocket 端点的状态值？

Question

我正在将来自外部服务的数据存储在本地缓存中，我想为缓存中当前的 return 数据创建一个端点。

#![feature(proc_macro_hygiene, decl_macro)]

#[macro_use]
extern crate rocket;

use rocket::{Route, State};
use rocket_contrib::json::Json;
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize)]
pub struct Post {
    pub title: String,
    pub body: String,
}

impl Post {
    pub fn new(title: String, body: String) -> Post {
        Post { title, body }
    }
}

pub struct Cache {
    pub posts: Vec<Post>,
}

impl Cache {
    pub fn new() -> Cache {
        let mut posts = vec![
            Post::new(String::from("Article1"), String::from("Blah")),
            Post::new(String::from("Article2"), String::from("Blah")),
            Post::new(String::from("Article3"), String::from("Blah")),
            Post::new(String::from("Article4"), String::from("Blah")),
            Post::new(String::from("Article5"), String::from("Blah")),
        ];

        Cache { posts }
    }
}

#[derive(Responder)]
pub enum IndexResponder {
    #[response(status = 200)]
    Found(Json<Vec<Post>>),
    #[response(status = 404)]
    NotFound(String),
}

#[get("/")]
pub fn index(cache: State<Cache>) -> IndexResponder {
    return IndexResponder::Found(Json(cache.posts));
}

fn main() {
    rocket::ignite()
        .mount("/", routes![index])
        .manage(Cache::new())
        .launch();
}

编译器抱怨：

error[E0507]: cannot move out of dereference of `rocket::State<'_, Cache>`
  --> src/main.rs:50:39
   |
50 |     return IndexResponder::Found(Json(cache.posts));
   |                                       ^^^^^^^^^^^ move occurs because value has type `std::vec::Vec<Post>`, which does not implement the `Copy` trait

(cargo build --verbose output)

我的 Cargo.toml 文件：

[package]
name = "debug-project"
version = "0.1.0"
authors = ["Varkal <mail@example.com>"]
edition = "2018"

[dependencies]
rocket = "0.4.0"
rocket_contrib = "0.4.0"
serde = { version = "1.0.90", features = ["derive"] }
serde_json = "1.0.39"

A very simple repository to reproduce the error.

Answer 1

您的端点不拥有该状态，因此它不能 return 拥有 Vec<Post>。从概念上讲，这是有道理的，因为如果您取得了它的所有权，那么下次调用端点时会出现什么值？

您可以做的最简单的事情就是克隆数据：

#[get("/")]
pub fn index(cache: State<Cache>) -> IndexResponder {
    IndexResponder::Found(Json(cache.posts.clone()))
}

这将要求您为 Post 实施 Clone，或者可能更改您的状态以保持 Arc.

之类的东西

一个稍微更高效的解决方案是 return 一个引用状态的切片。这不需要克隆，但需要使用 State::inner 方法：

#[derive(Responder)]
pub enum IndexResponder<'a> {
    #[response(status = 200)]
    Found(Json<&'a [Post]>),
    #[response(status = 404)]
    NotFound(String),
}

#[get("/")]
pub fn index<'a>(cache: State<'a, Cache>) -> IndexResponder<'a> {
    IndexResponder::Found(Json(&cache.inner().posts))
}

另请参阅：

如何 return 来自 Rocket 端点的状态值？

How to return a State value from a Rocket endpoint?

rust

rust-rocket