在akka actor消息中传递scala slick table

Question

我想发送 slick table 作为 akka actor 消息的一部分。这样另一端的远程actor可以连接到数据库，并且可以对mysql数据库进行CRUD操作。我无法理解这些光滑的类型，我发现编译器/eclipse 在抱怨。我怎样才能做到这一点。将灵活查询作为参与者消息的一部分传递是个好主意吗？

object RemoteActorMessages {
  case class Create(table: Table[A])
  case class RunQuery(query: Query[_, _, _])
  case Result(code: Int, message: String)
}

class DBActor extends Actor {
  def recieve = {
    case Create(table) => createTable(table)
    case RunQuery(query) => runQuery(query)
   case ... //so on
  }
}

def createTable(table: Table[M]): Future[A]  = Future {
   db.withSession(implicit session => tableQuery[table].ddl.create)
}

def runQuery(query: Query[_, _, _]): Future[A] = Future {
   db.withSession { implicit session => {
                                       query.run
                                     }
                                   }
}

警告：代码可能有一些类型错误。观众赞赏谨慎

我对如何将结果发送回消息的发件人感到困惑。例如：query.list.run 返回模型对象列表。那么，我应该如何通过 Result 消息框起来

Answer 1

我认为这是“当你有一把锤子时，一切都变成了钉子”的例子。我相信这不是演员的正确用例。一个原因（不是唯一的一个）是数据库操作“慢”并且它们会长时间阻塞参与者线程。

可以说您想要一个管理表操作的服务，使用 Futures 和自定义执行上下文来隔离影响（例如，在 Play 中完成 like this）。比如：

object DBService {
   def createTable() : Future[Boolean] = ???
   ...
}

Actor 应该只接收像 CreateTable 这样的命令，然后调用服务中的相应方法。

顺便说一句，这将简化您的用例，因为服务可以了解更多关于表格和其他 Slick 细节的信息，而参与者则不会注意到它们。

不是唯一的方法，但可以说更简单。