gRPC 是什么？和 REST 有什么区别？

syntax = "proto3";
package user.v1;
option go_package = "example.com/app/gen/user/v1;userv1";
service UserService {
  rpc GetUser(GetUserRequest) returns (User);               // 一元：一个请求一个响应
  rpc ListUsers(ListUsersRequest) returns (stream User);    // 服务端流：如分批推送查询结果
  rpc UploadLogs(stream LogEntry) returns (UploadSummary);  // 客户端流：如上传大量日志后汇总
  rpc Chat(stream ChatMessage) returns (stream ChatMessage); // 双向流：如聊天、实时协同
}
message GetUserRequest { int64 id = 1; }
message User {
  int64 id = 1;
  string name = 2;
  reserved 3; reserved "email"; // 删除过的字段：编号和名字都保留，防止被复用
}

package main

import (
	"context"
	"log"
	"net"
	"time"

	userv1 "example.com/app/gen/user/v1" // 上面的 proto 生成的包
	"google.golang.org/grpc"
	"google.golang.org/grpc/codes"
	"google.golang.org/grpc/status"
)

type userServer struct {
	userv1.UnimplementedUserServiceServer // 按值嵌入：未实现的方法返回 Unimplemented，proto 新增方法时也能编译
}

func (s *userServer) GetUser(ctx context.Context, req *userv1.GetUserRequest) (*userv1.User, error) {
	if req.GetId() <= 0 {
		return nil, status.Error(codes.InvalidArgument, "id must be positive")
	}
	return &userv1.User{Id: req.GetId(), Name: "alice"}, nil
}

func logging(ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (any, error) {
	start := time.Now()
	resp, err := handler(ctx, req)
	log.Printf("%s code=%s cost=%s", info.FullMethod, status.Code(err), time.Since(start))
	return resp, err
}

func main() {
	lis, err := net.Listen("tcp", ":50051")
	if err != nil {
		log.Fatal(err)
	}
	s := grpc.NewServer(grpc.ChainUnaryInterceptor(logging)) // 加一个记录日志的一元拦截器
	userv1.RegisterUserServiceServer(s, &userServer{})
	log.Fatal(s.Serve(lis)) // 退出时可以调用 s.GracefulStop() 等待进行中的调用结束
}

// 客户端关键片段（省略 import，insecure 来自 google.golang.org/grpc/credentials/insecure；演示用明文，生产环境用 TLS）
conn, err := grpc.NewClient("dns:///user-svc:50051",
	grpc.WithTransportCredentials(insecure.NewCredentials()),
	grpc.WithDefaultServiceConfig(`{"loadBalancingConfig":[{"round_robin":{}}]}`), // 按请求轮询
)
if err != nil {
	log.Fatal(err)
}
defer conn.Close() // ClientConn 并发安全，全局复用一个
client := userv1.NewUserServiceClient(conn)
ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond)
defer cancel()
user, err := client.GetUser(ctx, &userv1.GetUserRequest{Id: 42})
if err != nil {
	log.Printf("get user: code=%s", status.Code(err)) // 按状态码区分处理，DeadlineExceeded 表示超时
	return
}
log.Println("user:", user.GetName())