您的位置:首页 > 大数据 > 人工智能

关于akka的mailbox的size问题

2016-07-10 20:39 435 查看
在akka1.x中无论在actor内部还是外部提供了一个查询mailbox size的方法。但是在akka2.0中由于一系列的原因这一个方法被删除了。

那么查询maibox size会存在什么问题呢?

1,需要花费O(n)的时间,在queue并发大的情况下可能会很慢;)

2,并不需要精确计算size;

3,限制了扩张性;

4,在你得到size的时候,这个时候实际的size可能已经发生了非常大的变化。

来看下面的几个问题:

你为什么非要使用mailbox size呢?

假设这里有一个方法可以在actor内部探测到mailbox的size,并且探测到消息堆积太快而导致自己不能处理,那么腻将会怎么做呢?

最直接的答案是降低发送方的速度--只需要设置一个有界的queue(有界的mailbox)。

但是我想要定期的监测,并且当一个新message到来的时候打断一个常任务?

这不是一个最佳实践

那么推荐的方式是什么呢?

可以通过akka提供的resizer: dynamically resizable来分散负担,进行数据路由

如果你需要一个mailbox的metrics怎么办呢?

你能做的是实现一个自定义的mailbox,然后在自定义的mailbox里面实现你的metrics

参考:
http://letitcrash.com/post/17707262394/why-no-mailboxsize-in-akka-2
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: