1回答
当执行元被创建时，一个具有生命周期的计时器被启动(大约60秒)： private void setLifeSpanTimer(){ } 我给这个计时器起了个名字：lifespan。现在，当我收到一条特定的消息时，我想要返回这个计时器上剩余的时间。 我如何才能得到这个特定计时器的剩余时间？我只
浏览 30提问于2020-12-23得票数 0
1回答
我正在使用Akka经典，并且必须设置定时行为--在Akka类型中，我可以使用Behaviors.withTimers来完成这个任务--如何在Akka经典中完成这个任务？似乎我们可以在阿克卡创造一个演员 return Props.create(actor.class, () -> new actor());如何在这种初始化中使用计时器？
浏览 5提问于2022-02-23得票数 0
回答已采纳
第一种方法是akka.actor.Timers:第二种常用的方法是对参与者上下文系统的调度器message: Any)(implicit executor: ExecutionContext,
sender: ActorRef = Actor.noSender
浏览 0提问于2019-01-30得票数 6
回答已采纳
我正在使用16:42:44.335 28939 [ArteciateActorSystem-akka.actor.default-dispatcher28939 [TwitterActorSystem-akka.actor.default-dispatcher-5] TimerScheduler DEBUG - Cancel timer [perSecond]
浏览 5提问于2020-02-15得票数 0
2回答
我正在寻找Akka HTTP和Play的WSClient的文档，但我找不到它被提到的任何地方。
注意:在请求对服务器产生副作用的情况下，我希望不成功的请求不产生副作用。如何实现此行为？这有可能吗？
浏览 3提问于2019-01-25得票数 2
2回答
如果我在我的Actor的构造函数中安排了一条消息，而参与者在发送消息之前失败(异常)，那么会发生什么？
当参与者恢复或重新启动时，消息会像什么都没有发生一样发送吗？当我在preStart()中启动计时器时，当参与者在失败后重新启动时，我会有两条预定消息吗？
浏览 3提问于2014-04-03得票数 1
回答已采纳
1回答
我有一小部分参与者(用Java语言编写，使用Akka类型的API)，它们利用TimerScheduler将消息调度给它们自己。我想写一些测试来检查它们之间的交互。当使用ActorTestKit recommended in the documentation时，它可以使用普通计时器执行它们，这意味着当参与者在10秒内调度给自己一条消息时，测试必须持续10秒。
浏览 26提问于2021-05-03得票数 2
回答已采纳
事实上，我从一个使用scalaVersion := "2.10.0"的在线博客中获取了我使用的示例( hello程序)，如下所示。我用的是2.11.2。" % "akka-actor_2.10" % "2.2-M1"[info] Resolving com.typesafe.akka#akka-actor_2.11.2;2.2-M1 ...[warn] module not found: com.types
浏览 6提问于2014-08-11得票数 4
回答已采纳
我正在编写一个Akka WebService，它应该处理一个可能很大的纯文本请求体，将每一行发送到参与者的传入消息队列。
你们中有谁可以在这里写一些代码，或者直接转到一个示例页面？我实际上不知道从哪里开始:对我来说最大的问题是处理流(在我的例子中，我想使用Akka流媒体库)
浏览 10提问于2017-07-16得票数 1
回答已采纳
1回答
我正在使用Akka集群，我有一个有趣的问题。节点A上有一个演员Actor1 (akka.tcp://as@127.0.0.1:2554)。此参与者在另一个节点上发现另一个参与者ActorSelection[Anchor(akk
浏览 0提问于2017-10-16得票数 0
回答已采纳
2回答
ExecutionContext.Implicits.global
val system = akka.actor.ActorSystem
浏览 3提问于2015-04-10得票数 1
回答已采纳
1回答
我有一些伪代码，我希望一些有经验的人能告诉我，akka是否会像这样使用，如果不是，我如何重新设计我的设计，以适应akka的最佳实践。我知道Scala有一个收件箱类型的系统，但是我们应该使用Akka，但是我发现Akka在示例等方面的文档能力很差。
有人能告诉我上面的设计是否可行吗？我能在游戏应用程序里面用这个吗？
浏览 0提问于2014-05-14得票数 0
回答已采纳
1回答
供休息轮询之用
、、、、
我正在尝试将一个大型Scala + Akka + PlayMini应用程序与外部REST接口。Actor纬度/v1/当前位置/v1/位置Actor纬度/v1/位置/1轮询Actor‘纬度/v1/位置/2’轮询Actor‘纬度/v1/位置/3’轮询etc.此外，假设资源是通过几个级别嵌套的，并且存在时间有点短(例如，在每次轮询之间可以添加/删除几个资源)，akk
浏览 3提问于2012-05-18得票数 12
() --- End of inner exception stack trace --- at Akka.Actor.ActorCell.CreateNewActorInstance() at <em
浏览 1提问于2016-12-18得票数 1
1 "getAssets"场景将获取所有资产in并将其保存在列表中，第二场景"fetchMetadata"将迭代这些in。我必须只对"getAssets“场景执行一次才能获取所有ID，然后"fetchMetadata”场景将一直执行到给定的持续时间。下面是Json对"/api/assets;limit=$limit“请求的响应(我们使用$.assets*.id从这里获取id )， "assets": [
浏览 1提问于2017-05-17得票数 0
1回答
我有一个方法，它可以为我获取一个Actor引用-或者如果以前没有的话，就创建一个-但有时当我试图创建一个时，我收到了以下异常：
akka.actor.InvalidActorNameException:at akka.actor.dungeon.ChildrenContainer$NormalChildrenContainer.reserve(ChildrenContainer.scala:130)at akka.actor.dungeon.Child
浏览 0提问于2015-01-29得票数 9
1回答
我想要创建一个计时器Actor来跟踪整个程序的进度(并且估计剩余的执行时间)。由于计时器演员必须持有可变变量(即“当前进度”)，我认为应该在最高主管下构建它，而不是由较低的参与者生成。Sentence(.....) case sen: Sentence =>PCFGAddOne}
因此，在这一点上，我认为它应该发送信息给那个计时器演员。但是怎么做呢？我试过actorSel
浏览 2提问于2014-06-03得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
