Akka 消息传递保证

我正在尝试找出 Akka 支持哪些消息传递保证。我得出以下结论：

最多一次：默认支持

至少一次：由 Akka Persistence 支持

恰好一次：？

Akka支持exactly-once吗？如果不这样做，我怎样才能实现这一目标？

正如您所发现的，开箱即用的 Akka 提供最多一次交付。 At-Least-Once 在某些库（例如 Akka Persistence）中可用，您可以通过在 Actor 中创建 ACK-RETRY 协议来相当轻松地自行创建它。发送方持续定期发送消息，直到接收方确认收到消息。

简单来说，为了至少一次责任由发件人承担。例如在 Scala 中：

class Sender(receiver: ActorRef) extends Actor {

  var acknowledged = false

  override def preStart() {
    receiver ! "Do Work"
    system.scheduler.scheduleOnce(50 milliseconds, self, "Retry")
  }

  def receive = {
    case "Retry" => 
      if(!acknowledged) {
        receiver ! "Do Work"
        system.scheduler.scheduleOnce(50 milliseconds, self, "Retry")
      }

    case "Ack" => acknowledged = true
  }
}

class Receiver extends Actor {

  def receive = {
    case "Do Work" => 
      doWork()
      sender ! "Ack"
  }

  def doWork() = {...}
}

但通过最多一次处理，接收者必须确保同一消息的重复实例只会导致工作完成一次。这可以通过使接收者完成的工作具有幂等性以便可以重复应用，或者通过让接收者保留其已处理内容的记录来实现。为了至多一次责任由接收者承担：

class AtMostOnceReceiver extends Actor {

  var workDone = false

  def receive = {

    case "Do Work" =>
      if(!workDone) {
        doWork()
        workDone = true
      }
      sender ! Ack
  }

}