Akka.NET Persistence单元测试问题：PersistAll/PersistAllAsync未执行

你猜的没错，这个问题确实和TestKit默认使用的CallingThreadDispatcher直接相关。PersistAll系列方法的内部处理逻辑和Persist不一样——Persist是单条事件的持久化，而PersistAll需要批量处理，它的回调触发依赖于Akka的调度器完成异步批量操作，但CallingThreadDispatcher是同步执行的，会阻塞某些异步流程的完成信号传递，导致回调永远得不到执行。

核心解决方案：给PersistentActor指定专用调度器 #

TestKit默认会给测试中的Actor绑定CallingThreadDispatcher，但你可以在创建Actor时显式指定一个非同步阻塞的调度器，比如默认的Dispatcher.DefaultDispatcherId，或者专门的调度器配置。

步骤1：修改Actor的创建方式 #

在测试代码中，创建你的PersistentActor时，通过Props指定调度器：

var persistentActor = ActorOfAsTestActorRef<MyPersistentActor>(
    Props.Create<MyPersistentActor>()
        .WithDispatcher(Dispatcher.DefaultDispatcherId),
    "test-persistent-actor"
);

步骤2：用TestKit工具等待回调完成 #

改用异步调度器后，Actor的操作会在后台线程执行，你需要用TestKit的断言工具等待回调触发的信号（比如在回调里给TestActor发一条测试消息）。

下面是完整的测试示例：

[Test]
public async Task PersistAll_Should_Fire_Callback()
{
    // 创建带专用调度器的PersistentActor
    var persistentActor = ActorOfAsTestActorRef<MyPersistentActor>(
        Props.Create<MyPersistentActor>()
            .WithDispatcher(Dispatcher.DefaultDispatcherId),
        "test-actor"
    );

    // 发送触发PersistAll的命令
    var events = new List<object> { new ItemCreated(1), new ItemUpdated(1, "new name"), new ItemDeleted(1) };
    persistentActor.Tell(new BatchProcessEvents(events));

    // 等待回调完成的信号（假设回调里会给TestActor发CallbackDone消息）
    ExpectMsg<CallbackDone>(TimeSpan.FromSeconds(3));
}

// 你的PersistentActor实现示例
public class MyPersistentActor : ReceivePersistentActor
{
    public override string PersistenceId => "test-persistence-id";

    public MyPersistentActor()
    {
        Receive<BatchProcessEvents>(cmd =>
        {
            PersistAll(cmd.Events, () =>
            {
                // 回调完成后通知TestActor
                Context.System.TestActor.Tell(new CallbackDone());
            });
        });
    }
}

// 测试用的消息类
public class BatchProcessEvents
{
    public List<object> Events { get; }
    public BatchProcessEvents(List<object> events) => Events = events;
}

public class CallbackDone { }
public record ItemCreated(int Id);
public record ItemUpdated(int Id, string Name);
public record ItemDeleted(int Id);

为什么Persist能正常工作？ #

Persist的单条事件持久化逻辑更简单，CallingThreadDispatcher可以同步处理完单条事件的持久化流程，直接触发回调；而PersistAll需要处理批量事件的异步协调，CallingThreadDispatcher的同步模型无法正确传递批量完成的信号，导致回调被挂起。

额外注意点 #

• 不建议全局修改测试配置的默认调度器，因为其他测试可能依赖CallingThreadDispatcher的同步特性，按需给需要测试PersistAll的Actor指定调度器即可。
• 对于PersistAllAsync，解决方案完全一致，只需要把示例中的PersistAll换成PersistAllAsync，回调的等待逻辑保持不变。

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