Play 2.5 akka.actor.ActorSystem isTerminated方法已弃用
Play 2.5是一个流行的Java和Scala Web应用程序框架，akka.actor.ActorSystem是Play框架中用于处理并发和分布式计算的Akka库的一部分。在Play 2.5版本中，isTerminated方法已被弃用。
isTerminated方法用于检查ActorSystem是否已经终止。当ActorSystem终止时，意味着所有的Actor都已经停止运行。在Play框架中，ActorSystem通常在应用程序启动时创建，并在应用程序关闭时终止。
由于isTerminated方法已被弃用，建议使用其他方法来检查ActorSystem的状态。在Play 2.5中，可以使用以下方法来替代isTerminated方法：
- 使用ActorSystem的terminationFuture方法：terminationFuture方法返回一个Future对象，该对象在ActorSystem终止时完成。可以通过等待该Future对象完成来检查ActorSystem的状态。
- 使用ActorSystem的registerOnTermination方法：registerOnTermination方法允许注册一个回调函数，在ActorSystem终止时执行。可以在回调函数中处理ActorSystem终止的逻辑。
- 使用ActorSystem的whenTerminated方法：whenTerminated方法返回一个CompletionStage对象，该对象在ActorSystem终止时完成。可以通过等待该CompletionStage对象完成来检查ActorSystem的状态。
总结：
在Play 2.5中，isTerminated方法已被弃用，可以使用terminationFuture、registerOnTermination或whenTerminated方法来替代。这些方法提供了更灵活和可靠的方式来检查ActorSystem的状态。更多关于Play框架和Akka库的信息，请参考腾讯云的相关产品和文档：
相关·内容
1回答
Play 2.5 akka.actor.ActorSystem isTerminated方法已弃用
java、akka、playframework-2.5
我正在将我的项目升级到Play 2.5。在之前的版本中，我使用以下代码通过Akka来调度任务：
private ActorSystem actorSystem = Play.current().injector().instanceOf(ActorSystem.class);
private void scheduleUpdate() {
if (actorSystem.isTerminated()) {
return;
}
//run schedule code
}
但是现在不推荐使用isTermina
浏览 4提问于2016-07-21得票数 0
1回答
我的java应用程序使用Akka框架进行消息路由。在应用程序启动期间，我创建Actor系统，然后创建顶级参与者的数量。现在，在关闭我的应用程序时，我调用Await.result(actorSystem.terminate()，Duration.Inf())，并希望我的关闭线程等待到参与者系统终止。我遇到了其他API ActorSystem.whenTerminated()，它们也返回了未来，并做了类似的事情。只想知道这两个API的区别吗？我应该使用ActorSystem.whenTerminated()代替吗？
浏览 9提问于2022-10-06得票数 0
2回答
使用单独的ExecutionContext处理Slick
scala、playframework、slick
我用的是Play 2.5和Slick。关于这个主题的简单地说明了一切都是由Slick和Play的巧妙模块管理的。但是，这个示例打印Dispatcher[akka.actor.default-dispatcher]
class MyDbioImpl @Inject()(protected val dbConfigProvider: DatabaseConfigProvider)(implicit ec: ExecutionContext)
with HasDatabaseConfigProvider[JdbcProfile] {
import profile.api._
def se
浏览 1提问于2018-06-12得票数 1
回答已采纳
1回答
akka : terminationCallbacks未收到
scala、callback、akka、terminate、actorsystem
我有一个 actorsystem ，其中注册了一些关于actorsystem终止的代码。密码如下-
object ChildActor {
class Msg
}
class ChildActor extends Actor {
val log = Logging(context.system, this)
override def receive: Receive = {
case a : String => log.info(s"received $a")
case _ : Msg => throw new OutOfMemory
浏览 2提问于2018-04-11得票数 0
1回答
如何测试为播放框架注入akka系统的控制器？
scala、unit-testing、playframework、controller
以下是我的控制器：
package controllers
import java.util.TimeZone
import akka.actor.{ActorNotFound, ActorSystem}
import akka.util.Timeout
import com.google.inject.Inject
import com.typesafe.akka.extension.quartz.QuartzSchedulerExtension
import play.api.Logger
import play.api.libs.concurrent.Execution.Implic
浏览 5提问于2015-10-08得票数 2
1回答
运行AKKA远程执行元时出现“遇到死信”错误
scala、akka、remoting、actor
我试图在我的本地主机上使用AKKA运行远程actors，但每次我都得到这个错误。它说遇到了死信。我在互联网上搜索了一下，发现这个错误是在actors在线程停止后收到消息时出现的。因此，我正在寻找一种方法来保持远程机器上的演员存活。我使用的是akka角色，而不是scala角色。
[INFO] [09/16/2013 18:44:51.426] [run-main] [Remoting] Starting remoting
[INFO] [09/16/2013 18:44:51.688] [run-main] [Remoting] Remoting started; listening on
浏览 2提问于2013-09-17得票数 7
回答已采纳
7回答
如何等待Akka演员系统终止？
scala、akka
我需要启动Akka (2.0)演员系统，发送一些消息，然后等待它做繁重的工作。在那之后，我需要做一些与这些演员无关的事情。
我试着用下面的代码等待所有的参与者停止：
val system = new ActorSystem("parallelRunners")
val master = system.actorOf(Props[Master])
master ! Start
system.awaitTermination // <-- hangs here
所有演员都是通过self ! PoisonPill自杀的。我做错了什么？
浏览 0提问于2012-09-15得票数 17
回答已采纳
1回答
如何在Play 2.5.x中创建线程池？
scala、playframework、threadpool、playframework-2.5
我目前使用的是Play 2.4.2，并且已经使用以下内容成功创建了线程池：
package threads
import scala.concurrent.ExecutionContext
import play.api.libs.concurrent.Akka
import play.api.Play.current
object Contexts {
implicit val db: ExecutionContext = Akka.system.dispatchers.lookup("contexts.db-context")
implicit val pdf:
浏览 1提问于2016-09-28得票数 1
1回答
WPF中的参与者系统寿命
c#、wpf、akka.net
在过去，通过使用控制台应用程序，我让Akka.NET参与者系统保持如下状态：
class Program {
static void Main(string[] args) {
using (var actorSystem = ActorSystem.Create("ExampleSystem")) {
var exampleActor = actorSystem.ActorOf(Props.Create(() => new ExampleActor()), name: "Example");
浏览 5提问于2016-05-11得票数 1
回答已采纳
1回答
Play + Akka -加入集群并在另一个ActorSystem上询问参与者
scala、playframework、akka、akka-cluster
我能够让Play应用程序加入现有的Akka集群，然后向运行在另一个ActorSystem上的演员发出询问电话，并获得结果。但我在几件事上有麻烦-
我在下面的日志中看到，play试图加入集群。我怀疑游戏正在启动自己的akka集群？我真的不知道这是什么意思。
无法将群集JMX MBean注册到name=akka:type=Cluster，因为它已经注册了。如果您在同一个JVM中运行多个clust，那么在config`中设置‘akka.cluster.jmx.multi-mBeans-同-jvm= on’
现在，每当向Controller发出请求时，我都会重新初始化actorsyst
浏览 0提问于2018-06-27得票数 1
1回答
Akka流的物化价值
akka、akka-stream、materialized
我想引用流中的物化值。下面是代码片段，但它没有编译，错误： type mismatch;
found : (akka.NotUsed, scala.concurrent.Future[akka.Done])
required: (Playground.DomainObj, scala.concurrent.Future[akka.Done]) 代码： import akka.actor.ActorSystem
import akka.stream.scaladsl._
import scala.concurrent.Future
import akka.NotUsed
import
浏览 6提问于2020-08-16得票数 0
1回答
`akka.pattern.after` -理解“持续时间”论点？
scala、akka
使用Scala 2.11.8，在返回()之前给出一个睡眠5的Future，我用1秒的超时调用了akka.pattern.ask：
import scala.concurrent.duration._
import scala.concurrent._
import akka.actor.ActorSystem
import scala.concurrent.ExecutionContext.Implicits.global
import akka.pattern.after
val system = ActorSystem.create()
after( FiniteDuration(1
浏览 1提问于2016-11-21得票数 0
回答已采纳
1回答
使用Scala 3的Akka流: mapAsync失败
scala、akka-stream、scala-3
我做了一些关于Akka Streams和Scala 3的第一次实验。虽然我知道Akka只有对Scala 3的实验支持，但我对以下简单的程序不能工作感到有点惊讶：
object HelloAkka extends App {
implicit val actorSystem: ActorSystem = ActorSystem();
implicit val executionContext: ExecutionContext = actorSystem.dispatcher
val done = Source(1 to 5)
.mapAsync(2)(n => F
浏览 9提问于2022-09-18得票数 0
1回答
Play Controller试图向Akka集群发送请求时抛出AskTimeoutException
playframework、akka-cluster
我是个初学玩的人，所以请容忍我。我试图让我的游戏控制器与我的后端Akka集群通信。html get请求被路由到我的Controller中的以下方法：
public CompletionStage<Result> createSession(int connectionId){
return FutureConverters.toJava(ask(shardRegion, new CreateSessionMessage(connectionId), 2000))
.thenApply(response -> ok((St
浏览 1提问于2019-04-25得票数 0
2回答
在Akka中将路由转换为流-Http for Java
java、akka、akka-http
有办法将javadsl路由转换为Flow吗？在Scala中，我们有隐式可用的handlerFlow，但在Java中，我们没有类似的东西。
尝试调用handlerFlow，但它使用scaladsl类型，并且与路由的javadsl版本不兼容。
我希望使用API的低级版本来绑定到http和https，并能够访问连接。
==========================
更新:我使用了svezfaz的回答中的想法，现在我得到了代码：
Flow<HttpRequest, HttpResponse, NotUsed> createFlow(ActorSystem system, Materi
浏览 1提问于2016-04-15得票数 0
回答已采纳
1回答
了解阿克卡演员存在的三种方法
java、akka
我正在研究akka演员(JAVA)，最近我认识到有3种方法(可能更多)来了解演员的存在。
发送标识消息：
actorSystem.actorSelection("akka://test/user/TestActor")；AskableActorSelection asker =新AskableActorSelection( sel )；未来=asker.ask(新标识(1)，新超时(5，TimeUnit.SECONDS))；ActorIdentity identity = (ActorIdentity) Await.result(前途，timeOut.duration()；
浏览 9提问于2014-04-28得票数 10
回答已采纳
1回答
scala akka http类型错配
scala、akka-http、openapi-generator
我用open创建了一个项目，然后添加了一个端点GET /product，它应该返回一个产品(我正在测试它，所以我只想让它返回任何产品)。
当我运行这个项目时，我会得到以下错误。
[error] found : org.openapitools.server.model.Product.type
[error] required: (?, ?, ?) => ?
[error] def toEntityMarshallerProduct: ToEntityMarshaller[Product] = jsonFormat3(Product)
日志指向jsonFormat3内部的
浏览 2提问于2021-02-09得票数 0
1回答
阿克卡流错误处理。如何知道哪一行失败了？
scala、akka-stream
我读过这篇关于akka流错误处理的文章。
写了这段代码。
val decider: Supervision.Decider = {
case _: Exception => Supervision.Restart
case _ => Supervision.Stop
}
implicit val actorSystem = ActorSystem()
implicit val actorMaterializer = ActorMaterializer(ActorMaterializerSettings(actorSystem).withSupervisionStrate
浏览 3提问于2017-09-21得票数 2
回答已采纳
1回答
Spring Boot控制器返回scala.concurrent.Future的单声道
java、spring、scala、akka、reactor
我在Spring Boot应用程序中运行Akka actor系统。我有一组演员在运行。 在我的Controller类中，我调用了我的服务类，该服务类使用Actor ask模式向actor发送消息并等待响应。以下是服务方法代码： public Mono<Future<SportEventDetailed>> getEventBySportAndLeagueId(Integer sportId, Integer leagueId) {
final ActorSelection actorSelection = bootstrapAkka.getActorSyste
浏览 24提问于2020-03-24得票数 1
回答已采纳
1回答
播放2.5与Akka -找不到参数超时的隐式值: akka.util.Timeout
scala、playframework、akka
我试图用Play 2.5测试Akka，但是我遇到了一个编译错误，我似乎无法理解。
我从剧本文档：上看到了这个页面
以下是完整的代码：
package controllers
import javax.inject.{Inject, Singleton}
import akka.actor.ActorSystem
import controllers.HelloActor.SayHello
import play.api.mvc._
import play.api.libs.concurrent.Execution.Implicits.defaultContext
import scala.c
浏览 3提问于2016-03-07得票数 6
回答已采纳
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
腾讯云开发者
