Özet - gRPC

Sunucu ve istemciyi birleştirerek bir gRPC servis yazarsın.

gRPC özeti

Akış: sözleşmeyi .proto'da yaz → protoc ile Go kodu üret → sunucuda arayüzü uygula, Register et, Serve et → istemcide NewClient + üretilmiş istemciyle zaman aşımlı çağrı yap. Hatalar status ve codes ile taşınır.

Alan numaralarını asla değiştirme; silinenleri reserved yap.

Interceptor

gRPC'de middleware'in karşılığı interceptor'dır. Sunucuya grpc.UnaryInterceptor(...) seçeneğiyle eklenir ve her tekli çağrıdan önce/sonra çalışır:

func logla(ctx context.Context, req any, info *grpc.UnaryServerInfo, h grpc.UnaryHandler) (any, error) {
    bas := time.Now()
    resp, err := h(ctx, req)
    log.Println(info.FullMethod, time.Since(bas))
    return resp, err
}

Uygulama Interceptor benzetimi

type Handler func(string) string tanımla. intercept(h Handler) Handler yaz: çağrıdan önce ">", sonra "<" yazdırsın ve sonucu döndürsün. intercept(func(s string) string { return s + "!" })("go") sonucunu yazdır.

Örnek çözümü göster

package main

import "fmt"

type Handler func(string) string

func intercept(h Handler) Handler {
    return func(s string) string {
        fmt.Println(">")
        r := h(s)
        fmt.Println("<")
        return r
    }
}

func main() {
    fmt.Println(intercept(func(s string) string { return s + "!" })("go"))
}

Kendini test et

İstemci "kaynak bulunamadı" durumunu nasıl anlar?
- Yanıt boş olunca
- status.Code(err) == codes.NotFound
- err == nil
- HTTP 404 başlığından
Cevabı göster

status.Code(err) == codes.NotFound — gRPC hata kodları status paketinden okunur; NotFound sunucunun status.Error(codes.NotFound, ...) ile döndürdüğü koddur.

Hata kodu

return nil, status.Error(codes.____, "ürün yok")

Cevabı göster

return nil, status.Error(codes.NotFound, "ürün yok")

Grubun özeti

.proto

Sözleşme
protoc

Kod üretimi
Interceptor

gRPC middleware'i
codes.DeadlineExceeded

Süre doldu

Sıradaki ders: Servis iskeleti

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler