java akka 实战
时间: 2024-01-19 11:18:28 浏览: 91
以下是一个使用Java Akka的实战示例:
```java
import akka.actor.AbstractActor;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
// 定义一个Actor类
class MyActor extends AbstractActor {
@Override
public Receive createReceive() {
return receiveBuilder()
.match(String.class, message -> {
System.out.println("Received message: " + message);
})
.build();
}
}
public class AkkaDemo {
public static void main(String[] args) {
// 创建Actor系统
ActorSystem system = ActorSystem.create("MySystem");
// 创建一个Actor
ActorRef myActor = system.actorOf(Props.create(MyActor.class), "myActor");
// 发送消息给Actor
myActor.tell("Hello Akka!", ActorRef.noSender());
// 关闭Actor系统
system.terminate();
}
}
```
这个示例中,我们创建了一个名为`MyActor`的Actor类,它会接收并打印收到的消息。然后,我们创建了一个Actor系统,并通过`Props.create()`方法创建了一个`MyActor`实例。最后,我们使用`tell()`方法向`myActor`发送了一条消息。
阅读全文