akka - 如何使用 Akka BoundedMailBox 来限制生产者

Question

我有两个参与者，一个正在生成消息，另一个正在以固定速率使用消息。

是否有可能让生产者受到消费者 BoundedMailBox 的限制？ (背压)

我的生产者目前是定期安排的(向它发送一个滴答消息)，有没有办法让它根据消费者邮箱中的可用性来安排？

我使用的是即发即忘式 (consumer.tell())，因为我不需要响应。我应该使用不同的消息发送方法吗？

Answer 1

只需指定一个邮箱限制，如果邮箱已满，它就会出现阻塞。 我自己还没有尝试过，但是这个线程中的人正在查看行为，并且都发现一旦邮箱达到极限， Actor 就会阻塞。

有关讨论和更多此类性质的测试，请参见此处。 https://groups.google.com/forum/?fromgroups=#!topic/akka-user/e0tebq5V4nM

来自那个线程:

object ProducerConsumer extends App {

  implicit val system = ActorSystem("ProducerConsumer")

  def waitFor(actor: ActorRef) {
    Await.ready(gracefulStop(actor, 5.seconds), 5.seconds)
  }

  val consumers = system.actorOf(Props[Consumer].
    withRouter(RoundRobinRouter(4)).
    withDispatcher("consumer-dispatcher"), "consumer")

  for (work <- generateWork)
    consumers ! work

  consumers ! PoisonPill
  waitFor(consumers)
  system.shutdown
}

应用程序配置文件:

consumer-dispatcher {
  type = BalancingDispatcher
  mailbox-capacity = 100
}