第 07 章：服务通信

第 07 章：服务通信

服务间的通信方式决定了系统的耦合度、性能和可靠性。选对通信模式，是微服务成功的关键。

7.1 通信模式总览

7.1.1 同步 vs 异步

  同步通信 (Synchronous)
  ──────────────────────────────

  服务A ──请求──▶ 服务B
  服务A ◀──响应── 服务B

  特点：调用方等待响应，阻塞直到完成


  异步通信 (Asynchronous)
  ──────────────────────────────

  服务A ──消息──▶ [消息队列] ──消费──▶ 服务B

  特点：调用方发送消息后立即返回，不等待响应

7.1.2 通信模式矩阵

  请求-响应               发布-订阅
  ─────────              ─────────
  A ──请求──▶ B          A ──事件──▶ Topic
  A ◀──响应── B               ├──▶ B
                              ├──▶ C
                              └──▶ D

7.2 同步通信：REST

7.2.1 REST API 设计规范

  REST API 设计示例：

  ┌────────┬──────────────────────┬───────────────┐
  │ 方法    │ 路径                 │ 说明          │
  ├────────┼──────────────────────┼───────────────┤
  │ GET    │ /api/v1/users        │ 获取用户列表   │
  │ GET    │ /api/v1/users/{id}   │ 获取单个用户   │
  │ POST   │ /api/v1/users        │ 创建用户      │
  │ PUT    │ /api/v1/users/{id}   │ 更新用户      │
  │ DELETE │ /api/v1/users/{id}   │ 删除用户      │
  │ GET    │ /api/v1/users/{id}/orders │ 用户的订单 │
  └────────┴──────────────────────┴───────────────┘

7.2.2 REST 的优缺点

7.2.3 OpenAPI/Swagger 规范

# openapi.yaml
openapi: 3.0.0
info:
  title: User Service API
  version: 1.0.0
paths:
  /api/v1/users/{id}:
    get:
      summary: 获取用户详情
      parameters:
        - name: id
          in: path
          required: true
          schema:
            type: string
      responses:
        '200':
          description: 成功
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/User'
        '404':
          description: 用户不存在
components:
  schemas:
    User:
      type: object
      properties:
        id:
          type: string
        name:
          type: string
        email:
          type: string
          format: email

7.3 同步通信：gRPC

7.3.1 gRPC 概述

gRPC 是 Google 开发的高性能 RPC 框架，基于 HTTP/2 和 Protocol Buffers。

  gRPC 通信流程：

  ┌──────────┐                          ┌──────────┐
  │ 客户端    │                          │ 服务端    │
  │          │      HTTP/2 连接          │          │
  │ Proto    │ ◀══════════════════════▶ │ Proto    │
  │ Client   │   二进制传输 (Protobuf)   │ Server   │
  │          │                          │          │
  │ .proto   │  ┌──────────────────┐   │ .proto   │
  │ 文件生成  │  │ IDL 接口定义     │   │ 文件生成  │
  │ 客户端桩  │  │ service UserService│  │ 服务端骨架│
  └──────────┘  │ {                  │  └──────────┘
                │   rpc GetUser      │
                │   (GetUserReq)     │
                │   returns          │
                │   (UserResp)       │
                │ }                  │
                └──────────────────┘

7.3.2 Protocol Buffers 定义

// user.proto
syntax = "proto3";

package user;

option java_package = "com.example.user";

service UserService {
  rpc GetUser (GetUserRequest) returns (UserResponse);
  rpc ListUsers (ListUsersRequest) returns (ListUsersResponse);
  rpc CreateUser (CreateUserRequest) returns (UserResponse);
  rpc WatchUser (WatchUserRequest) returns (stream UserEvent); // 服务端流
}

message GetUserRequest {
  string id = 1;
}

message UserResponse {
  string id = 1;
  string name = 2;
  string email = 3;
  int64 created_at = 4;
}

message ListUsersRequest {
  int32 page = 1;
  int32 size = 2;
}

