在收到 TCP 特定消息时,我需要查询我的数据库。为此,我创建了一个名为 DBActor 的 Actor,并将其加载到Application.scala
file
class Application @Inject() (system: ActorSystem) extends Controller {
val tcpServer = system.actorOf(Props[TCPServer], "tcpserver")
val dbActor = system.actorOf(Props[DBActor], "dbActor")
}
Tcp 服务器是接收消息的 Actor,需要将其推送到 DB Actor 上
val handler = context.actorSelection("/dbActor")
根据 Play Framework 规范,DB actor 就是这样初始化的
object DBActor {
def props() =
Props(classOf[DBActor])
}
class DBActor @Inject() (protected val dbConfigProvider:
DatabaseConfigProvider) extends Actor
with HasDatabaseConfigProvider[JdbcProfile]
with ActorLogging
with TableComponent {
import akka.io.Tcp._
import driver.api._
val table = TableQuery[Table]
def receive: Receive = {
case GetConfig(id) => {
sender ! Await.result(db.run(table.filter(_.id=== id).result.headOption),
Duration.Inf)
.map { x => x.config }
}
}
}
目前,由于错误,演员尚未构建
Error injecting constructor, java.lang.IllegalArgumentException:
no matching constructor found on class tcp.DBActor for arguments []
at controllers.Application.<init>(Application.scala:17)
at controllers.Application.class(Application.scala:17)
所以我需要一种方法将数据库配置注入 DBactor 中以查询数据库或替代方案。之前我评估过注入一个DAO或者将我需要的DAO改造成一个actor,都失败了。
此时的问题是,授予参与者访问数据库或至少访问控制器的权限是否有意义?如果做不到,有什么替代方案?