使用guice注入与actor抛出空指针
Schedular part： private ActorRef myActor = Akka.system（）。actorOf（ new Props（Retreiver.class））; @Override public void onStart（应用程序应用程序）{ log.info（“启动schedular .....！”）; Akka.system（） .sc
..
akka相关内容
如何使用参数化actor在akka中创建路由器？
我想在Scala中使用广播路由器，如果我不误认为它应该看起来像这样： val system = ActorSystem（“My beautiful system”） val workerRouter = system.actorOf（Props [Agent] .withRouter（BroadcastRouter（individualDefinitions.size）），name =“
..
Socket连接和ActorSystem
我有一个应用程序，使用akka，现在我想通过socket连接到它。因此，我使用类似于 scala页面的机器。 但是如果我尝试 tell ，而我有一个打开 OutputStream ，没有收到消息目标。 这是我的源代码： def main（args：Array [String]）{ val port = 1337 val conf = ConfigFactory.loa
..
演员可以在一定条件下阅读邮件吗？
我有这种情况： ActorA每30-40秒发送一次ActorB开始/停止讯息 ActorA发送要打印的ActorB字符串（总是） ActorB必须打印他收到的字符串，但前提是ActorA只发送一个开始消息 现在我想知道我是否可以做以下事情： ActorB可以从ActorA读取一个开始/停止消息，然后才能在ActorB之前读取一个开始/停止消息其他字符串消息？我想有这种情况：A
..
使用Akka 1.3的演员时，我需要照顾生产者 - 消费者的费率匹配吗？
当使用Akka 1.3时，我需要担心当生成消息的actors比生成消息的actors更快地处理时会发生什么？ 没有任何机制，在长时间运行的进程中，队列大小将增长以消耗所有可用内存。 文档说默认分派器是ExecutorBasedEventDrivenDispatcher。 这个分派器有五个队列配置： 边界LinkedBlockingQueue 无界LinkedBlockin
..
如何处理与演员爆发？
假设我有一个actor，它每秒处理 X 个请求。这是平均确定，但有时有突发和客户端发送 Y> X 每秒请求数。 假设我们在Scala和 Akka中编程什么是最佳实践/设计模式，使演员处理这些突发？有没有处理突发的代码示例？ 解决方案 只要您的机器可以处理增加的负载（即有足够的CPU），那么我建议将 Actor 使用路由器。听起来像你的例子，动态调整大小的路由器可能是最合适的，但即使是
..
控制Akka中消耗显着量内存的actor的产生
我已经使用akka的actor模型构建了一个分布式流式机学习模型。训练模型通过向Actor发送训练实例（训练数据）异步发生。对该数据的训练占用计算时间并且改变actor的状态。 目前我使用历史数据来训练模型。我想运行一组不同配置的模型，训练相同的数据，看看不同的集合度量是如何变化的。基本上这里是一个不太复杂的模拟，我用Thread.sleep（1）和数据数组表示计算时间和状态。。 i
..
Scala.2.10.1的标准lib或Akka？
我将使用 Futures 和 Promises 从 scala.concurrent 包放在Scala 2.10.1 中。我应该使用 Akka 吗？ 解决方案 Akka futures and promises were moved到Scala标准库中2.10所以没有什么区别。这不是你使用的标准scala类 - 旧的scala类不再存在，并已被替换为akka的。 使用akka act
..
Akka演员：需要一个例子来了解一些基础知识
我正在修补Akka，并需要一些建议如何实现我想到的具体。我想有一个演员，我可以发送 DownloadFile（URI，文件）消息，并下载它。由于这可以并行，我不想下载文件后文件，但有并发下载的限制。 使用Akka建模的方法是什么？其他的事情，想到的是：如果一个“工人”的演员因某种原因死亡会发生什么？如何重试下载？等等。 我知道这是一个非常巨大的问题，但我希望有人花时间回答它！谢谢！
..
AKKA如何为单个actor提供并发性？
我已读过 “Akka确保每个actor的实例都运行在自己的轻量级线程中，并且其消息一次处理一个。” 如果这是AKKA actors按顺序处理其消息的情况，那么AKKA如何为单个Actor提供并发性。 请帮助。 解决方案 Actors是计算的独立代理，每个执行严格依次，但许多actors可以并发执行。你可以查看一个Actor作为线程，它只花费正常线程的0.1％，并且还有一个
..
如何实现没有Akka的actor模型？
如何实现没有Akka的简单actors？我不需要高性能许多（非固定计数）actor实例，绿线程，IoC（生命周期，基于Props的工厂，ActorRef的），监督，背压等。只需要顺序（队列）+处理程序+状态+消息传递。 作为副作用，我实际上需要小的基于actor的管道（使用递归链接）+一些parallell演员来优化 DSP 算法计算。它将在库内没有传递依赖，所以我不想（而不能作为一个jar
..
阻止Akka Actors中的呼叫
作为一个新手，我想了解演员如何工作。并且，从文档，我想我明白，演员是在同步模式下执行的对象，并且actor执行可以包含阻塞/同步方法调用，例如。 db请求 但是，我不明白的是，如果你写一个在其中有一些阻塞调用（如阻塞查询执行）的actor，整个线程池（在某种意义上cpu的利用率会下降等等），对吧？我的意思是，从我的理解，没有办法JVM理解是否可以切换到别人，如果/当演员进行阻塞调用时。
..
在哪里可以找到akka.cloud包？
有人可以将我指向包含akka.cloud.cluster的Akka版本吗？我目前使用Akka 1.2-RC6。 google搜索此主题导致关于Cloudy Akka ...的破碎链接... 解决方案 Cloudy Akka描述这里作为Akka的商业附加模块套件。 原来开发Akka的公司已经与 Typesafe 合并。 最近似乎是这 akka用户邮件列表中的主题： “Clo
..
与Actor一起使用时的Scala变量绑定
我对Scala很新。 我试图理解如何/如果scala在闭包作为消息的一部分传递给Actor时进行动态绑定。 我使用Akka 1.2和Scala 2.9。 我有以下代码段（修改自
..
Akka.net开始并没有停止活动
我想从一个类型安全的阿卡演员斯卡拉（2.4.11）在C＃中发送消息给Akka.net演员（1.0.4） 我有一个奇怪的问题，我的.Net演员，口口声声说开始再停了，但我不知道什么引擎盖下发生： A片Akka.net的日志： 二○一五年十一月一十八日16：23：57.6168 | DEBUG | Akka.Remote.Transport.ProtocolStateActor |指
..
我需要与多个远程演员系统进行通信
林用akka.Net开发一个插件架构即包含一个或多个插件每个DLL加载到自己的的AppDomain玩和新的演员系统初始化准备从“主机”收到消息。 我成为脱胶试图让这个与多个插件工作。 所以主机的配置如下： 阿卡{ 演员{ 提供商=“” Akka.Remote.RemoteActorRefProvider，Akka.Remote“” } 远程{ helios.tcp { 运输类
..
如何隐藏查找阿卡远程演员？
我运行的是阿卡2.0.2微内核，并希望实施不受信任的远程参与者的认证方案。 ，想到的第一件事是建立一个认证演员返回到工作的演员时的参考认证成功。 不过，我应该如何保护工作从演员干脆直接被通过actorFor（）远程抬头一看，干脆绕过身份验证？ 也就是说，我想prevent远程参与者访问在我的微内核系统男主角的演员不进行认证。 不放弃工作的演员actorOf名称（）是不够的，因为它会得到一个
..
用于处理在接收异步操作模式阿卡
我有一个接收指标数据点，并定期汇总，并将它们保存到磁盘上的演员。后者的操作执行I / O，所以我不希望使用阻塞操作。但是，如果我把它切换到异步的，我怎么prevent其他数据点从聚合不阻塞的地方完成之前被接收。 我见过的一种模式是使用藏匿，是这样的： 类聚合扩展了藏匿{演员 高清接收=处理 高清处理：接收= { 案“聚合”=＆GT; { context.become（
..
等待多阿卡FSM消息
我有收到消息后运行下面的伪code的阿卡FSM演员，而在的readyState lookupA！包装（查询（“A”）） lookupB！封套（查找（“B”）） lookupC！包装（查找（“C”）） 后藤（LookingUpDataState）使用DataFound（A =无，B =无，C =无） 演员，然后等待回应它可以是 FullResult [T] （延长 ServiceResult
..
阿卡演员问及类型安全
如何使用阿卡演员问及保持类型安全？或者避免使用要求赞成讲述了？ 致电时？或要求上的阿卡演员，一个未来[任意] 返回，我所要做的通过显式转换 future.mapTo [MyType的] 。 我不喜欢失去这种类型的安全性。如果我使用期货直接（不带演员），我可以明确地返回未来[的MyType] 并保持类型安全。 的我的具体使用情况涉及一个演员委派它的消息，两名儿童演员，然后从这些行动者聚集的结果
..