基于Actor的Web服务 - 如何正确实现？
在过去的几个月中，我和我的同事们成功地构建了一个服务器端系统，用于向iPhone设备发送推送通知。基本上，用户通过RESTful webservice（Spray-Server，最近更新为使用Spray-can作为HTTP层）注册这些通知，然后逻辑会安排将来的一个或多个消息进行调度，使用Akk...
基于Agent / Actor并发设计的设计模式
最近我开始涉足支持actor/agent/shared nothing架构的替代语言，如scala、clojure等（clojure也支持共享状态）。 到目前为止，我阅读的大多数文档都集中在入门级别上。我正在寻找更高级的文档，类似于《设计模式》（Gang of Four），但是基于share...
如何在Scala中为具有构造函数参数的Actor创建TestActorRef？
Akka测试文档提供了如下创建TestActorRef的方法： import akka.testkit.TestActorRef val actorRef = TestActorRef[MyActor] 如果我要测试一个带有构造参数的现有actor，该如何扩展这个方法呢？当我尝试直接...
TPL数据流，如何将项转发到多个链接目标块中的一个特定目标块？
我正在寻找一种TPL数据流块解决方案，它可以容纳多个项目，并可以链接到多个目标块，但具有仅将项目转发到通过过滤器/谓词的特定目标块的能力。任何时候都不应将项目同时传递给多个目标块，始终只传递给与过滤器匹配的目标块或者可以丢弃该项。我不喜欢BroadCastBlock，因为如果我理解正确的话，它...
将典型的3层架构转化为Actor模式
这个问题困扰我有一段时间了（希望我不是唯一一个）。我想找一个典型的3层Java EE应用程序，并看看它如何可能使用actors实现。我想知道是否真的有意义进行这样的转换，如果有意义，我如何从中受益（例如性能，更好的架构，可扩展性，可维护性等）。 以下是典型的Controller（表示层），S...
如何检查Akka actor是否存在（akka 2.2）？
我有一个Java对象，它不是Actor，但可以使用actorSelection(Path)从actor系统中选择Actor。有可能选定的Actor在系统中不存在。 在Java API中，ActorSelection没有ask()方法，因此我不能向ActorSelection发送Identif...
为什么Scala Actors在2.10版本中被弃用了？
我刚刚在比较不同的scala actor实现，现在我想知道2.10版本为什么要废弃现有的scala actor实现，并用Akka实现替换默认actor？无论是migration guide还是first announcement都没有给出任何解释。 根据比较，这两个解决方案的差异足以保持两者...
我应该如何在Akka演员之间最好地共享行为？
我有两个Akka actor，它们对一些消息的响应方式相同，但对另一些消息的响应不同。它们都响应相同的消息集合。想知道如何通过继承、组合等方式设计这两个actor的receive方法？我尝试了使用“orElse”将其他trait的部分函数链接在一起，但不幸的是这暴露了类的功能给trait，而且...
Azure 服务织物演员依赖注入
有没有办法在Azure Service Fabric Actor的构造函数中注入依赖项？
在Akka中处理下一条消息之前等待异步Future调用
当接收到事件时，Akka Actors会逐条处理消息，在进行下一条消息之前会阻塞直到请求被完成。这对于同步/阻塞任务来说很有效，但是如果我想执行异步/非阻塞请求，Akka将继续处理而不等待任务完成。例如： def doThing():Future[Unit] = /* Non blocking...