如何在akka执行元系统终止时运行调度函数

文章/答案/技术大牛

发布

1回答

scala、akka、apache-flink

我有一个参与者系统，我用它来调度一个函数的执行，该函数从flink的map操作符产生一个Kafka主题中的事件。在出现异常的情况下，执行元系统将终止，并在akka文档(请参阅https://doc.akka.io/docs/akka/current/scheduler.html#from-akka-act

浏览 16提问于2019-05-07得票数 1

1回答

我想创建基于Akka的分布式电子邮件邮箱系统。当我的应用程序启动时，我想创建所有的收件箱演员，并在他们上启动调度程序，以便以10秒的间隔接收邮件。但是有一个问题是如何创建这些收件箱演员？执行元名称可以是数据库中的邮箱UUID，集群中只能存在一个具有特定UUID的执行元。最重要的问题是如何在集群中创建以uuid作为名称的参与者，或者如果它存在，如何获得对它的引用？Logger.debug(s"Creating actor $

浏览 16提问于2016-07-27得票数 0

回答已采纳

1回答

如何在火花停止时清理其他资源

scala、apache-spark、akka

ActorSystem仍然在每个工作节点上保持活动，并阻止整个应用程序终止，它只是挂起。问题是，当SparkContext被关闭时，不需要那些“资源-akka-system”，但是我不知道如何通知ResourceFactory在SparkContext关闭时关闭“资源-akka-system所以现在，“资源-阿克卡-系统”在每个工作节点上保持存活，并阻止整个程序退出。reader.xx()} 在添加了这些printlns之后，我在spark模式下运行代码。但我

浏览 4提问于2016-04-13得票数 10

回答已采纳

1回答

使用akka参与者遍历目录树

scala、recursion、directory、akka、actor

我想使用Scala和Akka遍历目录树。该程序应该找到所有文件，并对每个文件执行任意(但快速)操作。任何帮助都将不胜感激！

浏览 0提问于2016-12-02得票数 0

1回答

在节点中断期间恢复akka实体执行元

java、akka、akka-cluster、akka-persistence

Akka-Cluster模块用于应用程序内的集群。如果我们有一个设置，在节点上运行的实体参与者(我们可能有数百个参与者分布在节点上)被调度为每1分钟接收一次消息(使用计时器/调度器)，那么当托管该参与者的节点优雅地和不优雅地关闭时会发生什么我们如何确保实体参与者在另一个节点上自动创建是只在收到第一条消息时创建实体执行元，还是自动创建执行元，而不需要应用程序中的任何逻辑。另外，参与者的调度器发生了什么情况。

浏览 3提问于2021-04-15得票数 0

2回答

在分片Akka集群中调度广播消息

java、akka、scheduling、akka-cluster

似乎不适合Akka集群。另外，是否可以向分片Akka集群中特定类型的所有参与者广播消息？

浏览 6提问于2020-08-20得票数 1

2回答

Scala akka执行元系统-加载扩展时的RuntimeException

scala、akka、actor

import akka.actor.Actorimport akka.event.Logging }}java.lang.RuntimeException:

浏览 2提问于2017-05-23得票数 0

1回答

有没有可能“扫除”一个无用的akka邮箱？

akka

Local Queue --------- SHOVEL ---------- Remote queue -> Consumer Remote Actor1 -> [DurableMailBox1 <- Actor2] 可以确保箭头的安全，以确

浏览 3提问于2013-05-04得票数 1

2回答

从Akka.net中的路径字符串创建IActorRef

akka.net

