- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我正在关注akka.io容错的代码http://doc.akka.io/docs/akka/current/java/fault-tolerance.html
。我将此代码作为引用。我的要求如下:假设 actor 因一条消息而崩溃并由他的主管重新启动。然后他开始处理下一个他的邮箱里的消息。导致崩溃的消息是'dropped'。但是我想在特定次数(假设 3 次)内处理相同的操作,并在它们之间定义一个时间间隔(假设 1 秒)。如何使用 akka 监督来做到这一点。实际上,通过 actor,我试图检查特定服务 api 是否正常工作(即给出一些异常)。因此,如果特定尝试出现任何异常(假设未找到 404),则将消息重新发送给失败的工作人员直到达到supervisorStrategy指定的maxNrOfRetries。如果工作人员失败了“maxNrOfRetries”次,则只需记录“此 xx 消息达到的最大尝试次数”。我将如何在 java 中执行此操作。
我的主管类(class):
public class Supervisor extends UntypedActor {
private static SupervisorStrategy strategy =
new OneForOneStrategy(3, Duration.create("1 minute"),
new Function<Throwable, Directive>() {
@Override
public Directive apply(Throwable t) {
if (t instanceof Exception) {
return restart();
}else if (t instanceof IllegalArgumentException) {
return stop();
} else {
return escalate();
}
}
});
@Override
public SupervisorStrategy supervisorStrategy() {
return strategy;
}
public void onReceive(Object o) {
if (o instanceof Props) {
getSender().tell(getContext().actorOf((Props) o), getSelf());
} else {
unhandled(o);
}
}
}
子类:
public class Child extends UntypedActor {
public void onReceive(Object o) throws Exception {
if (o instanceof String) {
Object response = someFunction( (String) message);//this function returns either successfull messgae as string or exception
if(response instanceOf Exception) {
throw (Exception) response;
}
else
getSender().tell(response, getSelf())
}else {
unhandled(o);
}
}
}
创建 Actor :
Props superprops = Props.create(Supervisor.class);
ActorRef supervisor = system.actorOf(superprops, "supervisor");
ActorRef child = (ActorRef) Await.result(ask(supervisor,
Props.create(Child.class), 5000), timeout);
child.tell("serVice_url", ActorRef.noSender());
对于service_url,如果发生故障,我想重复该过程。但它没有发生。如果将 creatng actor 中的下一行写为 child.tell("serVice_url_2", ActorRef.noSender());
那么该行将被执行,但我想在特定的时间(假设 3 次)内处理相同的操作(发生失败),并在它们之间定义一个时间间隔。请指导我实现这一目标。
最佳答案
我认为我已经开发出一种方法。尽管我仍然需要在生产级别进行测试。我在下面写下答案,因为它可能对尝试实现相同目标的人有所帮助。如果有人找到更好的方法,那么欢迎他/她。在这里要提一下,通过这种方法Supervisor 在一个时间范围内处理相同的操作(带有发生失败的消息)特定次数(假设 3 次)。我无法定义它们之间的间隔。这是代码。 Supervisor 类。
public class MyUntypedActor extends UntypedActor {
//here I have given Max no retrilas as 10.I will controll this number from logic as per my own requirements.But user given number of retrials can not exceed 10.
private static SupervisorStrategy strategy = new AllForOneStrategy(10, Duration.create(5, TimeUnit.MINUTES),
new Function<Throwable, SupervisorStrategy.Directive>() {
@Override
public SupervisorStrategy.Directive apply(Throwable t) {
if (t instanceof Exception) {
//System.out.println("exception" + "*****" + t.getMessage() + "***" + t.getLocalizedMessage());
return restart();
} else if (t instanceof NullPointerException) {
return restart();
} else if (t instanceof IllegalArgumentException) {
return stop();
} else {
return escalate();
}
}
});
@Override
public SupervisorStrategy supervisorStrategy() {
return strategy;
}
public void onReceive(Object o) {
if (o instanceof Props) {
getSender().tell(getContext().actorOf((Props) o), getSelf());
} else {
unhandled(o);
}
}
}
我们将在其中编写逻辑的子类。
public class Child extends UntypedActor {
//Through preRestart it will push the message for which exception occured before the restart of the child
@Override
public void preRestart(final Throwable reason, final scala.Option<Object> message) throws Exception {
System.out.println("reStarting :::" + message.get());
SetRules.setRemainingTrials(SetRules.remainingTrials + 1);
getSelf().tell(message.get(), getSender());
};
public void onReceive(Object o) throws Exception {
if (o instanceof Exception) {
throw (Exception) o;
} else if (o instanceof Integer) {
} else if (o.equals("get")) {
getSender().tell("get", getSelf());
} else if (o instanceof String) {
try {
// here either we can write our logic directly or for a better
// approach can call a function where the logic will be excuted.
getSender().tell("{\"meggase\":\"Succesfull after " + SetRules.remainingTrials + " retrials\"}",
getSelf());
} catch (Exception ex) {
if (SetRules.remainingTrials == SetRules.noOfRetries) {
getSender().tell("{\"meggase\":\"Failed to connect after " + SetRules.noOfRetries + " retrials\"}",
getSelf());
} else {
Exception value1 = ex;
throw (Exception) value1;
}
}
} else {
unhandled(o);
}
}
}
SetRules类提供了有关用户的信息,提供noOfReTrials,并通过remainingTrials存储每个重试状态的重试次数信息
public class SetRules {
public static int noOfRetries;
public static int remainingTrials;
public SetRules(int noOfRetries, int remainingTrials) {
super();
SetRules.noOfRetries = noOfRetries;
SetRules.remainingTrials = remainingTrials;
}
public int getRemainingTrials() {
return remainingTrials;
}
public static void setRemainingTrials(int remainingTrials) {
SetRules.remainingTrials = remainingTrials;
}
}
现在让我们创建 Actor 。
Props superprops = Props.create(MyUntypedActor.class);
SetRules setRules=new SetRules(3,0);
ActorSystem system = ActorSystem.create("helloakka");
ActorRef supervisor = system.actorOf(superprops, "supervisor");
ActorRef child = (ActorRef) Await.result(ask(supervisor, Props.create(Child.class), 5000), Duration.create(5, "minutes"));
Future<Object> future = Patterns.ask(child, service_Url, new Timeout(Duration.create(5, "minutes")));
Object result = Await.result(future, Duration.create(5, "minutes"));
System.out.println(result);
关于java - 使用 Actor Supervised ,如果发生失败,如何以定义的时间间隔重试相同的消息定义的次数,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42346361/
在complier.h中有一个宏定义如下: # define __cond_lock(x,c) ((c) ? ({ __acquire(x); 1; }) : 0) 但是这里我有一个问题,就是哪里
curl_easy_setopt 的选项在哪里?定义?我试图寻找 CURLOPT_VERBOSE 和其他一些整数值,但这些似乎没有在 curl.h 中明确定义。 最佳答案 第 792 行: #ifde
我确实有一个如下所示的类(class): //.h file class __declspec(dllimport) MyClass { public: //stuff pri
作者: zhuwenzhuang, 2024.05.08. 阅读前假设读者熟悉数据库使用,了解 SQL 的语法和关系算子的大概含义, 能通过 EXPLAIN 命令查看数据库执行计划. 0 前言
我似乎无法找到是否可以声明一个 header 对象以便在响应 header 中重用它,有一些示例定义了响应模式的对象,但它不会转置为响应 header 。我只设法制作了一个可重用的响应对象,如下所示:
css 选择器 * + * 实际上是什么意思?当您执行检查元素时,您可以在谷歌浏览器的控制台中看到它。在我看来,这似乎是对 "Every second child"应用一种风格,但仍然想确定。谁能帮我
我试图弄清楚基本的IO Haskell 函数是定义好的,所以我使用了this reference我到了putChar函数定义: putChar :: Char -> IO () putChar
我得到了一个自动生成的文件,该文件定义了程序集属性,我正在尝试理解内容。 [assembly: global::System.Runtime.Versioning.TargetFrameworkAtt
This文档演示了如何检查变量是否先前已在 gnuplot 脚本中定义。 文档中的示例: a = 10 if (exists("a")) print "a is defined" if (!exist
好吧,这是一个相当基本的问题:我正在关注 SICP 视频,我对 define、let 和 之间的区别有点困惑设置!. 1) 根据 Sussman 在视频中的说法,define 只允许为变量附加一个值一
我一直在尝试定义一个包含只能具有以下三个值之一的字段的 XSD: 绿色 红色 蓝色 本质上,我想在架构级别定义严格的枚举。 我的第一次尝试似乎是错误的,我不确定修复它的“正确”方法。
有人可以定义“POCO”到底是什么意思吗?我越来越频繁地遇到这个术语,我想知道它是否仅与普通类有关还是意味着更多? 最佳答案 “普通旧式 C# 对象” 只是一个普通的类,没有描述基础结构问题或域对象不
在我经常看到的一些django模型中 myfield = models.CharField(_('myfield')) class_name = models.CharField(_('Type'),
每当 BOOL 数据类型不容易预定义时,我都会使用以下定义进行 boolean 运算, typedef unsigned char BOOL; (由于内存使用)。 我意识到出于性能原因,使用本地总线宽
l_ABC_BEANVector = utilRemote.fnGetVector("ABC_COVBEANVector"); 编码的含义是什么?任何帮助,我真的很感激。谢谢 最佳答案 唯一可以肯定地
我正在使用 javacc 开发一个项目,我遇到问题并需要一些帮助,我的文件中有这样的内容: STRING COPYRIGHT (C) 2003, 2004 SYNOPSYS, INC.; 我为单词 S
我想弄清楚基本的 IO定义了 Haskell 函数,所以我使用了 this reference然后我到了 putChar函数定义: putChar :: Char -> IO () putCha
我在具体类中使用 @property 定义 getter 时遇到问题。这是Python代码: from abc import ABCMeta, abstractproperty class abstr
我正在为大学用 C 语言编写一个小游戏,但我陷入了困境。我(在头文件中)有这个结构: typedef struct{ game_element field[MAX_ROWS][MAX_COLU
我一直在 .l 文件中创建标记定义。由于数据集数量庞大,它变得有点乏味。有没有办法读取文件中的所有单词,例如包含所有名词的 noun.txt 并给所有名词一个标记。 基本上,我想自动化这部分: %%
我是一名优秀的程序员,十分优秀!