在实践中使用Scala actor编写应用程序

oxb*_*kes 6 scala actor

我现在用scala actor编写了一些应用程序,我对人们如何处理或处理我遇到的一些问题感兴趣.

过多的Message类或!?

我有一个演员,它会对用户操作作出反应并且必须导致某些事情发生.让我们说react一个消息UserRequestsX(id).我遇到的一个问题是,因为我想模块化我的程序,单个演员本身无法在不涉及其他演员的情况下完成动作.例如,假设我需要使用id参数来检索一堆值,然后需要通过其他一些actor删除它们.如果我正在编写一个普通的Java程序,我可能会这样做:

public void reportTrades(Date date) {
    Set<Trade> trades = persistence.lookup(date);
    reportService.report(trades);
}
Run Code Online (Sandbox Code Playgroud)

这很简单.然而,使用演员这会变得有点痛苦,因为我想避免使用 !?.一个参与者对ReportTrades(date)消息做出反应,但它必须要求PersistenceActor交易然后ReportActor报告它们.我发现这样做的唯一方法是:

react {
    case ReportTrades(date) =>
       persistenceActor ! GetTradesAndReport(date)
}
Run Code Online (Sandbox Code Playgroud)

所以,在我PersistenceActor的反应块中:

react {
    case GetTradesAndReport(date) =>
       val ts = trades.get(date) //from persietent store
       reportActor ! ReportTrades(ts)
}
Run Code Online (Sandbox Code Playgroud)

但现在我有两个问题:

  1. 我必须创建额外的消息类来表示相同的请求(即"报告交易").事实上,我在这种情况下有三个,但我可能还有更多 - 这成为跟踪这些问题的一个问题
  2. 我该怎么称呼第一条和第三条消息ReportTrades?把它们都称之为令人困惑ReportTrades(或者如果我这样做,我必须将它们放在单独的包中).本质上说是因为没有这样的事情overloading一类val的类型.

有什么我想念的吗?我可以避免这个吗?我应该放弃并使用!?人们是否使用某种组织结构来澄清发生了什么?

Dan*_*ral 2

对我来说,你的ReportTrades信息混合了两个不同的概念。一个是请求,命令是响应。例如,它们可能被命名为GetTradesReport(Date)和。SendTradesReport(List[Trade])或者,也许,ReportTradesByDate(Date)并且GenerateTradesReport(List[Trade])