微服务与跨服务通信（对照 Spring Cloud）

这一课你将能做到

1. 把判题平台按「题库 / 判题 / 用户」拆出服务边界，说清拆与不拆的判断标准
2. 用 gRPC 定义判题服务内部接口，用类型化 HttpClient + 标准弹性策略调用下游
3. 用 YARP 搭 API 网关，配健康检查，对照 Spring Cloud Gateway/Nacos/OpenFeign 完成映射

为什么要学

单体够用前不要拆微服务。「拆」的时机一到，需要回答四个问题：服务间怎么调用（同步 REST/gRPC）、怎么扛失败（超时/重试/熔断）、流量怎么进来（网关）、实例怎么找到彼此（服务发现）。Spring Cloud 全家桶（Gateway/OpenFeign/Resilience4j/Nacos）在 .NET 侧对应：YARP/HttpClientFactory+Resilience/gRPC/K8s DNS——理念相同，组件更「原生」。

人话：微服务的本质不是技术栈，是「团队与部署的边界」。判题要独立伸缩（CPU 密集且要沙箱安全）、题库读多写少、用户服务全局共享——这三块天然是三个部署单元。

先建立图像

                    ┌───────────────┐
 浏览器 ──HTTPS──→  │  YARP 网关     │   /api/problems/* → 题库服务
                    │ (路由/认证/限流) │   /api/submissions/* → 提交服务
                    └───────┬───────┘
                            │ gRPC(内部, 低延迟强类型)
        ┌───────────────────┼────────────────────┐
   题库服务              提交服务               判题服务(扩缩容)
   (EF+MySQL)          (API+队列发布)         (沙箱, BackgroundService)

Spring Cloud	ASP.NET Core 生态	职责
Spring Cloud Gateway	YARP（基于 .NET 的反向代理）	网关/路由/限流
OpenFeign	类型化 HttpClient（IHttpClientFactory）	声明式客户端
Resilience4j	Microsoft.Extensions.Http.Resilience / Polly	重试/熔断/超时
Eureka / Nacos	K8s DNS / Consul	服务发现
Spring Boot Actuator	健康检查中间件 + AspNetCore.HealthChecks	健康探测

跟着做

步骤 1：gRPC 定义判题接口（内部通信首选）

judge.proto（共享给服务端与客户端）：

syntax = "proto3";
option csharp_namespace = "Oj.Contracts";

service Judge {
  rpc Submit (JudgeRequest) returns (JudgeReply);
}

message JudgeRequest {
  int64 submission_id = 1;
  string language = 2;
  string code = 3;
  int32 time_limit_ms = 4;
}

message JudgeReply {
  string status = 1;
  int32 time_ms = 2;
  int32 memory_kb = 3;
}

服务端实现：

dotnet add package Grpc.AspNetCore

public class JudgeGrpcService(OjDbContext db) : Judge.JudgeBase
{
    public override async Task<JudgeReply> Submit(JudgeRequest req, ServerCallContext ctx)
    {
        var result = await SandboxRunner.RunAsync(req.Code, req.Language, req.TimeLimitMs, ctx.CancellationToken);
        return new JudgeReply { Status = result.Status, TimeMs = result.TimeMs, MemoryKb = result.MemoryKb };
    }
}

// Program.cs
builder.Services.AddGrpc();
app.MapGrpcService<JudgeGrpcService>();