有没有像这样的方法：我不习惯于膨胀我的消息类/结构，以及具有显式依赖于Akka.net IActorRef类型的API接口(可能会切换到其他实现，如幕后的Proto.Actor

浏览 0提问于2018-06-06得票数 0

2回答

在akka类型的执行元中创建调度程序/计时器

scala、akka、akka-typed

我正在尝试在我的akka类型中创建一个调度程序，只是为了测试它，比如每x秒运行一次。TestMessage(""""this is pretty cool"""")} 我收到一个错误，说隐式执行上下文不在作用域中。当我在一个类型化的执行元中时，我应该从哪里获取执行上下文？另外，这是我应该设置调度程序/计时器的方式吗？

浏览 22提问于2020-04-14得票数 0

1回答

当什么都没有发生时，Akka在做什么？

akka

应用程序使用Spring Boot和Akka，传输完成后，不会发生任何其他事情。然而，我注意到CPU使用率很高，即使在传输之后也是如此(比如4核机器上50%的CPU使用率，所以满2核)。我已经捕获了活动线程的快照，其中大约1/3属于Akka。 Akka在做什么，为什么要占用这么多cpu？

浏览 16提问于2017-03-08得票数 0

回答已采纳

2回答

演员和邮箱-谁传递消息？

akka、actor

邮箱是由参与者系统提供的。我有一个运行在id为10的线程上的角色myAct。那么myAct！给另一个演员yourAct的消息。

浏览 2提问于2017-04-04得票数 0

2回答

我能安排一个任务少于每10毫秒运行一次吗？

scala、akka

我注意到Akka中的scheduler.schedule不适用于小于10 in的时间表。例如，我尝试了下面，我只收到一条消息每10毫秒。能减少这个频率吗？谢谢德斯 val system = context.system

浏览 3提问于2014-09-15得票数 3

回答已采纳

3回答

实现事件驱动的轻量级线程

java、jvm、akka、quasar

受到Akka和Quasar等库的启发，我开始想知道这些实际上是如何“在引擎盖下”工作的。我知道这很可能是非常复杂的，而且它们各自的工作方式也有很大不同。我非常熟悉Akka这个库，对JVM上的并发性也有一定的了解。谁能告诉我一些关于这方面的文献，或者试着描述一下相关的概念？

浏览 0提问于2017-02-04得票数 1

1回答

在另一个库中配置ActorSystem

java、scala、akka、typesafe-config

我的应用程序使用一个库，该库在内部初始化参与者系统，如下所示 ActorSystem("MySys") 因此，MySys执行元系统使用默认调度程序。我想为这个特定的参与者系统使用一个自定义的分派器。如何在我的application.conf中重写这个库的执行元系统使用的调度程序我已经试过这样做了 MySys { actor {

浏览 21提问于2019-06-24得票数 1

回答已采纳

2回答

AKKA远程执行元错误

scala、akka-remote-actor

我正在尝试通过以下方式运行AKKA远程示例2.Running the local from my machine 远程执行元在机器中启动( ip地址为192.168.1.7)；但是当我从我的机器启动本地执行元时，它无法连接到远程执行元。请查找本地和远程执行元系统</em

浏览 5提问于2016-02-15得票数 2

2回答

播放Websocket示例-只有一个Akka演员？

scala、playframework、playframework-2.0、akka、actor

在play框架提供的Websocket聊天示例中，在我看来，似乎只创建/使用了一个参与者；它还使用了“接收”，如果我理解得很好的话，它会强制在参与者和线程之间进行1:1映射，从而有效地使这个聊天服务器成为单线程的？如果这个分析是正确的？如果是，您是否有关于如何使此服务器具有高度可伸缩性的建议？

浏览 0提问于2012-05-11得票数 6

回答已采纳

2回答

Scala执行元示例:预期类型为：？

scala、actor

在一些教程的指导下，我一直在尝试获得一个简单的Scala Actor示例，在该示例中，我向actor发送(String-)消息，然后该actor向控制台返回输出。我的代码是：import scala.actors.Actor def receive = { case _ =>

浏览 1提问于2013-01-22得票数 1

回答已采纳

7回答

如何等待Akka演员系统终止？

scala、akka

我需要启动Akka (2.0)演员系统，发送一些消息，然后等待它做繁重的工作。在那之后，我需要做一些与这些演员无关的事情。

浏览 0提问于2012-09-15得票数 17

回答已采纳

2回答

如何使Python应用调度器后台运行

python、ps、apscheduler

我想要让Python应用程序在后台运行，下面是我的代码：当我运行该命令时python itger.pyINFO:apscheduler.sc

浏览 0提问于2015-08-16得票数 4

回答已采纳

点击加载更多