在 Akka 2.6 之前,或者使用经典的 Actors,可以编写一个 Akka Extension 来访问 Akka 无类型 Actors 中的 Spring 的 @Inject 注释。
一个例子是:https://github.com/typesafehub/activator-akka-java-spring/blob/master/src/main/java/sample/SpringExtension.java
但是,这不适用于新的 Akka Typed actor。
Akka 的文档没有显示如何进行这样的扩展(但它确实显示了如何进行简单的扩展:https://doc.akka.io/docs/akka/current/typed/extending.html#building-an-extension)。
到目前为止,我写了这个扩展的开头,但是我不知道如何将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);
}
}
}
你如何为类型化 Actor 编写一个 Akka 扩展,允许在类型化 Actor 中使用 Spring DI?
最佳答案
可能这不是您所需要的,但我认为找到了一种无需使用扩展即可注入(inject)类型化 Actor 的方法。
我们可以将 Behavior 创建为 bean,注入(inject)所有需要的依赖项并将其传递给另一个 Actor,在那里根据定义的 Behavior 生成 Actor。
假设我们有可以使用 PrintService 打印消息的 PrintActor,以及使用 GreetService 并生成 PrintActor 的 GreetActor。我们可以这样定义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(printerActorBehavior, "printer");
从注入(inject)的 Behavior 创建 Actorpublic 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 Typed 中从 Actor 系统外部创建 Actor ,我认为没有合适的方法来使用 Spring 注入(inject) ActorRef。
我们可以尝试将 Spring 上下文注入(inject)到 Actor 中,生成一些 Actor 并将它们放入 Spring 上下文中,但我认为这不是使用这两个框架的好方法。
关于java - 你如何为构造函数依赖注入(inject)编写一个 Akka Typed Extension for Spring?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59990736/