Scala Akka如何为事件源创建入口点？

Question

我一直在努力学习Akka演员，我真的需要您的帮助！

因此，我的目标基本上是写一个简单的拍卖剂。实际上，Akka有一个示例！问题是，我不知道如何运行它。现在，我花了3天的时间在寻求您的帮助之前试图让它上班，但我完全丢失了它。.：/

o，我开始首先了解打字的演员以及他们的工作方式。我设法通过创建一个我在Internet上找到的简单演员系统来实际打印在屏幕上的

//Entry point inside main(args <...>)
val orderProcessor: ActorSystem[OrderProcessor.Order] = ActorSystem(OrderProcessor(), "main")
//create a new order
orderProcessor ! Order(0, "Bananas")
//<..printing something inside the actor when receiving this message>

东西拍卖示例使用 EventsourcedBehavior ，因此我得出结论，下一步是在Akka中了解事件采购（希望到目前为止，这不会混淆，或者希望我在正确的道路上）转到了Akka的活动采购的正式文档，我以他们的例子为例：

object MyPersistentBehavior {
  sealed trait Command
  final case class Add(data: String) extends Command
  case object Clear extends Command

  sealed trait Event
  final case class Added(data: String) extends Event
  case object Cleared extends Event

  final case class State(history: List[String] = Nil)

  val eventHandler: (State, Event) => State = { (state, event) =>
    event match {
      case Added(data) => state.copy((data :: state.history).take(5))
      case Cleared     => State(Nil)
    }
  }

  val commandHandler: (State, Command) => Effect[Event, State] = { (state, command) =>
    command match {
      case Add(data) => Effect.persist(Added(data))
      case Clear     => Effect.persist(Cleared)
    }
  }

  def apply(id: String): Behavior[Command] =
    EventSourcedBehavior[Command, Event, State](
      persistenceId = PersistenceId.ofUniqueId(id),
      emptyState = State(Nil),
      commandHandler = commandHandler,
      eventHandler = eventHandler)
}

现在很棒！非常简单。

问题是，我不明白入口点在哪里？ 就像 orderprocessor （我显示的第一个示例）显然只是为了创建一个新的Actorsystem，这就是这样，但是我找不到有关此示例的任何信息。我尝试了GitHub的许多不同项目，但它们都不是很简单，无法理解。公平地说，他们中的大多数人都有测试，但是测试并没有真正帮助我。

请任何帮助，任何提示都会非常感谢，我真的很挣扎！

爱yall！＆lt; 3

Answer 1

您必须获得 actorRef [messangeType] 才能向其发送 messageType 。

现有演员具有上下文（以行为定义为参数），您可以创建一个孩子：

val actorRef = context.spawn(behavior)

但是您也可以从 actorsystem < /code>（然后系统直接是父），

val actorRef = system.systemActorOf(behavior)

因此，在您的情况下，可能是：

val actorRef = system.systemActorOf(MyPersistentBehavior("test"))
actorRef ! MyPersistentBehavior.Add("test")

或者您可以 context.spontext.spawn it cistion> cratedy [orderprocessor.order] 为您的 ActorSystem 定义，然后您将通过 ActorRef 通过 System 将命令发送到持久性演员。

Answer 2

我了解您的油漆，不幸的是，Akka文档仅提供摘要作为文档中的样本，并且大多数时候都不完整且难以理解。

您可以在他们的github完整中找到示例我想您可以以这种方式更好地理解事物。

如果您想与Akka一起查看完整的概念验证验证证明，我有一个博客，您可以找到在这里。