java - Akka Actor 和消息限制

Question

我正在尝试针对一个非常旧的数据库编写一些代码，如果受到很大的打击，该数据库就会崩溃。

我正在寻找一种方法，使我的 Actor 每秒处理的消息不超过 X 条。

现在，我猜参与者的默认实现是尽可能快地处理消息框中的消息。

但我想知道是否有一种方法可以配置我的 actor，以便每秒从 actor 消息队列中发送的消息数限制为“X”个。

Answer 1

您正在寻找TimerBasedThrottler :

val printer = system.actorOf(Props[PrintActor])

// The throttler for this example, setting the rate
val throttler = system.actorOf(Props(
  classOf[TimerBasedThrottler],
  3 msgsPer 1.second))
throttler ! SetTarget(Some(printer))

然后通过节流器ActorRef发送消息。