私は分散ワーカー パターンで遊んでいて、Web リクエストから作業をプッシュする問題に遭遇しています。
サンプル プロジェクトにはフロントエンドがあります。
val mediator = DistributedPubSubExtension(context.system).mediator
def receive = {
case work =>
log.info("Frontend received: " + work.toString())
implicit val timeout = Timeout(5.seconds)
(mediator ? Send("/user/master/active", work, localAffinity = false)) map {
case Master.Ack(_) => Ok
} recover { case _ => NotOk } pipeTo sender
}
そして WorkProducer:
override def preStart(): Unit =
scheduler.scheduleOnce(5.seconds, self, Tick)
def receive = {
case Tick =>
n += 1
log.info("Produced work: {}", n)
val work = Work(nextWorkId(), n)
frontend ! work
context.become(waitAccepted(work), discardOld = false)
}
Play Framework コントローラーからフロントエンドに直接送信すると、これはすべて正常に機能します。
def multiply(num: Long) = Action {
implicit request =>
implicit val timeout = Timeout(5.seconds)
val frontend = core.Main.frontend
frontend ! num
Ok
}
メッセージは失われているようです。フロントエンドはメッセージを受け取りますが、下流のアクターは受け取っていないようです。
ClusterActorRefProvider を使用するように play 構成を変更しました
play {
akka {
extensions = ["akka.contrib.pattern.ClusterReceptionistExtension"]
actor.provider = "akka.cluster.ClusterActorRefProvider"
remote.netty.tcp.port=0
}
}
しかし、役に立たない。