- 본 글은 데보션 글을 기반으로 정리 형식에서 작성되었습니다. (해당 링크는 하단에)
gRPC 란?
- 구글에서 개발한 고성능 RPC 프레임워크
- HTTP/2 에서 동작하며 양방향 스트리밍 및 흐름 제어 제공
- 원경으로 호출할 수 있는 메서드 지정하여 서비스 정의하는 개념 기반
- 클라이언트 어플리케이션이 로컬 객체처럼 다른 컴퓨터의 서버 어플리케이션의 메서드를 직접 호출 가능 -> 분산 어플리케이션 및 서비스 개발에 용이함
- protobuf(IDL로 사용)를 기본 메세지 형식으로 사용
- IDL (Interface Definition Language)
gRPC 특징
- 언어 독립성: 다양한 언어 지원. 클라이언트와 서버가 다른 언어로 작성되어도 상호작용 가능
- 양방향 스트리밍: HTTP/2를 기반으로 하는 클라이언트 - 서버 간 양방향 스트리밍 지원
- 강력한 타입 체크: 메세지 형식으로 protobufs로 정의하면, gRPC는 Type 체크 제공
- 높은 성능: HTTP/2와 protobufs 를 활용한 높은 성능 제공
- 구글 API 연동: 구글 API 인터페이스에 gRPC가 제공되므로 연동에 용이함
gRPC 4가지 서비스 정의 방법
- 단항 RPC: 클라이언트가 서버에 단일 요청 전송 후 일반 함수 호출처럼 단일 응답
rpc SayHello(HelloRequest) returns (HelloResponse);
- 서버 스트리밍 RPC: 클라이언트가 서버에 요청 보내고, 일련의 메시지 읽을 수 있는 스트림을 다시 받는 방식
rpc LotsOfReplies(HelloRequest) returns (stream HelloResponse);
- 클라이언트 스트리밍 RPC: 클라이언트가 일련의 메시지 작성하고 제공된 스트림을 사용하여 다시 서버로 보내는 방식
rpc LotsOfGreetings(stream HelloRequest) returns (HelloResponse);
- 양방향 스트리밍 RPC: 양쪽이 읽기-쓰기 스트림을 사용해 일련의 메시지를 보내는 방식
rpc LotsOfGreetings(stream HelloRequest) returns (HelloResponse);
protobuf
- 프로토콜 버퍼 데이터
- 개발 언어, 플랫폼과 상관 없이 직렬화 가능하게 하는 데이터 구조
- 메시지로 구조화 됨
- 각 메세지는 필드라고 하는 일련의 이름-값 쌍을 포함함
- 서로 다른 시스템끼리 데이터 공유, 저장하기 위해 사용
- xml, json 보다 더 효율적인 방식으로 데이터 관리
- 때문에 전송 및 저장 시 데이터를 더 적게 사용할 수 있다.
- 파일 확장자는 .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
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
