java - AKKA:Actor 路由器消息持久化

标签 java scala playframework-2.0 akka typesafe-stack

我正在编写一个 webspider 并在 Heroku 上分配它,在主要参与者(分配路由器的那个)达到 512Mb 后它崩溃了。

基本上,每个解析的 URL 都会发送到 FetchRouter。队列的消息列表太大,无法进入内存。

有什么方法可以将此列表存储在磁盘中吗?

fetcherRouter = context.actorOf(Props[URLFetcher].withRouter(RandomRouter(30)), name = "fetcherRouter")

最佳答案

确实。

FileBasedMailbox。请参阅 Akka 2.0.x PDF(或相应网页)的第 7.1 节“持久邮箱”。

关于java - AKKA:Actor 路由器消息持久化,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/15008921/

相关文章:

java - Arrays.deepEquals 给出了 int[] 的错误,但适用于 Integer[]

java - 在方法 2 和 3 中返回数组中的多个项目

scala - Ordering.by(_.toLowerCase) 如何在 Scala 的 TreeMap 中进行不区分大小写的查找?

hibernate - 如何使用 JPA 插件获取 Play Framework 2 中的 org.hibernate.cfg.Configuration

java - 使用子字符串会产生 StringIndexOutOfBoundsException : String index out of range: -1 exception

java - 将 xml 膨胀到 LinearLayout 后,图像按钮 src 图像消失了

scala - 如何选择要在 Scala 中返回的集合类型?

java - 如何在自定义 ClassLoader 中处理类 [B

ruby-on-rails - Rails 控制台与 play 框架 2.4.x 等效?

css - 使用 Play Framework 2 生成更少的源映射