0Pricing
Learn Rust Coding · Lezione

Implementare un server gRPC

Esponga metodi RPC unari.

Implementare un server gRPC è una lezione Learn Rust Coding gratuita su CoddyKit. Questa è la lezione 3 di 4. Puoi leggere la lezione completa qui gratuitamente — poi esercitati direttamente nel browser con un editor di codice integrato e un tutor IA disponibile 24/7. Fa parte del percorso di apprendimento Learn Rust Coding, e i tuoi progressi si sincronizzano tra il web e l'app CoddyKit. Il corso Learn Rust Coding include 4 lezioni in totale.

Il trait del server generato

Per un servizio denominato Greeter, tonic genera un trait nel modulo greeter_server. Lo implementi su una propria struct per definirne il comportamento.

Il trait è async tramite #[tonic::async_trait], quindi ogni metodo è una funzione async che restituisce un Result.

use greeter::v1::greeter_server::{Greeter, GreeterServer};
use greeter::v1::{HelloRequest, HelloReply};

Wrapper di richiesta e risposta

I metodi ricevono un tonic::Request<T> e restituiscono un tonic::Response<T>. Questi wrapper contengono metadati, estensioni e il messaggio interno.

Chiami .into_inner() per ottenere il messaggio decodificato e Response::new(..) per creare una risposta.

let req: HelloRequest = request.into_inner();
let reply = HelloReply { message: format!("Hi {}", req.name) };
Ok(Response::new(reply))

Una struct del server

Definisca una struct che contenga lo stato condiviso, ad esempio un pool di connessioni al database. Spesso, quando non contiene stato, deriva Default.

Implementerà il trait generato su questa struct.

#[derive(Default)]
pub struct MyGreeter {}

Implementazione di un metodo unary

Annoti il blocco impl con #[tonic::async_trait] e implementi ogni rpc come funzione async, rispettando la firma generata.

In caso di successo, restituisca Ok(Response::new(reply)).

#[tonic::async_trait]
impl Greeter for MyGreeter {
    async fn say_hello(&self, request: Request<HelloRequest>)
        -> Result<Response<HelloReply>, Status> {
        let name = request.into_inner().name;
        Ok(Response::new(HelloReply { message: format!("Hello {name}") }))
    }
}

Restituzione degli errori con Status

Gli errori vengono restituiti come tonic::Status, che corrisponde a un codice di stato gRPC. Utilizzi costruttori come Status::invalid_argument o Status::not_found.

La stringa del messaggio viene inviata al client insieme al codice.

if name.is_empty() {
    return Err(Status::invalid_argument("name must not be empty"));
}

Compilazione e avvio del server

Utilizzi tonic::transport::Server in un main async. Aggiunga il servizio, racchiuso nel tipo ...Server generato, quindi chiami serve con un indirizzo socket.

La macro #[tokio::main] fornisce il runtime.

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let addr = "[::1]:50051".parse()?;
    Server::builder()
        .add_service(GreeterServer::new(MyGreeter::default()))
        .serve(addr)
        .await?;
    Ok(())
}

Risposte in streaming dal server

Un metodo con streaming dal server restituisce un tipo stream. tonic utilizza un tipo associato insieme a uno stream boxed; un canale mpsc è un modo comune per fornire i messaggi.

Restituisca un ReceiverStream racchiuso in una Response.

use tokio_stream::wrappers::ReceiverStream;
let (tx, rx) = tokio::sync::mpsc::channel(8);
tokio::spawn(async move { tx.send(Ok(reply)).await.ok(); });
Ok(Response::new(ReceiverStream::new(rx)))

Lettura dei metadati

I metadati della richiesta contengono intestazioni come i token di autenticazione. Vi acceda con request.metadata() prima di consumare il corpo.

Le chiavi sono ASCII e non distinguono tra maiuscole e minuscole; i valori vengono restituiti come MetadataValue.

