Go 언어로 gRPC 서비스를 생성하고 클라이언트에서 해당 서비스를 호출하는 예를 통해 설명하겠습니다.

1단계: Protocol Buffers 정의

먼저, 서비스 인터페이스와 메시지 타입을 정의하기 위해 Protocol Buffers (protobuf) 파일을 작성합니다.

helloworld.proto:

syntax = "proto3";

package helloworld;

// The greeting service definition.
service Greeter {
  // Sends a greeting
  rpc SayHello (HelloRequest) returns (HelloReply) {}
}

// The request message containing the user's name.
message HelloRequest {
  string name = 1;
}

// The response message containing the greetings
message HelloReply {
  string message = 1;
}

2단계: gRPC 코드 생성

위의 .proto 파일로부터 서버와 클라이언트 코드를 생성합니다. Go를 위한 gRPC 코드를 생성하기 위해 protoc 컴파일러와 Go용 gRPC 플러그인이 필요합니다.

터미널에서 다음 명령을 실행합니다:

protoc --go_out=. --go_opt=paths=source_relative \\\\
       --go-grpc_out=. --go-grpc_opt=paths=source_relative \\\\
       helloworld.proto

이 명령은 helloworld.pb.go와 helloworld_grpc.pb.go 두 개의 파일을 생성하는데, 이 파일들에는 gRPC 서버와 클라이언트를 위한 코드가 포함되어 있습니다.

3단계: gRPC 서버 구현

server.go 파일을 생성하고 gRPC 서버를 구현합니다.

package main

import (
	"context"
	"log"
	"net"

	pb "your/path/helloworld" // 프로토콜 버퍼 파일에서 생성된 패키지 경로로 변경하세요.
	"google.golang.org/grpc"
)

const (
	port = ":50051"
)

// server is used to implement helloworld.GreeterServer.
type server struct {
	pb.UnimplementedGreeterServer
}

// SayHello implements helloworld.GreeterServer
func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
	log.Printf("Received: %v", in.GetName())
	return &pb.HelloReply{Message: "Hello " + in.GetName()}, nil
}

func main() {
	lis, err := net.Listen("tcp", port)
	if err != nil {
		log.Fatalf("failed to listen: %v", err)
	}
	s := grpc.NewServer()
	pb.RegisterGreeterServer(s, &server{})
	log.Printf("server listening at %v", lis.Addr())
	if err := s.Serve(lis); err != nil {
		log.Fatalf("failed to serve: %v", err)
	}
}

4단계: gRPC 클라이언트 구현

client.go 파일을 생성하고 gRPC 클라이언트를 구현합니다.

package main

import (
	"context"
	"log"
	"os"
	"time"

	pb "your/path/helloworld" // 프로토콜 버퍼 파일에서 생성된 패키지 경로로 변경하세요.
	"google.golang.org/grpc"
)

const (
	address     = "localhost:50051"
	defaultName = "world"
)

func main() {
	// Set up a connection to the server.
	conn, err := grpc.Dial(address, grpc.WithInsecure(), grpc.WithBlock())
	if err != nil {
		log.Fatalf("did not connect: %v", err)
	}
	defer conn.Close()
	c := pb.NewGreeterClient(conn)

	// Contact the server and print out its response.
	name := defaultName
	if len(os.Args) > 1 {
		name = os.Args[1]
	}
	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
	defer cancel()
	r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})
	if err != nil {
		log.Fatalf("could not greet: %v", err)
	}
	log.Printf("Greeting: %s", r.GetMessage())
}

5단계: 서버

와 클라이언트 실행