經過大量研究,我想在此更新我的發現。雖然我能夠解決我的具體問題如下,這裏還有很多要說的。
我的具體解決方案第一 -
相反DbController的,我擠包我的服務如下,並注入其在需要時 -
trait Db {
def post
}
class InfluxDb @Inject() (ws: WSClient) extends Db {
val logger = LoggerFactory.getLogger(classOf[InfluxDb])
logger.info("InfluxDb: Initiatlized")
def post = {
val req = ws.url("http://localhost:9086/write")
.withQueryString("db" -> "db1")
.withHeaders("Content-Type" -> "application/json")
.post("job_id,command=PUT value=99")
logger.debug("InfluxDb: Post")
}
}
話雖如此,注射的東西給了我一噸的問題。我終於明白了,這裏有幾個不同的用例 -
- 使用阿卡& Guice和不使用Playframework
- 使用Playframework +阿卡+ Guice和注射頂級演員
- 使用Playframework + Akka + Guice和注射兒童演員
- 使用playframework + Akka + Guice但創建不「injectin g「你的頂級演員&演員系統。
這裏是你將如何解決上述每一個。
- 對於(1) - 參考guice akka tutorial
- 對於(2)&(3) - 參閱Playframework Documentation
- 對於(4)這是一個小更棘手
你會需要擴展「IndirectActorProducer」,然後用它來創建ActorRef。問題是「道具」不知道如何與Guice交互。這也是(1)中的解決方案的一部分
以下示例代碼顯示了所有4個用例,並進行了編譯。在下面的代碼中
ParentActor - 引用上面的使用案例(2),ChildActor使用案例(3)和ParentActor_2 & ChildActor_2使用案例(4)。
// play imports
import play.api.mvc._
import play.api.Logger
import play.api.mvc.Results
// actor imports
import akka.actor.{Actor, ActorSystem, ActorRef, Props, IndirectActorProducer}
// DI imports
import com.google.inject.{Injector, AbstractModule, Key, Provides}
import javax.inject._
import com.google.inject.assistedinject.Assisted
import play.libs.akka.AkkaGuiceSupport
import play.api.libs.concurrent.InjectedActorSupport
class MainCntrlr @Inject() (injector : Injector,
@Named("PActor") pa: ActorRef,
cfP: ParentActor_2.Factory)
extends Controller {
Logger.debug("MainCntrlr: created")
val pa_2 = ActorSystem("test")
.actorOf(Props(classOf[GuiceActorProducer], injector, "PActor_2"), "PA_2")
pa ! 12
pa_2 ! 100
def index = Action { Ok (views.html.index.render()) }
}
class ParentActor @Inject() (cf: ChildActor.Factory) extends Actor with InjectedActorSupport {
Logger.debug("ParentActor: created")
val cactor = injectedChild(cf(2),"childActor")
cactor ! 10
def receive = { case _ => Logger.debug("ParentActor received msg") }
}
object ChildActor { trait Factory { def apply(i: Int) : Actor } }
class ChildActor @Inject()(i: Injector, @Assisted v: Int) extends Actor {
Logger.debug("ChildActor: created with value " + v.toString)
def receive = { case _ => Logger.debug("ChildActor received msg") }
}
class ParentModule extends AbstractModule with AkkaGuiceSupport {
def configure() = {
bindActor(classOf[ParentActor],"PActor")
bindActorFactory(classOf[ChildActor], classOf[ChildActor.Factory])
bindActorFactory(classOf[ParentActor_2], classOf[ParentActor_2.Factory])
bindActorFactory(classOf[ChildActor_2], classOf[ChildActor_2.Factory])
}
}
object ParentActor_2 { trait Factory { def apply() : Actor } }
class ParentActor_2 @Inject() (cf: ChildActor_2.Factory) extends Actor with InjectedActorSupport {
Logger.debug("ParentActor_2: created")
val cactor = injectedChild(cf(4),"childActor_2")
cactor ! 10
def receive = { case _ => Logger.debug("ParentActor_2 received msg") }
}
object ChildActor_2 { trait Factory { def apply(i: Int) : Actor } }
class ChildActor_2 @Inject() (i: Injector, @Assisted v: Int) extends Actor {
Logger.debug("ChildActor_2: created with value " + v.toString)
def receive = { case _ => Logger.debug("ChildActor_2 received msg") }
}
class GuiceActorProducer(val injector: Injector, val actorName: String)
extends IndirectActorProducer {
override def actorClass = classOf[ParentActor_2]
override def produce() =
injector.getBinding(Key.get(classOf[ParentActor_2])).getProvider.get()
}
然後在我的application.conf
play.modules.enabled += "package.ParentModule"
可以使用依賴注入創造者,在這裏看到:https://www.playframework.com/documentation/2.5.x/ScalaAkka#依賴注入演員 – Haspemulator
Haspemulator,感謝您的迴應。它回答了我原來的問題的一部分(我如何依賴注入演員),但沒有解決我的問題。我重新回顧了我的問題的部分內容,以便更清楚。 –
這是最後做的, –