综合实战：迷你在线判题平台

这一课你将能做到

1. 把前 11 课的模块组装成一个分层清晰的判题平台后端：提交 → 队列 → 判题 → 推送全链路可运行
2. 用分层结构（Domain / Application / Infrastructure / Api）组织代码，说出每层与 Spring 项目的对应关系
3. 拿到一份上线前检查清单，能独立完成「从空仓库到容器化部署」的完整交付

为什么要学

单点知识学完不等于会做系统——功夫在「接线」：谁持有谁、事务边界在哪、失败谁兜底。这一课把判题平台当验收考题：每处接线都对应前面某一课，含糊就回那课补。

人话：前 11 课是零件，这一课是总装车间。装完你就有一套「能写进简历、面试讲 20 分钟」的项目。

先建立图像

项目分层（Clean Architecture 精简版）与 Spring 项目对照：

OJ.Platform/
├─ src/
│  ├─ Oj.Domain/            实体与领域规则（无框架）  ≙ domain 模块
│  ├─ Oj.Application/       用例编排（接口+实现）     ≙ service 模块
│  ├─ Oj.Infrastructure/    出站适配：EF/Redis/MQ/沙箱 ≙ persistence+client
│  ├─ Oj.Api/               入站适配：REST + SignalR  ≙ web/controller
│  └─ Oj.Worker/            判题消费者（独立进程）    ≙ 消息监听应用
└─ OJ.Platform.sln

依赖方向：Api/Worker → Application → Domain；Infrastructure 实现 Application 的接口，由组合根装配。.NET 版六边形架构，与 Spring 分层治理同源。

跟着做

步骤 1：组合根——一个文件看全装配

// Oj.Api/Program.cs
var builder = WebApplication.CreateBuilder(args);

// 数据（第 3 课）
builder.Services.AddDbContext<OjDbContext>(o =>
    o.UseNpgsql(builder.Configuration.GetConnectionString("Default")));

// 业务与 DI 生命周期（第 4 课）
builder.Services.AddScoped<SubmitUseCase>();
builder.Services.AddSingleton<IJudgeQueue, RabbitJudgeQueue>();   // 队列连接全局唯一
builder.Services.AddScoped<ProblemCacheService>();

// 缓存（第 6 课）
builder.Services.AddStackExchangeRedisCache(o =>
    o.Configuration = builder.Configuration.GetConnectionString("Redis"));

// 消息（第 9 课）
builder.Services.AddMassTransit(x => x.UsingRabbitMq((ctx, cfg) =>
{
    cfg.Host(builder.Configuration["RabbitMq:Host"]!);
    cfg.ConfigureEndpoints(ctx);
}));

// 实时/文档/全局异常（第 5、7 课）
builder.Services.AddSignalR();
builder.Services.AddSwaggerGen();
builder.Services.AddExceptionHandler<GlobalExceptionHandler>();
builder.Services.AddProblemDetails();

var app = builder.Build();

app.UseExceptionHandler();
if (app.Environment.IsDevelopment()) { app.UseSwagger(); app.UseSwaggerUI(); }

app.MapSubmissionEndpoints();   // /api/submissions
app.MapHub<JudgeHub>("/hubs/judge");
app.MapHealthChecks("/healthz");
app.Run();

public partial class Program { }   // 集成测试复用（第 8 课）

步骤 2：领域层——纯 C#，无框架痕迹

// Oj.Domain/Submission.cs
public class Submission
{
    public long Id { get; private set; }
    public long ProblemId { get; private set; }
    public string UserName { get; private set; } = null!;
    public string Language { get; private set; } = null!;
    public string Status { get; private set; } = "PENDING";   // PENDING→JUDGING→AC/WA/TLE/RE
    public int TimeMs { get; private set; }

    // 状态机收敛变更入口：非法流转直接拒绝（幂等第一道防线）
    public void MarkJudged(string verdict, int timeMs)
    {
        if (Status is not ("PENDING" or "JUDGING"))
            throw new InvalidOperationException($"状态 {Status} 不允许再判定");
        Status = verdict;
        TimeMs = timeMs;
    }
}