Durable Entities计数器实现订单跟踪号生成异常问题求助

DevOps 小满

2026-9-27

问题根因

1. 异步操作时序错误

SignalEntityAsync是单向异步通知方法，仅负责将操作消息写入实体队列，不会等待实体实际执行操作就直接返回。你在发送Add操作后立刻读取实体状态，此时操作大概率还未被执行：

首次调用时实体尚未初始化，EntityExists返回false，直接返回空字符串，对应你首次调用空响应的问题。
冷启动后实体需要从持久化存储加载状态，队列中的操作会有延迟，读取到的是未更新的旧状态，对应前几次请求返回旧跟踪号的问题。

2. 实体状态调用方式错误

ReadEntityStateAsync返回的是调用时刻的实体状态快照，是本地内存中的副本。你直接调用副本的GetNextTrackingNumber方法不会触发实体层面的操作，也不会同步到持久化存储，拿到的永远是读取快照时刻的旧值。

3. 潜在空引用风险

实体类标记了[JsonObject(MemberSerialization.OptIn)]，只有加了JsonProperty的属性会被持久化，_random字段不会被序列化。实体从存储反序列化时_random会被初始化为null，调用Reset方法时会抛出空引用异常。

修复方案

步骤1：合并原子操作（避免并发问题）

将计数+1和生成跟踪号的逻辑合并为单个实体方法，保证原子性，避免两次调用间隙插入其他请求导致的计数异常。
先更新ICounterEntity接口：

public interface ICounterEntity
{
    [Deterministic]
    public void Add(int amount);

    [Deterministic]
    public Task<string> GetNextTrackingNumber();

    [Deterministic]
    public Task Reset();

    // 新增原子操作方法
    [Deterministic]
    public Task<string> IncrementAndGetTrackingNumber();
}

然后在CounterEntity中实现该方法：

public Task<string> IncrementAndGetTrackingNumber()
{
    Value += 1;
    var thisTrackingNumber = string.Concat(Prefix, "-", $"{Value:00000000}");
    return Task.FromResult(thisTrackingNumber);
}

步骤2：修复_random空引用问题

将_random改为懒加载模式，保证实体反序列化后也能正常使用：

// 替换原_random字段定义
private readonly Lazy<Random> _lazyRandom = new Lazy<Random>(() => new Random());
private Random _random => _lazyRandom.Value;

步骤3：修改入口函数逻辑

用实体代理调用替代单向通知和快照读取，等待实体操作执行完成后直接获取返回结果：

public static class Counter
{
    [FunctionName("GetTrackingNumber")]
    public static async Task<IActionResult> Get(
        [HttpTrigger(AuthorizationLevel.Function, "get", Route = "GetTrackingNumber")] HttpRequest req,
        [DurableClient] IDurableEntityClient client,
        ILogger log
        )
    {
        var entityId = new EntityId(nameof(CounterEntity), "myCounter");
        // 创建实体代理，方法调用会等待实体执行完成并返回最新结果
        var entityProxy = client.CreateEntityProxy<ICounterEntity>(entityId);
        string trackingNumber = await entityProxy.IncrementAndGetTrackingNumber();
        return new OkObjectResult(trackingNumber);            
    }
}

修改后首次调用会自动初始化实体返回正确跟踪号，冷启动时会等待实体加载状态并执行操作后再返回结果，不会再出现返回旧值的问题。

内容的提问来源于stack exchange，提问作者FunkiNATEr