if let Some(token) = request.metadata().get("authorization") {
    // validate token
} else {
    return Err(Status::unauthenticated("missing token"));
}

Interceptor

Un interceptor viene eseguito prima di ogni richiesta, ed è ideale per l'autenticazione o la registrazione. Riceve la Request e restituisce la richiesta oppure un errore Status.

Lo associ con with_interceptor quando aggiunge il servizio.

fn auth(req: Request<()>) -> Result<Request<()>, Status> {
    match req.metadata().get("authorization") {
        Some(_) => Ok(req),
        None => Err(Status::unauthenticated("no token")),
    }
}
// .add_service(GreeterServer::with_interceptor(svc, auth))

Arresto graduale

Utilizzi serve_with_shutdown per interrompere l'accettazione di connessioni quando un future si risolve, ad esempio in seguito a un segnale Ctrl-C.

Le richieste in corso terminano prima dell'uscita del server, evitando interruzioni improvvise.

Server::builder()
    .add_service(GreeterServer::new(MyGreeter::default()))
    .serve_with_shutdown(addr, async {
        tokio::signal::ctrl_c().await.ok();
    })
    .await?;

Stato condiviso

Per condividere uno stato mutabile tra le richieste, lo conservi dietro un Arc e un primitivo di sincronizzazione come tokio::sync::Mutex, all'interno della struct del server.

tonic clona il servizio per ogni connessione, quindi il modello corretto consiste nell'usare handle condivisi economici da clonare.

use std::sync::Arc;
use tokio::sync::Mutex;

#[derive(Default)]
pub struct MyGreeter {
    hits: Arc<Mutex<u64>>,
}

Verifica rapida

Come segnalano i metodi gRPC gli errori in tonic?

Riepilogo

Ha implementato il trait del server generato: ha estratto le richieste, restituito risposte ed errori Status, avviato il server con tokio, gestito le risposte in streaming, letto i metadati, aggiunto interceptor, configurato l'arresto graduale e condiviso lo stato tramite Arc.

Ora creerà un client per chiamare questo server.

Domande Frequenti

La lezione «Implementare un server gRPC» è gratuita?

Sì — il testo completo di «Implementare un server gRPC» è gratuito qui sul web. Per esercitarvi in modo interattivo (un editor di codice integrato e un tutor IA 24/7) e sbloccare il resto del corso Learn Rust Coding, passa a CoddyKit PRO. Il corso Learn Rust Coding include 4 lezioni in totale.

Cosa imparerò in «Implementare un server gRPC»?

Esponga metodi RPC unari. Eserciti Learn Rust Coding con codice pratico che esegui direttamente nel browser, e un tutor IA 24/7 risponde alle tue domande mentre lavori sulla lezione.

Ho bisogno di esperienza per iniziare Learn Rust Coding?

Non è richiesta alcuna esperienza precedente. Learn Rust Coding su CoddyKit è strutturato per principianti e studenti avanzati, quindi puoi iniziare da qui o dall'inizio e procedere al tuo ritmo. Questa è la lezione 3 di 4.

Quanto tempo richiede la lezione «Implementare un server gRPC»?

La maggior parte delle lezioni CoddyKit richiede circa 5–10 minuti. Ogni lezione è breve e interattiva, quindi fai progressi costanti e riprendi esattamente da dove hai lasciato su web e app.

Posso scrivere ed eseguire codice in questa lezione Learn Rust Coding?

Sì. Ogni lezione Learn Rust Coding include un editor di codice integrato, quindi scrivi ed esegui codice reale direttamente nel tuo browser e ricevi feedback istantaneo dall'IA — nessuna configurazione locale necessaria.

Tutte le lezioni di questo corso

  1. Protobuf e definizioni dei servizi
  2. Generare codice con tonic-build
  3. Implementare un server gRPC
  4. Effettuare chiamate da un client gRPC
← Torna a Learn Rust Coding