2. gRPC 基础回顾

在深入事务边界与消息链路调优之前，必须夯实 gRPC 通信模型、Protocol Buffers 定义以及服务端/客户端搭建的基础。本章将系统梳理这三大核心模块，为后续的实战调优提供精确的上下文。

2.1 gRPC 通信模型

gRPC 基于 HTTP/2 协议，支持四种通信模式。理解每种模式的数据流特征，是配置事务边界和链路参数的前提。

2.2 Protocol Buffers 定义与编译

Protocol Buffers (protobuf) 是 gRPC 的接口定义语言 (IDL) 和序列化协议。其定义文件 (.proto) 的质量直接决定了服务接口的稳定性和性能。

2.2.1 核心定义要素

• 消息结构 (message)：定义字段编号、类型和可选/必选规则。
• 服务接口 (service)：声明 RPC 方法及其输入/输出消息类型。
• 字段规则：optional、repeated、map 等。
• 包名与导入：避免命名冲突，支持跨文件引用。

2.2.2 编译流程

1. 编写 .proto 文件。
2. 使用 protoc 编译器生成目标语言代码 (Java, Go, Python 等)。
3. 将生成的代码集成到项目中。

// 示例: order.proto
syntax = "proto3";
package order;

message OrderRequest {
  string order_id = 1;
  string user_id = 2;
  repeated string item_ids = 3;
}

message OrderResponse {
  bool success = 1;
  string message = 2;
}

service OrderService {
  rpc CreateOrder (OrderRequest) returns (OrderResponse);
  rpc SubscribeOrderStatus (OrderRequest) returns (stream OrderResponse);
}

2.3 gRPC 服务端与客户端快速搭建

以下步骤展示如何基于生成的代码快速搭建一个可运行的 gRPC 服务端和客户端。这是后续所有调优实验的起点。

2.3.1 服务端实现

// 服务端代码片段 (Java)
public class OrderServer {
    public static void main(String[] args) throws IOException, InterruptedException {
        Server server = ServerBuilder.forPort(50051)
                .addService(new OrderServiceImpl())
                .build();
        server.start();
        System.out.println("Server started on port 50051");
        server.awaitTermination();
    }

    static class OrderServiceImpl extends OrderServiceGrpc.OrderServiceImplBase {
        @Override
        public void createOrder(OrderRequest req, StreamObserver<OrderResponse> responseObserver) {
            // 业务逻辑
            OrderResponse resp = OrderResponse.newBuilder()
                    .setSuccess(true)
                    .setMessage("Order " + req.getOrderId() + " created")
                    .build();
            responseObserver.onNext(resp);
            responseObserver.onCompleted();
        }
    }
}

2.3.2 客户端实现

// 客户端代码片段 (Java)
public class OrderClient {
    public static void main(String[] args) {
        ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 50051)
                .usePlaintext()
                .build();
        OrderServiceGrpc.OrderServiceBlockingStub stub = OrderServiceGrpc.newBlockingStub(channel);
        OrderRequest request = OrderRequest.newBuilder()
                .setOrderId("ORD-001")
                .setUserId("USR-100")
                .addItemIds("ITEM-A")
                .build();
        OrderResponse response = stub.createOrder(request);
        System.out.println("Response: " + response.getMessage());
        channel.shutdown();
    }
}

2.4 通信模型与消息边界关系图

下图展示了四种通信模型下，消息在客户端与服务端之间的流动方式，以及事务边界可能出现的节点。

2.5 服务搭建与参数配置流程

以下流程图总结了从 proto 定义到服务端/客户端启动的完整链路，并标注了关键参数配置点。