Cache
Middleware que fornece funcionalidade de cache.
O middleware Cache pode armazenar em cache o StatusCode
, Headers
e Body
de uma Response
. Para conteúdo já armazenado em cache, quando a próxima solicitação for processada, o middleware Cache enviará diretamente o conteúdo armazenado na memória para o cliente.
Observação: este plugin não armazena em cache Response
cujo Body
seja ResBody::Stream
. Se aplicado a esse tipo de Response
, o Cache não processará essas solicitações e não causará erros.
Funcionalidades principais
-
CacheIssuer
fornece uma abstração para a atribuição de chaves de cache. RequestIssuer
é uma implementação que pode definir quais partes da URL da solicitação e o Method
serão usados para gerar a chave de cache. Você também pode definir sua própria lógica de geração de chaves. A chave de cache não precisa ser uma string - qualquer tipo que satisfaça as restrições Hash + Eq + Send + Sync + 'static
pode ser usado como chave.
-
CacheStore
fornece operações de armazenamento e recuperação de dados. MokaStore
é uma implementação de cache em memória integrada, baseada em moka
. Você também pode definir sua própria implementação.
-
Cache
é uma estrutura que implementa Handler
, contendo internamente um campo skipper
que pode especificar quais solicitações devem ser ignoradas pelo cache. Por padrão, o MethodSkipper
é usado para ignorar todas as solicitações, exceto Method::GET
.
Código de exemplo de implementação interna:
impl<S, I> Cache<S, I> {
pub fn new(store: S, issuer: I) -> Self {
let skipper = MethodSkipper::new().skip_all().skip_get(false);
Cache {
store,
issuer,
skipper: Box::new(skipper),
}
}
}
Migração rápida de outros frameworks
Se você já usou mecanismos de cache em outros frameworks, o mapeamento conceitual abaixo ajudará você a se adaptar mais rapidamente à implementação de cache do Salvo:
Guia de migração para frameworks Rust
Guia de migração para frameworks em outras linguagens
-
Migrando do Go/Gin: O Gin usa um padrão de middleware, assim como o Salvo:
// Exemplo de cache no Gin
store := persist.NewMemoryStore(time.Second * 60)
router.Use(cache.CachePage(store, time.Second * 30))
// Implementação equivalente no Salvo
let store = MokaStore::new(100).with_ttl(Duration::from_secs(30));
router.hoop(Cache::new(store, RequestIssuer::new()))
-
Migrando do Spring Boot: O cache declarativo do Spring Boot precisa ser convertido para uma configuração explícita de middleware no Salvo:
// Spring Boot
@Cacheable(value = "books", key = "#isbn")
public Book findBook(ISBN isbn) { ... }
// Implementação equivalente no Salvo - aplicando cache no nível da rota
let custom_issuer = YourCustomIssuer::new(); // implementando a interface CacheIssuer
Router::with_path("books").hoop(Cache::new(MokaStore::new(100), custom_issuer))
-
Migrando do Express.js: O middleware de cache do Express é conceitualmente similar ao do Salvo, mas com sintaxe diferente:
// Express.js
const apicache = require('apicache');
app.use(apicache.middleware('5 minutes'));
// Implementação equivalente no Salvo
let store = MokaStore::new(100).with_ttl(Duration::from_secs(300));
router.hoop(Cache::new(store, RequestIssuer::new()))
Ao migrar de outros frameworks, observe estes conceitos-chave do cache no Salvo:
- Geração de chaves de cache - controlada pela interface
CacheIssuer
- Armazenamento de cache - implementado pela interface
CacheStore
- Lógica de ignorar cache - personalizada através do mecanismo
skipper
Por padrão, o Salvo armazena apenas solicitações GET em cache, comportamento consistente com a maioria dos frameworks.
Código de exemplo
cache-simple/src/main.rs
use std::time::Duration;
use salvo::cache::{Cache, MokaStore, RequestIssuer};
use salvo::prelude::*;
use salvo::writing::Text;
use time::OffsetDateTime;
// Handler for serving the home page with HTML content
#[handler]
async fn home() -> Text<&'static str> {
Text::Html(HOME_HTML)
}
// Handler for short-lived cached response (5 seconds)
#[handler]
async fn short() -> String {
format!(
"Hello World, my birth time is {}",
OffsetDateTime::now_utc()
)
}
// Handler for long-lived cached response (1 minute)
#[handler]
async fn long() -> String {
format!(
"Hello World, my birth time is {}",
OffsetDateTime::now_utc()
)
}
#[tokio::main]
async fn main() {
// Initialize logging system
tracing_subscriber::fmt().init();
// Create cache middleware for short-lived responses (5 seconds TTL)
let short_cache = Cache::new(
MokaStore::builder()
.time_to_live(Duration::from_secs(5))
.build(),
RequestIssuer::default(),
);
// Create cache middleware for long-lived responses (60 seconds TTL)
let long_cache = Cache::new(
MokaStore::builder()
.time_to_live(Duration::from_secs(60))
.build(),
RequestIssuer::default(),
);
// Set up router with three endpoints:
// - / : Home page
// - /short : Response cached for 5 seconds
// - /long : Response cached for 1 minute
let router = Router::new()
.get(home)
.push(Router::with_path("short").hoop(short_cache).get(short))
.push(Router::with_path("long").hoop(long_cache).get(long));
// Bind server to port 5800 and start serving
let acceptor = TcpListener::new("0.0.0.0:5800").bind().await;
Server::new(acceptor).serve(router).await;
}
// HTML template for the home page with links to cached endpoints
static HOME_HTML: &str = r#"
<!DOCTYPE html>
<html>
<head>
<title>Cache Example</title>
</head>
<body>
<h2>Cache Example</h2>
<p>
This examples shows how to use cache middleware.
</p>
<p>
<a href="/short" target="_blank">Cache 5 seconds</a>
</p>
<p>
<a href="/long" target="_blank">Cache 1 minute</a>
</p>
</body>
</html>
"#;