如何让Guardian Actor持有SpawnProtocol.Command类型ActorSystem引用传递给子Actor

可行实现方案 #

你之前的理解存在偏差，Akka Typed 原生支持在 Guardian Actor 内部直接获取 ActorSystem 实例，不需要外部提前传入，完全可以满足你的需求。

核心思路

Guardian Actor 初始化时通过 Behaviors.setup 块获取 Actor 上下文，上下文中自带已经实例化完成的 ActorSystem 引用，直接持有后就可以在生成子 Actor 时传递。

代码实现

1. 改造 Guardian Actor 的创建逻辑

import akka.actor.typed.ActorSystem;
import akka.actor.typed.Behavior;
import akka.actor.typed.javadsl.Behaviors;
import akka.actor.typed.javadsl.ActorContext;

public class GuardianActor {
    private final ActorContext<SpawnProtocol.Command> context;
    private final ActorSystem<SpawnProtocol.Command> system;

    private GuardianActor(ActorContext<SpawnProtocol.Command> context, ActorSystem<SpawnProtocol.Command> system) {
        this.context = context;
        this.system = system;
    }

    public static Behavior<SpawnProtocol.Command> create() {
        // setup 块的执行时机是Actor被系统初始化完成后，此时ActorSystem已经实例化
        return Behaviors.setup(context -> 
            new GuardianActor(context, context.getSystem()).buildBehavior()
        );
    }

    private Behavior<SpawnProtocol.Command> buildBehavior() {
        return Behaviors.receive(SpawnProtocol.Command.class)
            .onMessage(SpawnProtocol.Spawn.class, spawnMsg -> {
                // 生成子Actor时直接传入持有的system引用
                Behavior<?> targetBehavior;
                if (spawnMsg.behavior() instanceof NewActor.InitMarker) {
                    // 针对需要传入system的NewActor做特殊处理
                    targetBehavior = NewActor.create(system);
                } else {
                    targetBehavior = spawnMsg.behavior();
                }
                var childRef = context.spawn(targetBehavior, spawnMsg.name(), spawnMsg.props());
                spawnMsg.replyTo().tell(new SpawnProtocol.Spawned(childRef));
                return Behaviors.same();
            })
            .build();
    }
}

2. 外部调用方式（完全走Guardian生成子Actor）

// 初始化系统和Guardian
ActorSystem<SpawnProtocol.Command> system = ActorSystem.create(GuardianActor.create(), "System", config);
// 给Guardian发Spawn命令，不需要外部传入system
system.tell(
    new SpawnProtocol.Spawn<>(NewActor.initMarker(), "NewActor", Props.empty(), system.ignoreRef())
);

补充说明 #

你之前直接给 system 发 Spawn 消息的写法，本质是用了Akka内置的默认Guardian处理逻辑，确实绕开了你自定义的Guardian Actor。用上面的方案，所有Spawn请求都会经过你自定义的Guardian处理，你可以在生成子Actor前后加自定义逻辑，符合优雅实现的要求。
如果不需要用通用的SpawnProtocol，也可以直接给Guardian定义专属的生成子Actor命令，实现更简洁：

// Guardian的自定义协议
public interface GuardianCmd {}
public record SpawnNewActor(String name) implements GuardianCmd {}

// Guardian处理逻辑
private Behavior<GuardianCmd> buildBehavior() {
    return Behaviors.receive(GuardianCmd.class)
        .onMessage(SpawnNewActor.class, msg -> {
            context.spawn(NewActor.create(system), msg.name(), Props.empty());
            return Behaviors.same();
        })
        .build();
}

// 外部调用
system.tell(new GuardianActor.SpawnNewActor("NewActor"));

内容的提问来源于stack exchange，提问作者r4bb1t