Een gRPC-server implementeren
Bied unarie RPC-methoden aan.
Een gRPC-server implementeren is een gratis Leer programmeren met Rust-les op CoddyKit. Dit is les 3 van 4. Je kunt 3 lessen uit dit leerpad gratis volledig lezen — daarna ontgrendelt CoddyKit PRO alle lessen, plus praktische oefeningen met een ingebouwde code-editor en een AI-tutor die 24/7 beschikbaar is. Deze les maakt deel uit van het leertraject Leer programmeren met Rust. Je voortgang wordt gesynchroniseerd op het web en in de CoddyKit-app. De cursus Leer programmeren met Rust bevat in totaal 4 lessen.
De gegenereerde servertrait
Voor een service met de naam Greeter genereert tonic een trait in greeter_server. Je implementeert die op je eigen struct om het gedrag te leveren.
De trait is async via #[tonic::async_trait], dus elke methode is een async fn die een Result retourneert.
use greeter::v1::greeter_server::{Greeter, GreeterServer};
use greeter::v1::{HelloRequest, HelloReply};Wrappers voor verzoeken en antwoorden
Methoden nemen een tonic::Request<T> aan en retourneren een tonic::Response<T>. Deze wrappers bevatten metadata, extensies en het binnenste bericht.
Roep .into_inner() aan om het gedecodeerde bericht op te halen en gebruik Response::new(..) om een antwoord op te bouwen.
let req: HelloRequest = request.into_inner();
let reply = HelloReply { message: format!("Hi {}", req.name) };
Ok(Response::new(reply))Een serverstruct
Definieer een struct voor gedeelde toestand, zoals een databasepool. Vaak leidt die Default af wanneer de server geen toestand heeft.
Je implementeert de gegenereerde trait op deze struct.
#[derive(Default)]
pub struct MyGreeter {}Een unaire methode implementeren
Voorzie het impl-blok van #[tonic::async_trait] en implementeer elke rpc als een async fn die overeenkomt met de gegenereerde signatuur.
Retourneer bij succes 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}") }))
}
}Fouten retourneren met Status
Fouten worden geretourneerd als tonic::Status, dat wordt vertaald naar een gRPC-statuscode. Gebruik constructors zoals Status::invalid_argument of Status::not_found.
De berichttekst wordt samen met de code naar de client gestuurd.
if name.is_empty() {
return Err(Status::invalid_argument("name must not be empty"));
}Bouwen en aanbieden
Gebruik tonic::transport::Server in een asynchrone main. Voeg je service toe, verpakt in het gegenereerde type ...Server, en roep daarna serve aan met een socketadres.
De macro #[tokio::main] levert de 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(())
}Streamingantwoorden vanaf de server
Een server-streamingmethode retourneert een streamtype. tonic gebruikt een geassocieerd type plus een boxed stream; een mpsc-kanaal is een gebruikelijke manier om berichten aan te leveren.
Je retourneert een ReceiverStream, verpakt in een 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)))Metadata lezen
Verzoekmetadata bevat headers zoals authenticatietokens. Je krijgt deze met request.metadata() voordat je de inhoud van het verzoek verbruikt.
Sleutels zijn ASCII en niet hoofdlettergevoelig; waarden worden geretourneerd als MetadataValue.
if let Some(token) = request.metadata().get("authorization") {
// validate token
} else {
return Err(Status::unauthenticated("missing token"));
}Interceptors
Een interceptor wordt vóór elk verzoek uitgevoerd en is ideaal voor authenticatie of logboekregistratie. Hij ontvangt de Request en retourneert die opnieuw of een Status-fout.
Koppel hem met with_interceptor wanneer je de service toevoegt.
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))Gecontroleerd afsluiten
Gebruik serve_with_shutdown om geen nieuwe verbindingen meer te accepteren zodra een future is voltooid, bijvoorbeeld na een Ctrl-C-signaal.
Lopende verzoeken worden afgehandeld voordat de server afsluit, zodat ze niet abrupt worden afgebroken.
Server::builder()
.add_service(GreeterServer::new(MyGreeter::default()))
.serve_with_shutdown(addr, async {
tokio::signal::ctrl_c().await.ok();
})
.await?;Gedeelde toestand
Als je veranderlijke toestand tussen verzoeken wilt delen, bewaar je die achter Arc en een synchronisatiemechanisme zoals tokio::sync::Mutex in je serverstruct.
tonic kloont de service per verbinding, dus gedeelde handles die goedkoop te klonen zijn vormen het juiste patroon.
use std::sync::Arc;
use tokio::sync::Mutex;
#[derive(Default)]
pub struct MyGreeter {
hits: Arc<Mutex<u64>>,
}Snelle controle
Hoe melden gRPC-methoden fouten in tonic?
Samenvatting
Je hebt de gegenereerde servertrait geïmplementeerd: verzoeken uitgepakt, antwoorden en Status-fouten geretourneerd, met tokio een server aangeboden, antwoorden gestreamd, metadata gelezen, interceptors toegevoegd, gecontroleerd afgesloten en toestand gedeeld via Arc.
Vervolgens bouw je een client om deze server aan te roepen.
Leer Rust met een AI-tutor — gratis
Schrijf echte code en voer die uit in je browser, krijg direct hulp van een AI-tutor die 24/7 beschikbaar is en ga verder waar je gebleven bent op het web of in de app.
- Cursussen
- 39
- Lessen
- 144
Veelgestelde vragen
Is de les “Een gRPC-server implementeren” gratis?
Ja — je kunt hier op het web alle 3 lessen van het leerpad Leer programmeren met Rust, waaronder “Een gRPC-server implementeren”, gratis volledig lezen. Daarna ontgrendelt CoddyKit PRO alle lessen, plus interactieve oefeningen met een ingebouwde code-editor en een AI-tutor die 24/7 beschikbaar is. De cursus Leer programmeren met Rust bevat in totaal 4 lessen.
Wat leer ik in “Een gRPC-server implementeren”?
Bied unarie RPC-methoden aan. Je oefent met Leer programmeren met Rust door code rechtstreeks in de browser uit te voeren. Een AI-begeleider die 24/7 beschikbaar is beantwoordt je vragen terwijl je de les doorwerkt.
Heb ik ervaring nodig om met Leer programmeren met Rust te beginnen?
Ervaring vooraf is niet nodig. Leer programmeren met Rust op CoddyKit is opgebouwd voor beginners tot gevorderden, zodat je hier of bij het begin kunt starten en in je eigen tempo kunt leren. Dit is les 3 van 4.
Hoe lang duurt de les “Een gRPC-server implementeren”?
De meeste lessen van CoddyKit duren ongeveer 5–10 minuten. Elke les is kort en interactief, zodat je gestaag vooruitgaat en op het web en in de app precies verdergaat waar je was gebleven.
Kan ik code schrijven en uitvoeren in deze les over Leer programmeren met Rust?
Ja. Elke les over Leer programmeren met Rust bevat een ingebouwde code-editor, zodat je rechtstreeks in je browser echte code kunt schrijven en uitvoeren en direct feedback van AI krijgt — lokale installatie is niet nodig.
Alle lessen in deze cursus
- Protobuf- en servicedefinities
- Code genereren met tonic-build
- Een gRPC-server implementeren
- Bellen vanuit een gRPC-client