gRPC核心概念与工作原理#

Client Stub (生成代码)
    ↓ Protobuf 序列化
Channel (HTTP/2 连接管理)
    ↓ HTTP/2 帧
Transport (TCP / TLS)
    ↓
Server: Interceptor → Service Implementation

service OrderService {
  // 1. Unary: 一请求一响应（最常用，类似 REST）
  rpc GetOrder(OrderRequest) returns (OrderResponse);

  // 2. Server Streaming: 一请求多响应（适合推送、分页拉取）
  rpc ListOrders(ListRequest) returns (stream OrderResponse);

  // 3. Client Streaming: 多请求一响应（适合上传、批量写入）
  rpc UploadOrders(stream OrderRequest) returns (UploadResponse);

  // 4. Bidirectional Streaming: 双向流（适合聊天、实时同步）
  rpc Chat(stream ChatMessage) returns (stream ChatMessage);
}

gRPC 本身不提供服务发现，需要集成：
- Nacos / Consul / etcd 作为注册中心
- 客户端负载均衡：gRPC 内置 pick_first / round_robin
- 也可用 Envoy / Istio 做 sidecar 代理

// 服务端
Server server = ServerBuilder.forPort(9090)
    .addService(new OrderServiceImpl())
    .addService(ServerInterceptors.intercept(service, authInterceptor))
    .build()
    .start();

// 客户端
ManagedChannel channel = ManagedChannelBuilder
    .forTarget("dns:///order-service:9090")
    .usePlaintext()
    .build();
OrderServiceGrpc.OrderServiceBlockingStub stub =
    OrderServiceGrpc.newBlockingStub(channel);