ACTOR模型及AKKA

使用Java 手写一个简单的actor模型-只记录数据的

首先定义一个Actor接口,包含三个方法:onStart、onMessage和onStop。onStart方法在Actor启动时调用一次,onMessage方法在Actor接收到消息时调用,onStop方法在Actor停止时调用:public interface Actor<T> { void onS

首先定义一个 Actor 接口,包含三个方法:onStart、onMessage 和 onStop。onStart 方法在 Actor 启动时调用一次,onMessage 方法在 Actor 接收到消息时调用,onStop 方法在 Actor 停止时调用:

public interface Actor<T> {
    void onStart();

    void onMessage(T message);

    void onStop();
}

接下来实现一个简单的 ActorSystem 类,负责创建和管理 Actor。它包括一个名为 actors 的 Map,用于存储所有 Actor 实例:

import java.util.HashMap;
import java.util.Map;

public class ActorSystem {
    private Map<String, Actor<?>> actors = new HashMap<>();

    public <T> ActorRef<T> actorOf(Actor<T> actor, String name) {
        // 创建 ActorRef,并将 Actor 加入 actors 中
        ActorRef<T> actorRef = new ActorRef<>(actor, name);
        actors.put(name, actor);
        return actorRef;
    }

    public void

原创不易,完成人机校验,阅读全文

相关推荐