java - Akka 经典 - 发送自定义类消息类型
问题描述
我正在尝试遵循在 Akka 演员之间发送消息并阅读以下内容的最佳实践:
https://doc.akka.io/docs/akka/current/actors.html
似乎最好的做法是定义一个包含要发送的消息的静态类。
通过阅读文档,我定义了以下内容:
import akka.event.Logging;
import akka.event.LoggingAdapter;
import akka.persistence.AbstractPersistentActor;
class RecoveryActor extends AbstractPersistentActor {
public static class Msg1 {}
public static class Msg2 {}
private final LoggingAdapter log = Logging.getLogger(getContext().getSystem(), this);
/**
* Handler that will be called on recovery.
* @return
*/
@Override
public Receive createReceiveRecover() {
return receiveBuilder()
.match(Msg1.class, this::receiveMsg1)
.match(Msg2.class, this::receiveMsg2)
.build();
}
private void receiveMsg1(Msg1 msg) {
log.info("in receive message 1");
}
private void receiveMsg2(Msg2 msg) {
log.info("in receive message 2");
}
/**
* The normal receive method.
* @return
*/
@Override
public Receive createReceive() {
return receiveBuilder()
.match(String.class, s -> s.equals("cmd"), s -> persist("evt", this::handleEvent))
.build();
}
private void handleEvent(String event) {
System.out.println("in handle event");
}
@Override
public String persistenceId() {
return "simple-accountant"; //best practice, the id should be unique.
}
}
但我不确定如何使用Msg1
and发送消息Msg2
我定义了一个新类来发送消息:
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
public class ActorMessaging {
public static void main(String args[]){
final ActorSystem system = ActorSystem.create("example");
final ActorRef actor = system.actorOf(Props.create(RecoveryActor.class));
actor.tell(RecoveryActor.Msg1);
}
}
但它因编译器错误而失败:
java: cannot find symbol
symbol: variable Msg1
location: class recoverydemo.RecoveryActor
如何向类型的 Actor 发送消息Msg1
?
这是在参与者之间发送消息、将消息包装在自定义类中的最佳实践吗?
解决方案
actor.tell
正在接受对象。RecoveryActor.Msg1
不是这样,它甚至不是类参考。如何尝试发送这样的实例Msg1
:
actor.tell(new RecoveryActor.Msg1(), actorRef)
为了与远程参与者“交谈”,您首先需要获取对它的引用。这通常由ActorSystem完成
推荐阅读
- html - 在页面上划分部分时使用 div 或样式内容元素更好吗?
- django - 在 Google App Engine 中优化 Django 应用
- javascript - Javascript 自动运行 onclick 功能
- c# - 为什么我需要等待已经等待的呼叫(.NET Core 2.2)
- r - 在 R 中获取 xgb.DMatrix 的大小
- c++ - 获取“未定义的引用”
- php - 如何将图像保存在数据库中?
- c# - 如何将 youtube 视频的音频 url 作为 ffmpeg 源传递
- data-structures - 具有 3 个元素 {a1,a2,a3} 的堆排序决策树
- android - Android BLE 广告失败,错误代码为 1