Sparkdo.Messaging.Reliability 3.0.0-preview.1

Sparkdo.Messaging.Reliability

可靠性设施的默认实现：指数退避重试、进程内 Inbox / Outbox / Saga 存储。

端口（IRetryPolicy / IMessageInbox / IMessageOutbox / ISagaStore / IDeadLetterSink / IWorkUnit） 全在 Sparkdo.Messaging 内核里；本包只提供实现，宿主可以整体替换。

接线

builder.Services
    .AddSparkdoMessagingReliability(options =>
    {
        options.MaxAttempts = 5;                    // 默认 5（含首次尝试）
        options.BaseDelay   = TimeSpan.FromSeconds(1);   // 默认 1s：第一次重试的基础延迟
        options.MaxDelay    = TimeSpan.FromMinutes(1);   // 默认 1min：指数增长到这里封顶
        options.JitterRatio = 0.25;                 // 默认 0.25：±25% 抖动，0 表示不抖
    })
    .AddSparkdoMessaging(serializers, bus => bus
        .AddTransport(new RabbitMQTransport(options), TransportDefault.Default)
        .Use(InboxMiddleware.Create(sp => sp.GetRequiredService<IMessageInbox>(), tenant: "orders", handlerId: "sparkdo.billing.order-placed-handler")))
    .AddSparkdoMessagingHosting();

一次登记全部装好，且一律 TryAdd——先登记的赢，宿主要换实现就在它之前注册，或者干脆不叫这个方法：

ISagaStore 这一条要盯住：不显式登记 <ISagaStore, 真实存储>，Saga 的状态就落在内存里， 进程一重启就没了，而不会报错。换 EF 档就是 AddMessagingEntityFrameworkCore<AppDbContext>() （它登记的也是 TryAdd，所以调用顺序决定谁赢）。

重试：默认那条曲线

var delay = BaseDelay * 2^(Attempt - 1)        // 位移封在 30，防溢出
              封顶到 MaxDelay
              × (1 + 随机[-1,1) × JitterRatio)  // JitterRatio ≤ 0 时不抖

Inbox：幂等中间件怎么摆

端口在核心（IMessageInbox），实现（InMemoryMessageInbox）在这里，登记在管道上：

bus.Use(InboxMiddleware.Create(
    services => services.GetRequiredService<IMessageInbox>(),
    tenant: "orders",
    handlerId: "sparkdo.billing.order-placed-handler"));

键是 (Tenant, MessageId, HandlerId) 三元组——"同一条消息在同一个处理器上只跑一次"， 不是"同一条消息只跑一次"。三家订阅者各自都要跑，各自记一格。

顺序要紧：Use(workUnit) 与 Use(inbox) 谁先登记谁在外层。想让"提交成功"等于"幂等标记落库"， 就把工作单元放外层（先开单元，再判幂等，一起提交）。

Outbox：内存档只到"单进程能用"

var outbox = provider.GetRequiredService<InMemoryMessageOutbox>();   // 具体类型也登记了，为了取单元

var unit = outbox.CreateWorkUnit();
await outbox.EnqueueAsync(unit, envelope, payload, ct);              // 攒在单元里
await unit.CommitAsync(ct);                                          // 一次性放出去

"要不要自己写循环"这一条在 EF 档不存在（那边中继是自带的）。所以内存档的合理用处是 用例与单进程旁路，生产路径请直接上 EF 档或自己实现 IMessageOutbox。

Saga 存储：内存档

services.AddSingleton<ISagaStore>(new InMemorySagaStore());           // 时钟可注入
services.AddSingleton<ISagaStore>(new InMemorySagaStore(fakeTimeProvider));   // 用例把"租约过期"推到眼前

什么时候必须离开本包