بناء خدمات مصغرة عالية الأداء في Go باستخدام gRPC

في المشهد الحديث لأنظمة الموزعة، يعد الأداء والكفاءة أمرين لا غنى عنهما. مع نمو التطبيقات، يمكن أن يصبح عبء الاتصال بين الخدمات عنق زجاجة كبير. هنا تبرز قوة gRPC. من خلال الاستفادة من بروتوكول Buffers (Protobuf) كلغة تعريف الواجهة (IDL) وHTTP/2 للنقل، يقدم gRPC بديلاً قوياً وفعالاً ومقيداً بأنواع صارمة لواجهات برمجة التطبيقات التقليدية القائمة على REST، مما يجعله خياراً مثالياً للخدمات المصغرة في Go.

لماذا تختار gRPC لـ Go؟

تشتهر Go بنموذج التزامن ومكتبتها القياسية، مما يجعلها منافساً قوياً للبنية التحتية للخلفية. عند دمجها مع gRPC، يحصل المطورون على:

• تحديد أنواع قوي: يتم تعريفها في ملفات .proto، مما يضمن استقرار العقد.
• كفاءة ثنائية: تعد عملية تسلسل Protobuf أصغر حجماً وأسرع بكثير من JSON.
• البث الأصلي: دعم مدمج للبث من العميل، ومن الخادم، والبث ثنائي الاتجاه.
• الأداء: يقلل تعدد الإرسال عبر HTTP/2 من عبء الاتصال.

تعريف عقد الخدمة

تمثل ملف .proto أساس أي خدمة gRPC. يحدد هذا الملف هياكل البيانات وطرق RPC. دعنا نعرف خدمة بسيطة لخدمة المستخدم.

1. تعريف Protobuf

أنشئ ملفاً باسم user.proto. سنحدد هيكل رسالة للمستخدم وواجهة الخدمة.

syntax = "proto3";

package user;

option go_package = "github.com/example/service/user";

message User {
  int32 id = 1;
  string name = 2;
  string email = 3;
}

service UserService {
  rpc GetUser (GetUserRequest) returns (User) {}
  rpc ListUsers (ListUsersRequest) returns (stream User) {}
}

message GetUserRequest {
  int32 id = 1;
}

message ListUsersRequest {
  string filter = 1;
}

لاحظ استخدام stream User في طريقة ListUsers. يشير هذا إلى البث من جانب الخادم، حيث يرسل الخادم تسلسلاً من الردود لطلب عميل واحد.

توليد الكود

بمجرد أن يكون ملف .proto جاهزاً، تحتاج إلى توليد كود Go الذي يطبق الواجهات. تأكد من تثبيت مترجم protoc وإضافات Go.

go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@latest

protoc --go_out=. --go-grpc_out=. user.proto

يولد هذا الأمر ملفين: user.pb.go (الذي يحتوي على هياكل الرسائل) و user_grpc.pb.go (الذي يحتوي على أكواد العميل والخادم الوهمية).

تنفيذ الخادم

الآن، دعنا نطبق واجهة UserService في Go. سنقوم بإنشاء خادم يفي بالواجهة المولدة.

package main

import (
    "context"
    "log"
    "net"

    pb "github.com/example/service/user"
    "google.golang.org/grpc"
)

// server implements the UserService
type server struct {
    pb.UnimplementedUserServiceServer
}

func (s *server) GetUser(ctx context.Context, in *pb.GetUserRequest) (*pb.User, error) {
    // Mock data retrieval
    return &pb.User{
        Id:    in.Id,
        Name:  "John Doe",
        Email: "john@example.com",
    }, nil
}

func (s *server) ListUsers(req *pb.ListUsersRequest, stream pb.UserService_ListUsersServer) error {
    // Mock list of users
    users := []*pb.User{
        {Id: 1, Name: "Alice", Email: "alice@example.com"},
        {Id: 2, Name: "Bob", Email: "bob@example.com"},
    }
    
    for _, user := range users {
        if err := stream.Send(user); err != nil {
            return err
        }
    }
    return nil
}

func main() {
    lis, err := net.Listen("tcp", ":50051")
    if err != nil {
        log.Fatalf("failed to listen: %v", err)
    }

    s := grpc.NewServer()
    pb.RegisterUserServiceServer(s, &server{})

    log.Println("Server listening on :50051")
    if err := s.Serve(lis); err != nil {
        log.Fatalf("failed to serve: %v", err)
    }
}

بناء العميل

مع تشغيل الخادم، يمكن للعميل الاتصال واستدعاء عمليات RPC. إليك كيفية استدعاء طريقتي GetUser و ListUsers.

package main

import (
    "context"
    "log"

    pb "github.com/example/service/user"
    "google.golang.org/grpc"
    "google.golang.org/grpc/credentials/insecure"
)

func main() {
    // Set up a connection to the server
    conn, err := grpc.Dial(":50051", grpc.WithTransportCredentials(insecure.NewCredentials()))
    if err != nil {
        log.Fatalf("did not connect: %v", err)
    }
    defer conn.Close()

    c := pb.NewUserServiceClient(conn)

    // Call unary RPC
    ctx, cancel := context.WithTimeout(context.Background(), 1000000)
    defer cancel()
    
    r, err := c.GetUser(ctx, &pb.GetUserRequest{Id: 1})
    if err != nil {
        log.Fatalf("could not get user: %v", err)
    }
    log.Printf("User: %+v", r)

    // Call server-streaming RPC
    stream, err := c.ListUsers(ctx, &pb.ListUsersRequest{Filter: "all"})
    if err != nil {
        log.Fatalf("could not list users: %v", err)
    }
    
    for {
        msg, err := stream.Recv()
        if err == nil {
            log.Printf("User: %+v", msg)
        } else {
            break
        }
    }
}

الخاتمة

يوفر دمج gRPC في بنية الخدمات المصغرة الخاصة بك في Go أداة قوية لبناء أنظمة قابلة للتوسع وعالية الأداء. بينما يظل REST معياراً متعدد الاستخدامات لواجهات برمجة التطبيقات الموجهة للجمهور، فإن كفاءة gRPC وأمانها النوعي يجعلها متفوقة في الاتصال بين الخدمات الداخلية. من خلال إتقان تعريفات Protobuf والاستفادة من مبادئ التزامن في Go، يمكن للمطورين بناء أنظمة موزعة قوية تقاوم اختبار القياس.