Picocli命令中的注入和micronaut之间的互操作性



在Micronaut中定义@Singleton豆不会将同一实例@Inject到Picocli命令中。

Micronaut提供与Picocli的集成。 看起来,必不可少的是,从 Picocli 命令中,可以启动 Micronaut 的嵌入式服务器(也许问题已经在这里,Micronaut 只是从 Picocli 中真正启动的?)。 当我通过 @Singleton 将一个类定义为单例,并在 Micronaut 的 Rest-endpoint 和 Picocli 命令中@Inject它时,它注意到这是两个不同的实例,状态也不相同。 我想要的是传输通过命令行界面提供的一些状态来配置后端/休息服务。 现在我刚刚创建了静态实例来共享此状态,但我想知道我是否可以让依赖注入在 Picocli 和 Micronaut 之间正常工作。

@Singleton
public class SharedState {
private int num;
public void setNum(int num) { this.num = num };
public int getNum() { return this.num; };
}
@Command(name = "ui", description = "...", mixinStandardHelpOptions = true)
public class UICommand implements Runnable {
@Inject
SharedState state;
public static void main(String[] args) throws Exception {
PicocliRunner.run(UICommand.class, args);
}
public void run() {
EmbeddedServer server = ApplicationContext.run(EmbeddedServer.class);
state.setNum(42);
}
}
@Controller("/rest")
public class RestResource{
@Inject
SharedState state;
@Get
public String get() {
return state.getNum();
}
}

如果我在UICommand的run()-method中的SharedState实例中设置了一些状态,我希望能够从RestResource中读取它。因此,我希望在调用其余端点时返回"42"。

有没有办法以某种方式设置 Micronaut/Picocli,以便尽早启动并共享 Micronaut/Picocli 的依赖注入容器?还是Micronaut真的只是从EmbeddedServer调用开始的?在这种情况下,我必须选择哪些选项才能仍然具有一些互操作性?我可以以某种方式明确要求Micronaut的DI容器提供实例吗?

我认为问题中的代码创建了两个单独的ApplicationContext实例。

对底层PicocliRunner.run(UICommand.class, args)的调用会创建一个应用程序上下文,而UICommand.run方法调用ApplicationContext.run(EmbeddedServer.class),这会启动另一个ApplicationContext实例。

解决此问题的一种方法可能是注入ApplicationContext而不是启动新的:

@Command(name = "ui", description = "...", mixinStandardHelpOptions = true)
public class UICommand implements Runnable {
@Inject
SharedState state;
@Inject
ApplicationContext appContext;
public static void main(String[] args) throws Exception {
PicocliRunner.run(UICommand.class, args);
}
public void run() {
// start the injected, shared, application context (not a new instance)
if (!appContext.isRunning()) { // future versions of PicocliRunner may start the context
appContext.start();
}
// start the embedded server
EmbeddedServer server = appContext.getBean(EmbeddedServer.class);
if (!server.isRunning()) {
server.start();
}
state.setNum(42);
}
}

最新更新