message ListUsersResponse {
  repeated UserResponse users = 1;
  int32 total = 2;
}

message CreateUserRequest {
  string name = 1;
  string email = 2;
}

message WatchUserRequest {
  string user_id = 1;
}

message UserEvent {
  string event_type = 1;  // CREATED, UPDATED, DELETED
  UserResponse user = 2;
  int64 timestamp = 3;
}

7.3.3 gRPC 四种通信模式

  1. 一元 RPC (Unary)
     客户端 ──请求──▶ 服务端
     客户端 ◀──响应── 服务端

  2. 服务端流式 (Server Streaming)
     客户端 ──请求──▶ 服务端
     客户端 ◀──stream── 服务端
     客户端 ◀──stream── 服务端
     客户端 ◀──stream── 服务端

  3. 客户端流式 (Client Streaming)
     客户端 ──stream──▶ 服务端
     客户端 ──stream──▶ 服务端
     客户端 ──stream──▶ 服务端
     客户端 ◀──响应── 服务端

  4. 双向流式 (Bidirectional Streaming)
     客户端 ──stream──▶ 服务端
     客户端 ◀──stream── 服务端
     客户端 ──stream──▶ 服务端
     客户端 ◀──stream── 服务端

7.3.4 REST vs gRPC 全面对比

7.4 通信模式选型

7.4.1 选型决策树

  需要同步响应吗？
  │
  ├── 是 → 需要高性能/低延迟？
  │        │
  │        ├── 是 → 使用 gRPC
  │        │        (服务间内部通信)
  │        │
  │        └── 否 → 使用 REST
  │                  (外部 API / 简单场景)
  │
  └── 否 → 需要保证消息不丢失？
           │
           ├── 是 → 使用消息队列
           │        (Kafka / RabbitMQ)
           │
           └── 否 → 使用事件通知
                    (轻量级异步)

7.4.2 通信方式适用场景

7.5 服务发现（Service Discovery）

7.5.1 服务发现方式

  客户端发现                    服务端发现
  ────────────                ────────────

  ┌────────┐                  ┌────────┐
  │ 客户端  │                  │ 客户端  │
  └───┬────┘                  └───┬────┘
      │                           │
      ▼                           ▼
  ┌──────────┐               ┌──────────┐
  │ 服务注册  │               │ 负载均衡  │
  │ 中心     │               │ / 代理   │
  │(Eureka/  │               │(LB/Nginx)│
  │ Consul)  │               └────┬─────┘
  └──────────┘                    │
      │                           ▼
      ▼                       ┌──────────┐
  ┌──────────┐               │ 服务实例  │
  │ 服务实例  │               └──────────┘
  └──────────┘

7.5.2 注册中心对比

7.6 弹性通信模式

7.6.1 超时、重试与熔断

  ┌──────────────────────────────────────────────────────────┐
  │                 弹性通信三板斧                             │
  ├──────────────────────────────────────────────────────────┤
  │                                                          │
  │  1. 超时 (Timeout)                                       │
  │  ┌────────┐  ──请求──▶  ┌────────┐                      │
  │  │ 服务A   │  3秒超时    │ 服务B   │                      │
  │  │        │  ◀─超时!──  │ (卡住)  │                      │
  │  └────────┘             └────────┘                      │
  │                                                          │
  │  2. 重试 (Retry)                                         │
  │  ┌────────┐  ──请求1──▶ ┌────────┐                      │
  │  │ 服务A   │  ◀─失败──  │ 服务B   │                      │
  │  │        │  ──请求2──▶ │        │                      │
  │  │        │  ◀─成功──   │        │                      │
  │  └────────┘             └────────┘                      │
  │                                                          │
  │  3. 熔断 (Circuit Breaker)                               │
  │  ┌────────┐             ┌────────┐                      │
  │  │ 服务A   │  ──请求──▶  │ 服务B   │  (连续失败)          │
  │  │        │             └────────┘                      │
  │  │  熔断器 │  ──直接──▶  返回降级响应                     │
  │  │ CLOSED │             (不再调用B)                      │
  │  │   ↓    │                                             │
  │  │  OPEN  │  一段时间后 ──半开──▶  探测请求               │
  │  └────────┘             恢复? CLOSED : OPEN              │
  └──────────────────────────────────────────────────────────┘

