后端微服务【免费下载链接】akka.netCanonical actor model implementation for .NET with local distributed actors in C# and F#.项目地址https://gitcode.com/gh_mirrors/ak/akka.net点击查看免费下载Akka.NET 的Akka.TestKit包内置了一套完整的默认 HOCON 配置随程序集嵌入的Reference.conf涵盖日志监听器、各类断言/等待超时、时间因子缩放以及专用的 CallingThreadDispatcher同时它还提供一份可选的TestScheduler.conf用于将 ActorSystem 的调度器替换为可人为推进虚拟时间的TestScheduler。读完本文你将能够逐项理解并自定义 TestKit 的全部配置参数掌握如何为测试换用 TestEventListener、启用虚拟化调度器以及这些参数在源码中如何被读取和应用。一、TestKit 配置的两个来源Akka.TestKit的配置以程序集内嵌资源的方式发布共两份配置文件相对仓库路径用途Akka.TestKit.Internal.Reference.confsrc/core/Akka.TestKit/Internal/Reference.conf基础 TestKit 默认配置akka根节点Akka.TestKit.Configs.TestScheduler.confsrc/core/Akka.TestKit/Configs/TestScheduler.conf启用虚拟化TestScheduler的替换配置这两份资源在 TestConfigs.cs 中被正式暴露给开发者使用public static class TestConfigs { // 默认 TestKit 配置随 TestKitBase 加载内嵌资源 public static Config DefaultConfig ConfigurationFactory.FromResourceTestKitBase(Akka.TestKit.Internal.Reference.conf); // 需要确定性控制 ActorSystem 调度器的测试所用配置 public static Config TestSchedulerConfig ConfigurationFactory.FromResourceTestKitBase(Akka.TestKit.Configs.TestScheduler.conf); }当你在测试中不显式传入 ActorSystem 时TestKitBase的构造函数会默认使用DefaultConfig创建系统见 TestKitBase.cs如果测试需要精确的时间控制则应传入TestSchedulerConfig或手动合并对应的 HOCON 片段。二、Reference.conf 全文与逐项解析Akka.TestKit的默认配置完整内容如下即akka.testkit.md中引用的那份内嵌配置akka { # 将默认值 [Akka.Event.DefaultLogger] 替换为 TestEventListener。 # 该 logger 的行为与 DefaultLogger 完全一致但支持 EventFilter 过滤 # 若未指定任何过滤器则与 DefaultLogger 一样向 StdOut 输出日志。 loggers [Akka.TestKit.TestEventListener, Akka.TestKit] test { # 测试期间超时时间的缩放因子例如用于应对共享构建系统负载 timefactor 1.0 # EventFilter.intercept 在代码块执行完毕后等待全部所需消息接收完成的时间 filter-leeway 3s # expectMsg 及同类方法在 within() 块之外使用的默认等待时长 single-expect-default 3s # expectNoMsg 的默认等待时长 expect-no-message-default 3s # 由 DefaultTimeout trait 隐式添加的超时用于 Ask 模式 default-timeout 5s # TestKit 启动自身所需的时间若并行运行大量测试请调大此值 startup-timeout 5s calling-thread-dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 } test-actor.dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 } } # 关闭批处理以避免 Akka.Remote 测试不稳定这类测试消息频率很低。 # 该键必须位于 akka.remote 之下而非 akka.test 之下 # DotNettyTransportSettings 是相对 akka.remote.dot-netty.tcp 读取 config.GetConfig(batching) 的。 remote.dot-netty.tcp.batching.enabled false }2.1akka.loggers换上 TestEventListener默认配置将系统日志器从Akka.Event.DefaultLogger替换为Akka.TestKit.TestEventListener。这一替换是 EventFilter 机制能够工作的前提TestEventListener继承自DefaultLogger但在其Receive中维护了一组IEventFilter并在收到LogEvent时先经过ShouldFilter判断命中过滤器的日志不再输出见 TestEventListener.cs。它还额外订阅了Mute、Unmute、DeadLetter与UnhandledMessage事件因此能配合EventFilter.DeadLetter()断言死信。注意若你自己的 HOCON 覆盖了akka.loggers例如为了接入 Serilog 等第三方日志器TestEventListener 将被替换EventFilter 断言也将随之失效。2.2akka.test.timefactor全局超时缩放因子这是 TestKit 中最具全局影响力的参数默认1.0。它的作用是把测试中所有最大等待时长统一放大从而让在本地快速机器上通过、但在高负载 CI 上偶发失败的测试变得稳定。其实际语义是所有最大时长在内部都乘以该因子你也可以通过TestKitBase.Dilated(TimeSpan)主动用同一因子缩放自定义时长。源码中该值由 TestKitSettings.cs 读取并校验TestTimeFactor config.GetDouble(akka.test.timefactor, 0); if (TestTimeFactor 0) throw new ConfigurationException($Expected a positive value for akka.test.timefactor but found {TestTimeFactor});即该值必须是正数否则启动测试系统时直接抛出ConfigurationException。缩放计算发生在 TestKitBase.cs 的Dilated方法中public TimeSpan Dilated([AutoDilate] TimeSpan duration) { if (duration TimeSpan.Zero) throw new ArgumentException(Must not be negative, nameof(duration)); return new TimeSpan((long)(duration.Ticks * _testState.TestKitSettings.TestTimeFactor)); }在 CI 上把timefactor设为3.0或更高是解决本地通过、CI 抖动失败的常见手段。2.3 四组等待/超时参数配置键默认值作用对象源码引用akka.test.single-expect-default3sexpectMsg及同类方法在within()块外的默认等待时长由GetTimeoutOrDefault返回见 TestKitBase.csakka.test.expect-no-message-default3sexpectNoMsg默认等待时长akka.test.default-timeout5sAsk 模式DefaultTimeout使用的隐式超时akka.test.startup-timeout5sTestKit 自身启动等待时长并行测试多时需调大这四个值在TestKitSettings中全部通过GetTimeSpan(...)读取且allowInfinite:false也就是说配置中的负值或无限大会被拒绝读取结果对外暴露为DefaultTimeout、SingleExpectDefault、ExpectNoMessageDefault、TestKitStartupTimeout属性。2.4akka.test.filter-leewayEventFilter 的收尾窗口filter-leeway默认3s是EventFilter.intercept系列方法ExpectOne/Expect在传入的代码块执行完毕后继续等待剩余日志事件到达的时间。在 IEventFilterApplier.cs 的接口文档中明确注明未显式传超时参数时该等待时间取自akka.test.filter-leeway即TestKitSettings.TestEventFilterLeeway。事件比预期多、或超时未收齐都会导致断言抛异常失败。2.5 两组 CallingThreadDispatchercalling-thread-dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 } test-actor.dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 }这两段分别定义akka.test.calling-thread-dispatcher与akka.test.test-actor.dispatcher两个调度器 ID。前者是给测试 Actor 显式指定的调度器Id akka.test.calling-thread-dispatcher见 CallingThreadDispatcher.cs后者被TestKitBase内部常量TestActorDispatcherId akka.test.test-actor.dispatcher用作 TestActor 的默认调度器。两者都指向CallingThreadDispatcherConfigurator其核心行为是在前台线程上同步执行 Actor 消息处理执行时临时清空SynchronizationContext以保证 async 处理器中的 continuation 正确回到ActorTaskScheduler。throughput 2147483647表示不设吞吐上限一次调度即可取完队列中的所有消息。2.6akka.remote.dot-netty.tcp.batching.enabled false这是 Reference.conf 中唯一位于akka.test之外的键。其注释解释得很清楚为了让 Akka.Remote 的测试消息频率低不因批处理而产生抖动需要关闭 DotNetty TCP 传输的批处理且该键必须放在akka.remote.dot-netty.tcp之下因为DotNettyTransportSettings是相对该路径读取batching配置的。三、TestScheduler.conf把真实时间换成虚拟时间对于定时器、超时重试、ScheduleTellOnce/ScheduleTellRepeatedly等时间相关逻辑的测试真实调度器会引入不可控的时钟等待。TestScheduler.conf提供了替换方案akka { loggers [Akka.TestKit.TestEventListener, Akka.TestKit] scheduler { implementation Akka.TestKit.TestScheduler, Akka.TestKit } test { timefactor 1.0 filter-leeway 3s single-expect-default 3s default-timeout 5s calling-thread-dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 } test-actor.dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 } } }关键差异只有一行akka.scheduler.implementation Akka.TestKit.TestScheduler, Akka.TestKit它将 ActorSystem 的IScheduler替换为TestScheduler。TestScheduler的实现要点见 TestScheduler.cs虚拟时钟内部维护_now初始化为当前 UTC 时间其Now属性返回的是虚拟时间MonotonicClock仍是进程真实时钟不受Advance影响。推进时间Advance(TimeSpan offset)将虚拟时间前移并按到期时间桶ConcurrentDictionarylong, ConcurrentQueueScheduledItem依序派发到期的消息/执行到期的 Action重复任务会从当前虚拟时间重新调度。AdvanceTo(DateTimeOffset when)则推进到指定时刻且禁止时光倒流when _now时抛InvalidOperationException(You cant reverse time...)。取消支持带ICancelable的任务在派发前检查IsCancellationRequested已取消的不会被投递。适用面ScheduleTellOnce、ScheduleTellRepeatedly、ScheduleOnce、ScheduleRepeatedly均被实现个别IRunnable重载因测试场景用不到而直接抛NotImplementedException。典型用法是测试中调用scheduler.Advance(TimeSpan.FromSeconds(5))一步快进5 秒然后立即断言因定时器触达而应产生的消息全程零真实等待、结果完全确定。四、在测试中如何应用这些配置4.1 继承默认配置不传任何配置时TestKit 自动使用内嵌的 Reference.conf// xunit 示例默认配置自带 TestEventListener 与全部默认超时 public class MyActorSpec : TestKit { [Fact] public void Should_receive_reply() { var actor Sys.ActorOf(Props.Create(() new MyActor())); actor.Tell(ping); ExpectMsg(pong); // 默认等待 3ssingle-expect-default } }4.2 覆盖或合并自定义配置把TestKitSettings与 TestKitBase 构造函数配合即可在创建系统时传入自定义 HOCON。例如给 CI 环境放大超时、缩短 EventFilter 收尾窗口akka.test { timefactor 3.0 filter-leeway 1s startup-timeout 10s }var config ConfigurationFactory.ParseString( akka.test.timefactor 3.0 akka.test.startup-timeout 10s ).WithFallback(TestConfigs.DefaultConfig); using var system ActorSystem.Create(spec-system, config);注意顺序自定义配置在前、TestConfigs.DefaultConfig作为 fallback这样既能覆盖所需参数又不会丢失 TestEventListener、CallingThreadDispatcher 等 TestKit 必需默认项。4.3 启用虚拟化 TestSchedulerusing var system ActorSystem.Create(timed-spec, TestConfigs.TestSchedulerConfig); var scheduler (TestScheduler)system.Scheduler; scheduler.ScheduleTellOnce(TimeSpan.FromSeconds(30), receiver, boom, ActorRefs.NoSender); scheduler.Advance(TimeSpan.FromSeconds(30)); // 虚拟时钟直接推进 30 秒 // 此时 receiver 应已收到 boom无需真实等待若使用TestKit/TestKitBase子类可将TestSchedulerConfig传入构造函数的config参数。4.4 EventFilter 与 filter-leeway 的联动换上 TestEventListener 后即可使用EventFilter工厂定义见 EventFilterFactory.cs。仓库测试 DeadLettersEventFilterTests.cs 展示了多过滤器串联与计数断言await EventFilter.DeadLetterint() .And.DeadLetterdouble() .ExpectAsync(2, () { /* 产生两条死信 */ });未显式传超时时Expect/ExpectOne的收尾等待就由akka.test.filter-leeway控制若日志事件到达偏慢可适当调大该值。五、FAQ 与调优建议为什么改了akka.test.timefactor后expectMsg的等待还是没变确认你传入 ActorSystem 的配置确实覆盖到了akka.test.timefactor并且未显式给expectMsg传超时参数expectMsg在within()块外使用single-expect-default该值本身也会被Dilated缩放。EventFilter 断言总超时检查akka.loggers是否仍为TestEventListenerfilter-leeway是否过小以及日志事件是否是异步产生、需要更多收尾时间。并行跑大量测试时 TestKit 启动失败/超时调大akka.test.startup-timeout。时间相关测试又慢又飘换成TestSchedulerConfig用Advance/AdvanceTo精确控制虚拟时钟。Remote 相关测试出现偶发死信/抖动保持 Reference.conf 中akka.remote.dot-netty.tcp.batching.enabled false的默认关闭状态不要轻易在自定义配置中重新打开。六、小结Akka.TestKit的配置体系非常精简但影响深远TestEventListener是 EventFilter 断言的基石timefactor是应对 CI 负载抖动的全局旋钮四组超时参数分别控制断言、Ask 与系统启动的等待行为两套 CallingThreadDispatcher 保证测试 Actor 在前台线程上同步执行而TestScheduler.conf则通过一行scheduler.implementation将真实时钟替换为可编程的虚拟时钟让时间敏感测试变得快速且确定。两份配置的实际读取与校验逻辑均可分别追溯至 TestKitSettings.cs、TestConfigs.cs、TestScheduler.cs 与 TestEventListener.cs在自定义测试配置时建议始终以TestConfigs.DefaultConfig或TestConfigs.TestSchedulerConfig作为 fallback避免遗漏必需默认项。赞分享后端微服务【免费下载链接】akka.netCanonical actor model implementation for .NET with local distributed actors in C# and F#.项目地址https://gitcode.com/gh_mirrors/ak/akka.net点击查看免费下载相关推荐Akka.NET配置指南HOCON与程序化配置详解Akka.NET配置指南HOCON与程序化配置详解 概述 Akka.NET作为一款强大的分布式Actor模型框架其配置系统是框架灵活性的重要体现。本文将深入后端微服务NetBox 虚拟化模型详解VirtualMachineType 虚拟机器类型虚拟机默认规格分类NetBox 虚拟化模型详解VirtualMachineType 虚拟机器类型虚拟机默认规格分类 VirtualMachineType虚拟机器类型是后端网络数据建模Akka.NET 配置完全指南HOCON 与 Setup 编程式配置实战Akka.NET 配置完全指南HOCON 与 Setup 编程式配置实战 Akka.NET 的配置体系由两条路径构成以 HOCON https://link后端微服务上一篇如何免费获得Windows透明任务栏TranslucentTB完整使用指南下一篇3分钟掌握Windows任务栏美化TranslucentTB终极透明效果指南创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
后端微服务【免费下载链接】akka.netCanonical actor model implementation for .NET with local distributed actors in C# and F#.项目地址https://gitcode.com/gh_mirrors/ak/akka.net点击查看免费下载Akka.NET 的Akka.TestKit包内置了一套完整的默认 HOCON 配置随程序集嵌入的Reference.conf涵盖日志监听器、各类断言/等待超时、时间因子缩放以及专用的 CallingThreadDispatcher同时它还提供一份可选的TestScheduler.conf用于将 ActorSystem 的调度器替换为可人为推进虚拟时间的TestScheduler。读完本文你将能够逐项理解并自定义 TestKit 的全部配置参数掌握如何为测试换用 TestEventListener、启用虚拟化调度器以及这些参数在源码中如何被读取和应用。一、TestKit 配置的两个来源Akka.TestKit的配置以程序集内嵌资源的方式发布共两份配置文件相对仓库路径用途Akka.TestKit.Internal.Reference.confsrc/core/Akka.TestKit/Internal/Reference.conf基础 TestKit 默认配置akka根节点Akka.TestKit.Configs.TestScheduler.confsrc/core/Akka.TestKit/Configs/TestScheduler.conf启用虚拟化TestScheduler的替换配置这两份资源在 TestConfigs.cs 中被正式暴露给开发者使用public static class TestConfigs { // 默认 TestKit 配置随 TestKitBase 加载内嵌资源 public static Config DefaultConfig ConfigurationFactory.FromResourceTestKitBase(Akka.TestKit.Internal.Reference.conf); // 需要确定性控制 ActorSystem 调度器的测试所用配置 public static Config TestSchedulerConfig ConfigurationFactory.FromResourceTestKitBase(Akka.TestKit.Configs.TestScheduler.conf); }当你在测试中不显式传入 ActorSystem 时TestKitBase的构造函数会默认使用DefaultConfig创建系统见 TestKitBase.cs如果测试需要精确的时间控制则应传入TestSchedulerConfig或手动合并对应的 HOCON 片段。二、Reference.conf 全文与逐项解析Akka.TestKit的默认配置完整内容如下即akka.testkit.md中引用的那份内嵌配置akka { # 将默认值 [Akka.Event.DefaultLogger] 替换为 TestEventListener。 # 该 logger 的行为与 DefaultLogger 完全一致但支持 EventFilter 过滤 # 若未指定任何过滤器则与 DefaultLogger 一样向 StdOut 输出日志。 loggers [Akka.TestKit.TestEventListener, Akka.TestKit] test { # 测试期间超时时间的缩放因子例如用于应对共享构建系统负载 timefactor 1.0 # EventFilter.intercept 在代码块执行完毕后等待全部所需消息接收完成的时间 filter-leeway 3s # expectMsg 及同类方法在 within() 块之外使用的默认等待时长 single-expect-default 3s # expectNoMsg 的默认等待时长 expect-no-message-default 3s # 由 DefaultTimeout trait 隐式添加的超时用于 Ask 模式 default-timeout 5s # TestKit 启动自身所需的时间若并行运行大量测试请调大此值 startup-timeout 5s calling-thread-dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 } test-actor.dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 } } # 关闭批处理以避免 Akka.Remote 测试不稳定这类测试消息频率很低。 # 该键必须位于 akka.remote 之下而非 akka.test 之下 # DotNettyTransportSettings 是相对 akka.remote.dot-netty.tcp 读取 config.GetConfig(batching) 的。 remote.dot-netty.tcp.batching.enabled false }2.1akka.loggers换上 TestEventListener默认配置将系统日志器从Akka.Event.DefaultLogger替换为Akka.TestKit.TestEventListener。这一替换是 EventFilter 机制能够工作的前提TestEventListener继承自DefaultLogger但在其Receive中维护了一组IEventFilter并在收到LogEvent时先经过ShouldFilter判断命中过滤器的日志不再输出见 TestEventListener.cs。它还额外订阅了Mute、Unmute、DeadLetter与UnhandledMessage事件因此能配合EventFilter.DeadLetter()断言死信。注意若你自己的 HOCON 覆盖了akka.loggers例如为了接入 Serilog 等第三方日志器TestEventListener 将被替换EventFilter 断言也将随之失效。2.2akka.test.timefactor全局超时缩放因子这是 TestKit 中最具全局影响力的参数默认1.0。它的作用是把测试中所有最大等待时长统一放大从而让在本地快速机器上通过、但在高负载 CI 上偶发失败的测试变得稳定。其实际语义是所有最大时长在内部都乘以该因子你也可以通过TestKitBase.Dilated(TimeSpan)主动用同一因子缩放自定义时长。源码中该值由 TestKitSettings.cs 读取并校验TestTimeFactor config.GetDouble(akka.test.timefactor, 0); if (TestTimeFactor 0) throw new ConfigurationException($Expected a positive value for akka.test.timefactor but found {TestTimeFactor});即该值必须是正数否则启动测试系统时直接抛出ConfigurationException。缩放计算发生在 TestKitBase.cs 的Dilated方法中public TimeSpan Dilated([AutoDilate] TimeSpan duration) { if (duration TimeSpan.Zero) throw new ArgumentException(Must not be negative, nameof(duration)); return new TimeSpan((long)(duration.Ticks * _testState.TestKitSettings.TestTimeFactor)); }在 CI 上把timefactor设为3.0或更高是解决本地通过、CI 抖动失败的常见手段。2.3 四组等待/超时参数配置键默认值作用对象源码引用akka.test.single-expect-default3sexpectMsg及同类方法在within()块外的默认等待时长由GetTimeoutOrDefault返回见 TestKitBase.csakka.test.expect-no-message-default3sexpectNoMsg默认等待时长akka.test.default-timeout5sAsk 模式DefaultTimeout使用的隐式超时akka.test.startup-timeout5sTestKit 自身启动等待时长并行测试多时需调大这四个值在TestKitSettings中全部通过GetTimeSpan(...)读取且allowInfinite:false也就是说配置中的负值或无限大会被拒绝读取结果对外暴露为DefaultTimeout、SingleExpectDefault、ExpectNoMessageDefault、TestKitStartupTimeout属性。2.4akka.test.filter-leewayEventFilter 的收尾窗口filter-leeway默认3s是EventFilter.intercept系列方法ExpectOne/Expect在传入的代码块执行完毕后继续等待剩余日志事件到达的时间。在 IEventFilterApplier.cs 的接口文档中明确注明未显式传超时参数时该等待时间取自akka.test.filter-leeway即TestKitSettings.TestEventFilterLeeway。事件比预期多、或超时未收齐都会导致断言抛异常失败。2.5 两组 CallingThreadDispatchercalling-thread-dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 } test-actor.dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 }这两段分别定义akka.test.calling-thread-dispatcher与akka.test.test-actor.dispatcher两个调度器 ID。前者是给测试 Actor 显式指定的调度器Id akka.test.calling-thread-dispatcher见 CallingThreadDispatcher.cs后者被TestKitBase内部常量TestActorDispatcherId akka.test.test-actor.dispatcher用作 TestActor 的默认调度器。两者都指向CallingThreadDispatcherConfigurator其核心行为是在前台线程上同步执行 Actor 消息处理执行时临时清空SynchronizationContext以保证 async 处理器中的 continuation 正确回到ActorTaskScheduler。throughput 2147483647表示不设吞吐上限一次调度即可取完队列中的所有消息。2.6akka.remote.dot-netty.tcp.batching.enabled false这是 Reference.conf 中唯一位于akka.test之外的键。其注释解释得很清楚为了让 Akka.Remote 的测试消息频率低不因批处理而产生抖动需要关闭 DotNetty TCP 传输的批处理且该键必须放在akka.remote.dot-netty.tcp之下因为DotNettyTransportSettings是相对该路径读取batching配置的。三、TestScheduler.conf把真实时间换成虚拟时间对于定时器、超时重试、ScheduleTellOnce/ScheduleTellRepeatedly等时间相关逻辑的测试真实调度器会引入不可控的时钟等待。TestScheduler.conf提供了替换方案akka { loggers [Akka.TestKit.TestEventListener, Akka.TestKit] scheduler { implementation Akka.TestKit.TestScheduler, Akka.TestKit } test { timefactor 1.0 filter-leeway 3s single-expect-default 3s default-timeout 5s calling-thread-dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 } test-actor.dispatcher { type Akka.TestKit.CallingThreadDispatcherConfigurator, Akka.TestKit throughput 2147483647 } } }关键差异只有一行akka.scheduler.implementation Akka.TestKit.TestScheduler, Akka.TestKit它将 ActorSystem 的IScheduler替换为TestScheduler。TestScheduler的实现要点见 TestScheduler.cs虚拟时钟内部维护_now初始化为当前 UTC 时间其Now属性返回的是虚拟时间MonotonicClock仍是进程真实时钟不受Advance影响。推进时间Advance(TimeSpan offset)将虚拟时间前移并按到期时间桶ConcurrentDictionarylong, ConcurrentQueueScheduledItem依序派发到期的消息/执行到期的 Action重复任务会从当前虚拟时间重新调度。AdvanceTo(DateTimeOffset when)则推进到指定时刻且禁止时光倒流when _now时抛InvalidOperationException(You cant reverse time...)。取消支持带ICancelable的任务在派发前检查IsCancellationRequested已取消的不会被投递。适用面ScheduleTellOnce、ScheduleTellRepeatedly、ScheduleOnce、ScheduleRepeatedly均被实现个别IRunnable重载因测试场景用不到而直接抛NotImplementedException。典型用法是测试中调用scheduler.Advance(TimeSpan.FromSeconds(5))一步快进5 秒然后立即断言因定时器触达而应产生的消息全程零真实等待、结果完全确定。四、在测试中如何应用这些配置4.1 继承默认配置不传任何配置时TestKit 自动使用内嵌的 Reference.conf// xunit 示例默认配置自带 TestEventListener 与全部默认超时 public class MyActorSpec : TestKit { [Fact] public void Should_receive_reply() { var actor Sys.ActorOf(Props.Create(() new MyActor())); actor.Tell(ping); ExpectMsg(pong); // 默认等待 3ssingle-expect-default } }4.2 覆盖或合并自定义配置把TestKitSettings与 TestKitBase 构造函数配合即可在创建系统时传入自定义 HOCON。例如给 CI 环境放大超时、缩短 EventFilter 收尾窗口akka.test { timefactor 3.0 filter-leeway 1s startup-timeout 10s }var config ConfigurationFactory.ParseString( akka.test.timefactor 3.0 akka.test.startup-timeout 10s ).WithFallback(TestConfigs.DefaultConfig); using var system ActorSystem.Create(spec-system, config);注意顺序自定义配置在前、TestConfigs.DefaultConfig作为 fallback这样既能覆盖所需参数又不会丢失 TestEventListener、CallingThreadDispatcher 等 TestKit 必需默认项。4.3 启用虚拟化 TestSchedulerusing var system ActorSystem.Create(timed-spec, TestConfigs.TestSchedulerConfig); var scheduler (TestScheduler)system.Scheduler; scheduler.ScheduleTellOnce(TimeSpan.FromSeconds(30), receiver, boom, ActorRefs.NoSender); scheduler.Advance(TimeSpan.FromSeconds(30)); // 虚拟时钟直接推进 30 秒 // 此时 receiver 应已收到 boom无需真实等待若使用TestKit/TestKitBase子类可将TestSchedulerConfig传入构造函数的config参数。4.4 EventFilter 与 filter-leeway 的联动换上 TestEventListener 后即可使用EventFilter工厂定义见 EventFilterFactory.cs。仓库测试 DeadLettersEventFilterTests.cs 展示了多过滤器串联与计数断言await EventFilter.DeadLetterint() .And.DeadLetterdouble() .ExpectAsync(2, () { /* 产生两条死信 */ });未显式传超时时Expect/ExpectOne的收尾等待就由akka.test.filter-leeway控制若日志事件到达偏慢可适当调大该值。五、FAQ 与调优建议为什么改了akka.test.timefactor后expectMsg的等待还是没变确认你传入 ActorSystem 的配置确实覆盖到了akka.test.timefactor并且未显式给expectMsg传超时参数expectMsg在within()块外使用single-expect-default该值本身也会被Dilated缩放。EventFilter 断言总超时检查akka.loggers是否仍为TestEventListenerfilter-leeway是否过小以及日志事件是否是异步产生、需要更多收尾时间。并行跑大量测试时 TestKit 启动失败/超时调大akka.test.startup-timeout。时间相关测试又慢又飘换成TestSchedulerConfig用Advance/AdvanceTo精确控制虚拟时钟。Remote 相关测试出现偶发死信/抖动保持 Reference.conf 中akka.remote.dot-netty.tcp.batching.enabled false的默认关闭状态不要轻易在自定义配置中重新打开。六、小结Akka.TestKit的配置体系非常精简但影响深远TestEventListener是 EventFilter 断言的基石timefactor是应对 CI 负载抖动的全局旋钮四组超时参数分别控制断言、Ask 与系统启动的等待行为两套 CallingThreadDispatcher 保证测试 Actor 在前台线程上同步执行而TestScheduler.conf则通过一行scheduler.implementation将真实时钟替换为可编程的虚拟时钟让时间敏感测试变得快速且确定。两份配置的实际读取与校验逻辑均可分别追溯至 TestKitSettings.cs、TestConfigs.cs、TestScheduler.cs 与 TestEventListener.cs在自定义测试配置时建议始终以TestConfigs.DefaultConfig或TestConfigs.TestSchedulerConfig作为 fallback避免遗漏必需默认项。赞分享后端微服务【免费下载链接】akka.netCanonical actor model implementation for .NET with local distributed actors in C# and F#.项目地址https://gitcode.com/gh_mirrors/ak/akka.net点击查看免费下载相关推荐Akka.NET配置指南HOCON与程序化配置详解Akka.NET配置指南HOCON与程序化配置详解 概述 Akka.NET作为一款强大的分布式Actor模型框架其配置系统是框架灵活性的重要体现。本文将深入后端微服务NetBox 虚拟化模型详解VirtualMachineType 虚拟机器类型虚拟机默认规格分类NetBox 虚拟化模型详解VirtualMachineType 虚拟机器类型虚拟机默认规格分类 VirtualMachineType虚拟机器类型是后端网络数据建模Akka.NET 配置完全指南HOCON 与 Setup 编程式配置实战Akka.NET 配置完全指南HOCON 与 Setup 编程式配置实战 Akka.NET 的配置体系由两条路径构成以 HOCON https://link后端微服务上一篇如何免费获得Windows透明任务栏TranslucentTB完整使用指南下一篇3分钟掌握Windows任务栏美化TranslucentTB终极透明效果指南创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
