如何在micronaut的线程中注入服务或组件？

问题描述

环境因素：

JDK：11.0.7
操作系统：Windows 10
Micronaut：2.1.2

如何使用cli-app配置文件将服务（或组件）注入micronaut的线程中？

下面的链接是我的代码。

关键部分：

@Prototype
class TestWorker implements Callable  {
    private String threadName = Thread.currentThread().name
    @Inject TestService testService

    @Override
    Object call() throws Exception {
        for(int x = 0;x < 20; x++) {
            println("${threadName}: x:${x},${testService.getGreeting(threadName)}")
            sleep(1000)
        }
    }
}

它将引发NullPointerException如下

09：08：31.254 [main] INFO i.m.context.env.DefaultEnvironment- 建立的活动环境：[cli] managerId：1 workerCount：1 java.lang.NullPointerException：无法在上调用方法getGreeting（）在的空对象 org.codehaus.groovy.runtime.NullObject.invokeMethod（NullObject.java:91）在 org.codehaus.groovy.runtime.callsite.PogoMetaClassSite.call（PogoMetaClassSite.java:44）在 org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCall（CallSiteArray.java:47）在 org.codehaus.groovy.runtime.callsite.NullCallSite.call（NullCallSite.java:34）在 org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCall（CallSiteArray.java:47）在 org.codehaus.groovy.runtime.callsite.AbstractCallSite.call（AbstractCallSite.java:125）在 org.codehaus.groovy.runtime.callsite.AbstractCallSite.call（AbstractCallSite.java:139）在test.multithread.app.TestWorker.call（TestWorker.groovy：29）在 java.base / java.util.concurrent.FutureTask.run（FutureTask.java:264）在 java.base / java.util.concurrent.ThreadPoolExecutor.runWorker（ThreadPoolExecutor.java:1128）在 java.base / java.util.concurrent.ThreadPoolExecutor $ Worker.run（ThreadPoolExecutor.java:628）在java.base / java.lang.Thread.run（Thread.java:834）停止

解决方法

在我的书中，使用@Inject是一种代码味道，在这里我们了解原因。您的工人需要 TestService上班（没有办法解决-如果不存在，您会得到NPE）。

接下来，您将手动创建工作程序-因此它不参与依赖项注入。由于您只使用“ deklarative” @Inject，因此没有任何麻烦，因为该服务（强制性服务）会在需要的地方结束。

所以您在这里的第一步：

摆脱@Inject并添加一个构造函数，该构造函数将TestService设置为更好-甚至使变量将其保存为final，因此，如果您错过设置所有警报在c'tor中

现在，如果您通过TestWorker创建new，则必须将TestService传入（当然，您仍然可以通过null等，但是断言可以强制执行此操作）

另一种选择（无论您是出于某种原因切换到基于c'tor的注入还是出于某种原因仍要使用@Inject），都将要求ApplicationContext来构建您的实例。例如。 applicationContext.getBean(Testworker)。

问题是您自己在https://github.com/wureka/test-multithread-app/blob/7e8838c7545e18edda8a367b3b966c06d65fc226/src/main/groovy/test/multithread/app/TestManager.groovy#L19用new TestWorker()创建了一个worker实例。当您这样做时，将不涉及依赖项注入容器，因此实例将不会受到依赖项注入，因此您的testWorker属性在该特定TestManager实例上将为null。

建议对设计进行改进需要了解周围的环境，但是以上内容解释了为什么要获得NPE。

groovy java java micronaut multithreading multithreading