7.6.2 熔断器状态机

  ┌─────────────┐    失败率超过阈值    ┌─────────────┐
  │   CLOSED    │ ──────────────────▶ │    OPEN     │
  │  (正常状态)  │                     │  (熔断状态)  │
  │  所有请求    │                     │  所有请求    │
  │  通过       │                     │  直接拒绝    │
  └──────┬──────┘                     └──────┬──────┘
         │                                   │
         │  正常响应                          │ 等待超时后
         │                                   ▼
         │                            ┌──────────────┐
         │◀────────────────────────── │  HALF-OPEN   │
         │    探测成功，恢复            │  (半开状态)   │
         │                            │  允许少量请求  │
         │                            └──────────────┘
         │                                   │
         │                            探测失败│
         │                                   ▼
         │                            回到 OPEN 状态

7.6.3 Resilience4j 示例

// 熔断器配置
CircuitBreakerConfig config = CircuitBreakerConfig.custom()
    .failureRateThreshold(50)           // 失败率阈值 50%
    .waitDurationInOpenState(Duration.ofSeconds(30))  // 熔断等待 30 秒
    .slidingWindowSize(10)              // 滑动窗口 10 次请求
    .minimumNumberOfCalls(5)            // 最少 5 次调用才计算
    .build();

CircuitBreaker circuitBreaker = CircuitBreaker.of("userService", config);

// 使用
Supplier<User> decoratedSupplier = CircuitBreaker
    .decorateSupplier(circuitBreaker, () -> userService.getUser(userId));

Try<User> result = Try.ofSupplier(decoratedSupplier)
    .recover(CallNotPermittedException.class, e -> getFallbackUser())
    .recover(Exception.class, e -> getDefaultUser());

7.7 业务场景：电商系统的通信设计

  ┌───────────────────────────────────────────────────────────┐
  │              电商系统通信模式选型                            │
  ├───────────────────────────────────────────────────────────┤
  │                                                           │
  │  外部 API（客户端 → 网关）:                                │
  │  └─ REST / HTTPS                                          │
  │                                                           │
  │  服务间同步调用：                                          │
  │  ├─ 订单服务 → 用户服务 (查询用户): REST                   │
  │  ├─ 订单服务 → 商品服务 (查询商品): gRPC                   │
  │  └─ 订单服务 → 库存服务 (扣库存): gRPC (高性能)            │
  │                                                           │
  │  服务间异步事件：                                          │
  │  ├─ 订单已创建 → Kafka → 支付服务/库存服务/通知服务        │
  │  ├─ 支付已完成 → Kafka → 订单服务/物流服务                 │
  │  └─ 商品已发货 → Kafka → 通知服务/用户服务                 │
  │                                                           │
  │  实时通信：                                                │
  │  └─ WebSocket / gRPC Streaming (订单状态实时推送)          │
  └───────────────────────────────────────────────────────────┘

⚠️ 注意事项

1. 同步调用链不要太长——超过 3 层的同步调用应考虑异步化
2. 设置合理的超时——每个调用都必须有超时，避免无限等待
3. 重试要有退避策略——指数退避 + 抖动，避免重试风暴
4. 熔断要配合降级——熔断后要有兜底响应
5. gRPC 调试不如 REST 方便——确保有合适的调试工具

📖 扩展阅读

1. gRPC Documentation (grpc.io) — gRPC 官方文档
2. Resilience4j (resilience4j.readme.io) — Java 弹性通信库
3. Sam Newman - Building Microservices, Chapter 4 — 同步通信
4. Netflix Hystrix (已进入维护模式，推荐 Resilience4j 替代)
5. Web API Design — API 设计最佳实践

本章小结

📌 下一章：第 08 章：消息队列 — 深入消息队列、事件驱动架构与最终一致性。