AKKA:Actor路由器消息持久性



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

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

有没有办法将这个列表存储在磁盘中?

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

确实如此。

存在FileBasedMailbox。请参阅Akka 2.0.x PDF(或相应的网页)的7.1节"耐用邮箱"。

最新更新