Akka演员:需要一个例子来理解一些基础知识

Question

我正在修补Akka并需要一些建议如何实现我想到的具体内容.我想有一个演员,我可以发送DownloadFile(URI, File)消息并下载它.由于这可以并行,我不想一个接一个地下载文件但是有并发下载限制.

什么是用Akka模拟这样的东西的预定方式？其他想到的事情是:如果某个"工人"演员因某种原因去世,会发生什么？如何重试下载？等等

我知道这是一个非常大的问题,但我希望有人花时间回答它!谢谢!

Answer 1

给它一个机会; 它创建了三个 - 但您可以将其配置为创建任意多个 - 下载程序,以便可以同时处理三个下载请求.

sealed trait DownloaderMessage
case class DownloadFile(uri: URI, file: File) extends DownloaderMessage

object Downloader {
  val dispatcher = Dispatchers.newExecutorBasedEventDrivenWorkStealingDispatcher("pool").build
}

class Downloader extends Actor {
  self.lifeCycle = Permanent
  self.dispatcher = Downloader.dispatcher
  def receive = {
    case DownloadFile(uri, file) =>
      // do the download
  }
}

trait CyclicLoadBalancing extends LoadBalancer { this: Actor =>
  val downloaders: List[ActorRef]
  val seq = new CyclicIterator[ActorRef](downloaders)
}

trait DownloadManager extends Actor {
  self.lifeCycle = Permanent
  self.faultHandler = OneForOneStrategy(List(classOf[Exception]), 5, 5000)
  val downloaders: List[ActorRef]
  override def preStart = downloaders foreach { self.startLink(_) }
  override def postStop = self.shutdownLinkedActors()
}

class DownloadService extends DownloadManager with CyclicLoadBalancing {
  val downloaders = List.fill(3)(Actor.actorOf[Downloader])
}

Answer 2

创建一个管理下载的DownloadActor类,让所有DownloadActors共享相同的Dispatcher,根据需要配置Dispatcher(最大数量线程,队列大小等),让所有DownloadActors链接到同一个Supervisor,根据需要配置Supervisor (可能是OneForOneStrategy),为每个新下载创建一个新的DownloadActor,或者使用带有适当InfiniteIterator的LoadBalancer将下载内容分发到DownloadActors.

如果您使用AsycHttpClient下载文件,它支持download-resume.