[gRPC] Go 언어로 gRPC 사용해보기

• 본 글은 데보션 글을 기반으로 정리 형식에서 작성되었습니다. (해당 링크는 하단에)

gRPC 란?

• 구글에서 개발한 고성능 RPC 프레임워크
• HTTP/2 에서 동작하며 양방향 스트리밍 및 흐름 제어 제공
• 원경으로 호출할 수 있는 메서드 지정하여 서비스 정의하는 개념 기반
  • 클라이언트 어플리케이션이 로컬 객체처럼 다른 컴퓨터의 서버 어플리케이션의 메서드를 직접 호출 가능 -> 분산 어플리케이션 및 서비스 개발에 용이함
• protobuf(IDL로 사용)를 기본 메세지 형식으로 사용
  • IDL (Interface Definition Language)

gRPC 특징

• 언어 독립성: 다양한 언어 지원. 클라이언트와 서버가 다른 언어로 작성되어도 상호작용 가능
• 양방향 스트리밍: HTTP/2를 기반으로 하는 클라이언트 - 서버 간 양방향 스트리밍 지원
• 강력한 타입 체크: 메세지 형식으로 protobufs로 정의하면, gRPC는 Type 체크 제공
• 높은 성능: HTTP/2와 protobufs 를 활용한 높은 성능 제공
• 구글 API 연동: 구글 API 인터페이스에 gRPC가 제공되므로 연동에 용이함

gRPC 4가지 서비스 정의 방법

1. 단항 RPC: 클라이언트가 서버에 단일 요청 전송 후 일반 함수 호출처럼 단일 응답

rpc SayHello(HelloRequest) returns (HelloResponse);

2. 서버 스트리밍 RPC: 클라이언트가 서버에 요청 보내고, 일련의 메시지 읽을 수 있는 스트림을 다시 받는 방식

rpc LotsOfReplies(HelloRequest) returns (stream HelloResponse);

3. 클라이언트 스트리밍 RPC: 클라이언트가 일련의 메시지 작성하고 제공된 스트림을 사용하여 다시 서버로 보내는 방식

rpc LotsOfGreetings(stream HelloRequest) returns (HelloResponse);

4. 양방향 스트리밍 RPC: 양쪽이 읽기-쓰기 스트림을 사용해 일련의 메시지를 보내는 방식

rpc LotsOfGreetings(stream HelloRequest) returns (HelloResponse);

protobuf

• 프로토콜 버퍼 데이터
• 개발 언어, 플랫폼과 상관 없이 직렬화 가능하게 하는 데이터 구조
  • 메시지로 구조화 됨
  • 각 메세지는 필드라고 하는 일련의 이름-값 쌍을 포함함
• 서로 다른 시스템끼리 데이터 공유, 저장하기 위해 사용
• xml, json 보다 더 효율적인 방식으로 데이터 관리
  • 때문에 전송 및 저장 시 데이터를 더 적게 사용할 수 있다.
• 파일 확장자는 .proto로 정의된다

코드 작성해 보기

• proto 파일 생성

// https://github.com/grpc/grpc-go

syntax = "proto3";

// 패키지로 생성하기 위해 추가
option go_package = "grpc/helloworld";

// 패키지로 생성하기 위해 추가
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;
}

• .proto 파일 생성 후, protoc 을 이용해 각 언어에 맞는 코드 생성

protoc --go\_out=. --go\_opt=paths=source\_relative --go-grpc\_out=. --go-grpc\_opt=paths=source\_relative helloworld/helloworld.proto

• go 서버 코드 작성

package main

import (
    "context"
    "flag"
    "fmt"
    pb "grpc/helloworld" // protoc 로 생성된 코드
    "log"
    "net"

    "google.golang.org/grpc"
)

var (
    port = flag.Int("port", 50051, "The server port")
)

// helloworld.GreeterServer 구현체 시용하는 서버
type server struct {
    pb.UnimplementedGreeterServer // 이부분은 안하면 에러가 발생한다. protobuf generate시 생성됨
}

type GreeterServer struct {
    SayHello(context.Context, *HelloRequest) (*HelloReply, error)
    // protobuf 빌드 시 생성되는 메서드
    mustEmbedUnimplementedGreeterServer()
}

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() {
    flag.Parse()
    lis, err := net.Listen("tcp", fmt.Sprintf(":%d", *port))
    if err != nil {
        log.Fatalf("failed to listen: %v", err)
    }
    s := grpc.NewServer()
    pb.RegisterGreeterServer(s, &server{}) //client가 사용할 수 있도록 등록
    log.Printf("server listening at %v", lis.Addr())
    if err := s.Serve(lis); err != nil {
        log.Fatalf("failed to serve: %v", err)
    }
}

REFERENCE

• 데보션: https://devocean.sk.com/blog/techBoardDetail.do?ID=165058