Actor + playframework + slick query

Question

我是 akka + playframework 的新手。我一直在 play async action 方法中使用 direct slick 运行 方法。 运行(. … ) 方法 returns 未来 [T]。现在我的问题是 - 在控制器的播放异步操作中使用 actor ask 方法来执行 slick 运行 方法可以吗？

package controllers

import akka.actor.{ActorRef, ActorSystem, Props}
import akka.pattern.ask
import akka.util.Timeout
import javax.inject.{Inject, Singleton}
import play.api.mvc._
import services.actorServices.TestActor

import scala.concurrent.ExecutionContext
import scala.concurrent.duration._

@Singleton
class ActorTestController @Inject()(cc: ControllerComponents, actorSystem: ActorSystem)(implicit assetsFinder: AssetsFinder, executionContext: ExecutionContext)
  extends AbstractController(cc) {

  val testActor: ActorRef = actorSystem.actorOf(Props[TestActor])
  implicit val timeout: Timeout = Timeout.apply(2 second)


  def test: Action[AnyContent] =Action.async{
    (testActor ? "test").mapTo[String].map(string => Ok(string))
  }

}


package services.actorServices

import akka.actor.Actor
import services.dbServices.HomePageDAO

import scala.concurrent.ExecutionContext.Implicits.global


class TestActor extends Actor {

  override def receive: Receive = {
    case "test" =>
      HomePageDAO.getSlogan.map { seqOfString =>
        sender() ! seqOfString.head
      }

  }
}

实际上 ask 不适用于在 Future 中计算的方法:(

Answer 1

没有。你不想这样做：

HomePageDAO.getSlogan.map { seqOfString =>
        sender() ! seqOfString.head
      }

"sender" 可能会改变（实际上，它可能会）直到 Future 完成。您可以做的是使用 pipeTo 并在 Future 完成时回复发件人。

HomePageDAO.getSlogan pipeTo sender()

个人意见：Actor在这种情况下是多余的。你不需要它。只需在 ActorTestController.

中使用 HomePageDAO