不尊重maxNrOfRetries的SupervisorStrategy策略
SupervisorStrategy是Akka框架中用于管理和监控Actor生命周期的一种策略。maxNrOfRetries是SupervisorStrategy的一个参数，用于指定在一段时间内，当一个Actor失败的次数超过这个值时，Supervisor应该如何处理。
具体来说，SupervisorStrategy中的maxNrOfRetries参数决定了一个Actor可以尝试重启的次数。当一个Actor在处理消息时出现了异常或错误，Supervisor会根据定义的策略来决定如何处理这个异常。如果maxNrOfRetries的值大于0，则会尝试将这个Actor重启，以使其恢复到一个可用状态。如果达到最大重试次数，Supervisor会停止这个Actor，并将其标记为无法恢复。
这个参数的主要作用是为了避免异常导致的系统无限重试和资源耗尽。通过设置maxNrOfRetries参数，我们可以控制系统在出现异常时的行为，避免系统崩溃或陷入无限重试的状态。
在云计算领域中，SupervisorStrategy和maxNrOfRetries参数可以用于处理一些关键任务或服务的异常情况，保证系统的可靠性和稳定性。例如，在一个云平台上运行的大规模分布式系统中，可以使用SupervisorStrategy来监控和管理各个节点的状态，当节点出现异常时，根据maxNrOfRetries的设置，可以自动重启或停止节点，以确保整个系统的稳定运行。
腾讯云中相关的产品和服务如下：
- 云服务器（ECS）：提供了灵活可扩展的虚拟服务器，适用于不同规模和负载的应用场景。详情请参考：腾讯云云服务器
- 弹性伸缩（Auto Scaling）：帮助用户根据业务需求自动调整云服务器的数量，以提供更好的弹性和可靠性。详情请参考：腾讯云弹性伸缩
- 云监控（Cloud Monitor）：提供全方位的监控和告警服务，帮助用户实时了解云资源的运行状态和性能指标。详情请参考：腾讯云云监控
- 云函数（Cloud Function）：支持无服务器架构的事件驱动计算服务，可在响应事件时自动运行代码逻辑。详情请参考：腾讯云云函数
通过使用这些腾讯云的产品和服务，用户可以根据自身需求来配置SupervisorStrategy和maxNrOfRetries参数，以实现高可用、高稳定性的云计算系统。
相关·内容
使用下面的代码，我希望"child has error“字符串显示5次(maxNrOfRetries)，但我只看到它一次。 有人能指出我错过了什么吗？我的理解是我的代码错了吗？两者都有？Sender.Tell(child)); }
浏览 16提问于2020-07-28得票数 1
如果我在Scala中为一个参与者定义了监督策略，我如何同时使用OneForOneStrategy和AllForOneStrategy？是否有一种简单的方法来组合它们，或者我是否必须定义一个自定义SupervisorStrategy？下面是一个示例： override val supervisorStrategy = OneForOneStrategy() {// here I want to restart all children
浏览 2提问于2017-07-06得票数 3
回答已采纳
1回答
希望在先前的状态管理策略出现异常后重新启动参与者。演员主管给他的孩子们留了一些参数。此外，主管还有下一个战略： OneForOneStrategy(maxNrOfRetries = 10} }
如何通过supervisorStrategy</e
浏览 1提问于2016-03-21得票数 0
我和Akka一起玩，我有一个设计，其中一个主管演员有一个孩子扮演角色A和几个孩子扮演角色B我想定义一个监督政策，例如A失败升级(终止主管)和B一个产生要重新启动的单个演员。
这个是可能的吗？是明智的吗？
浏览 3提问于2014-01-21得票数 12
1回答
重试一个长寿的阿克卡演员的小例外
、、、、
因此，在这种情况下，什么是合适的重试机制和监督策略，考虑到参与者将在很长的时间间隔后(每天一次)接收消息。case object FileFetch
如果我在父母中有这样的监督策略，它将在每个小的/重大的异常上重新启动失败的子程序，而不需要重试。override val supervisorStrategy =
浏览 5提问于2018-01-25得票数 1
回答已采纳
假设我有以下简单的模型:一个单一的顶级参与者(例如ReportService)，它接受慢速异步操作的请求，并使用多个委托参与者执行容易出错的子任务，遵循错误内核模式。到目前为止，这一切都非常符合我对演员模型的理解，但我不知道如何优雅地处理无法恢复的失败案例。监督策略等都很清楚，但是如果请求在几次重试后无法完成，我如何向用户发送详细说明发生的具体错误的通知？例如，如果我用完了磁盘空间，就没有什么可以恢复的了。我希望Re
浏览 4提问于2017-06-26得票数 0
回答已采纳
1回答
我有一个简单的演员层次结构，如下所示： | | | | | |-- parent2 -- child2_1 -- child2_2
root实现了处理各种异常的supervisorStrategy。如果在parent1或parent2中出现未处理的异常，则到达supervisorStrategy并适当地进行处理
浏览 1提问于2017-09-14得票数 1
回答已采纳
1回答
如何在akka中执行监督
、、、、
我有两个actor，一个是父actor，一个是子actor，子actor负责根据给定的id从MongoDB中获取数据，并将数据返回给调用actor，在我的例子中，actor就是父actor。我知道如何执行监督策略，但如何在代码中执行监督策略让我感到困惑。我在try/catch块中捕获异常，以便捕获每种类型的异常，但随后我被困在如何应用程序的问题上。ReadOnlyAdmin]()
implicit val timeout = Timeout(10 sec
浏览 7提问于2015-08-18得票数 1
我有一个简单的"hello world“角色系统，它有一个RoundRobinPool路由器和一个OneForOneStrategy重新启动策略。我期望下面的代码最终(在几次失败之后)打印10条"work done"消息，但实际上，失败的Worker参与者似乎没有被重新启动：import akka.actor.=
OneForOneStrat
浏览 5提问于2017-11-10得票数 0
回答已采纳
2回答
子执行元中的函数生成的异常是否必须由子执行元显式捕获并抛出，或者主管策略指令(升级)是否会负责将生成的异常渗透到幕后的主管执行元？我的主管策略：OneForOneStrategy(maxNrOfRetries = 5, withinTimeRange = 5Stop case
浏览 2提问于2015-04-15得票数 3
当演员失败时，我需要把失败的原因发送给另一个演员。 override def supervisorStrategy: SupervisorStrategy = case e: Except
浏览 1提问于2016-07-22得票数 2
回答已采纳
有没有一种方法可以在演员主管的SupervisorStrategy中获得信息？我是说导致演员失败的那个。我想从中得到一些数据。
浏览 2提问于2014-03-03得票数 5
回答已采纳
我现在已经设置了这样的连接器： val connector = ContactPoint(sys.env("CASSANDRA_URL"), sys.env("CASSANDRA_PORTConcreteComments with keyspace.Connector
还有我的剧本Action.async {
CassandraDB.users.getAll.m
浏览 4提问于2016-10-19得票数 0
回答已采纳
我有一个主管演员，他创造了这样的儿童演员： case "throw" => throw new Exception()}
现在，在我的MyConnectorActor我需要增加主管的策略吗？ove
浏览 1提问于2016-02-16得票数 1
回答已采纳
我有以下几点建议： case e: JedisConnectionException根据我上面的规则，如果我的孩子演员总是在接收时抛出异常，难道不应该重新启动10次吗？
出于某种原因，从我的日志来看，它看起来只是重新启动一次，仅此而已。我把日志放在启动前和启动后。现在我使用的是"context.actorof()“，我确实看到了被strat”捕获“的</e
浏览 1提问于2015-10-22得票数 1
回答已采纳
2回答
我应该如何处理DbActor在这里抛出的异常？我不确定如何处理它，是否应该通过管道处理失败的情况？dbActor = context.actorOf(Props[DbActor])
OneForOneStrategy(maxNrOfRetries = 10, withinTimeRange
浏览 2提问于2013-07-22得票数 9
回答已采纳
2回答
我被我在Akka看到的行为搞糊涂了。简而言之，我有一组执行科学计算(恒星形成模拟)的参与者。他们有一些状态。当发生错误，导致一个或多个进入无效状态时，我希望重新启动整个集合以重新开始。Broadcast(Kill)我认为会发生的情况是，所有的子演员都会重新启动。然而，他们的preRestart()钩子方法从未被调用过。我看到收到了Kill消息，但仅此而已。
我一定在这里遗漏了一些基本的</e
浏览 1提问于2013-05-30得票数 3
回答已采纳
我有两个演员：通知符--如果ProcessManager发生错误，应通知用户。我需要捕捉ProcessManager参与者的失败(因为任何原因它都失败并停止了，例如，由于达到了ActorInitializationException或最大重启时间，进程管理器参与者被停止)。pm actor"
}如何捕捉到ProcessManage
浏览 7提问于2017-07-20得票数 1
1回答
我正在使用Akka Java库(不幸的是，经典版本)。在实现容错策略时，提供了如下代码段： new OneForOneStrategy(
10如果您指定：-1到maxNrOfRetries，Duration.Inf()指定为withinTimeRange，那么子程序总是不受任何限制地重新启动”。问题是，在我的Java (openjdk-11)中，Duration.Inf() 实际上并不存在！。
浏览 4提问于2022-06-29得票数 0
回答已采纳
我试图在我的Akka项目中通过使用主管来做正确的异常处理。只是想确定这是否是正确的方法。我有一个演员系统，它创建了4个独立的actors.Lets，比方说，我的演员中有1个击中了DB。监管策略是否正确的处理方法？HitDatabase("","")
override val supervisorStrategy = OneForOneStrategy(loggingEnabled = fal
浏览 0提问于2019-01-17得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
