我开始学习Actor模型(使用Akka.net),并计划在当前项目中使用它.我当前的任务是使用IFilter从不同文件中提取文本. IFilter是一组具有本机代码的COM服务器.有时它可能会挂起或处理过程过长.在这种情况下,我需要中止对问题文件的处理,并继续处理队列中的下一个文件.但是我需要杀死整
我想使用Akka.net TestKit编写单元测试,但是我有一个问题.我有一个SubscriptionService类,负责将消息传输到选定的参与者. public class SubscriptionService : ReceiveActor { private readonly ActorSelection service1; private readonly ActorSelection service2;
我的测试解决方案中有3个项目： > f#类库(我们将其命名为F#Lib), > f#控制台应用程序(将其命名为F#Console),然后> c#控制台应用程序(C#Console). 在类库中,我定义了akka.net actor： namespace Just.Test.Project open Akka.Actor open Akka.FSharp open Akka.Configuration module
我有一个分布式的演员系统,一些在Windows上,一些在Linux机器上.有时一个演员可能需要连接其他演员并进行一些沟通.当然,有些情况下,其中一个在Windows上,另一个在Linux系统上. 演员通过ActorSelection相互连接.问题是,当Windows演员试图与Linux通信时,一切正常.但是当Linux actor发
大多数文档都指的是使用ReceiveActor,然后使用Receive()等方法.但是,某些文档指的是继承自TypedActor,然后使用IHandle< MyMessageType>等接口. 使用TypedActor接口是安全的[如,最佳实践/不弃用]还是我应该只使用ReceiveActor？ (官方文件似乎不清楚这个问题)解决方法:TypedActor将在
Wiki在描述如何配置记录器方面含糊不清.我正在使用 var config = ConfigurationFactory.ParseString(@" akka { loggers = [""Akka.NLog.Event.NLog.NLogLogger,Akka.NLog""] stdout-loglevel = INFO loglevel = INFO log-config-on
