如何为Spring编写Akka类型扩展以进行构造函数依赖注入？

Question

在Akka 2.6之前，或者使用经典Actors，可以编写一个Akka扩展来访问Akka非类型化Actor中Spring的@Inject注释。

其中一个例子是：https://github.com/typesafehub/activator-akka-java-spring/blob/master/src/main/java/sample/SpringExtension.java

然而，这不适用于新的Akka类型的演员。

Akka的文档没有显示如何进行这样的扩展（但它显示了如何进行简单的扩展：https://doc.akka.io/docs/akka/current/typed/extending.html#building-扩展）。

到目前为止，我写了这个扩展的开头，但我不知道如何将Spring的ApplicationContext与actor系统链接起来：

import org.springframework.context.ApplicationContext;

import akka.actor.typed.ActorSystem;
import akka.actor.typed.Extension;
import akka.actor.typed.ExtensionId;

public class SpringExtension implements Extension {

  private volatile ApplicationContext applicationContext;

  private SpringExtension(final ActorSystem<?> system) {
    // TODO: What do you put here?
  }

  void initialize(final ApplicationContext applicationContext) {
    this.applicationContext = applicationContext;
  }

  public static class Id extends ExtensionId<SpringExtension> {

    private static final Id instance = new Id();

    private Id() {}

    // called once per ActorSystem
    @Override
    public SpringExtension createExtension(final ActorSystem<?> system) {
      return new SpringExtension(system);
    }

    public static SpringExtension get(final ActorSystem<?> system) {
      return instance.apply(system);
    }
  }
}

如何为类型化演员编写允许在类型化演员中使用Spring DI的Akka扩展？

Answer 1

可能这并不完全是您所需要的，但我认为找到了一种方法，可以在不使用扩展的情况下注入类型化的参与者。

我们可以将行为创建为bean，注入所有需要的依赖项并将其传递给另一个参与者，在那里根据定义的行为生成参与者。

假设我们有PrintActor，它可以使用PrintService打印消息，GreetActor使用GreetService生成PrintActor。我们可以这样定义bean：

@Bean
public Behavior<String> printActorBehavior(PrintService printService) {
    return Behaviors.setup(ctx -> new PrintActor(ctx, printService));
}

@Bean
public Behavior<GreetActor.Greet> greetActorBehavior(GreetService greetService, 
                                                     Behavior<String> printerActorBehavior) {
    return Behaviors.setup(ctx -> new GreetActor(ctx, greetService, printerActorBehavior));
}

然后，在GreetActor中，我们只需通过调用getContext（）. spawn（printerActorBeAct or，“打印机”）从注入的行为创建行为者；

public class GreetActor extends AbstractBehavior<GreetActor.Greet> {
    private GreetService greetService;
    private Behavior<String> printerActorBehavior;

    public GreetActor(ActorContext<Greet> context, 
                      GreetService greetService,
                      Behavior<String> printerActorBehavior) {
        super(context);
        this.greetService = greetService;
        this.printerActorBehavior = printerActorBehavior;
    }

    @Override
    public Receive<Greet> createReceive() {
        return newReceiveBuilder()
                .onMessage(Greet.class, this::onGreet)
                .build();
    }

    private Behavior<Greet> onGreet(Greet msg) {
        ActorRef<String> printer = getContext().spawn(printerActorBehavior, "printer");
        printer.tell(greetService.greet(msg.name));
        return this;
    }

    @Value
    static class Greet {
        String name;
    }
}

因为我们不能在Akka类型的actor系统之外创建actor，所以我认为没有合适的方法将ActorRef注入Spring。

我们可以尝试将Spring上下文注入到参与者中，生成一些参与者并将它们放入Spring上下文中，但我认为这不是同时使用两个框架的好方法。