CDI 在 jberet 实现下无法与 Java EE Batch 一起使用答案

【问题标题】：CDI not working with Java EE Batch under jberet implementationCDI 在 jberet 实现下无法与 Java EE Batch 一起使用
【发布时间】：2019-04-17 11:59:00
【问题描述】：

我有一个使用 jberet 实现的 Java EE 批处理应用程序，部署在 WildFly 应用程序服务器上。此应用程序还公开了一个 REST API 以按需触发作业。

我有以下类创建要注入的bean：

public class Factory {

    @Produces
    public JsonValidator getJsonValidator() {
        return JsonSchemaFactory.byDefault().getValidator();
}

在 REST api 中注入上述 bean 可以正常工作：

@Path("my-resource")
public class MyResource{

    @Inject
    private JsonValidator jsonValidator;

    @PUT
    @Consumes(MediaType.APPLICATION_JSON)
    public Response handleNotification(String notification) {
        // using jsonValidator here works fine..

但是在 ItemReader 中使用相同的 bean 会引发空指针异常，但是注入 JobContext 可以正常工作：

public class MyReader extends AbstractItemReader {

    @Inject
    private JobContext jobContext;

    @Inject
    private JsonValidator jsonValidator;

    @Override
    public Integer readItem() throws Exception {
        // using jsonValidator here throws a null pointer exception
        // however jobContext works fine

src/main/resources/META-INF下我的beans.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://xmlns.jcp.org/xml/ns/javaee"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/beans_1_1.xsd"
       version="1.1" bean-discovery-mode="all">
</beans>

src/main/resources/META-INF/batch-jobs/myjob.xml下的job文件：

<job id="myjob" xmlns="http://xmlns.jcp.org/xml/ns/javaee" version="1.0"> 
  <step id="mystep">
    <chunk item-count="1">
      <reader ref="myReader"/>
      <processor ref="myProcessor"/>
      <writer ref="myWriter"/>
    </chunk>
  </step>
</job>

src/main/resources/META-INF/batch.xml 下的批处理工件文件

<?xml version="1.0" encoding="UTF-8"?>
<batch-artifacts xmlns="http://xmlns.jcp.org/xml/ns/javaee">
    <ref id="myReader" class="com.my.app.MyReader" />
    <ref id="myProcessor" class="com.my.app.MyProcessor" />
    <ref id="myWriter" class="com.my.app.MyWriter" />
</batch-artifacts>

我的 pom.xml 如下所示：

<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.my.app</groupId>
    <artifactIdjava-batch</artifactId>
    <packaging>war</packaging>
    <version>1.0</version>

    <name>java-batch</name>
    <url>http://maven.apache.org</url>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

        <!-- JBoss dependency versions -->
        <version.wildfly.maven.plugin>1.0.2.Final</version.wildfly.maven.plugin>

        <!-- other plugin versions -->
        <version.compiler.plugin>3.7.0</version.compiler.plugin>
        <version.surefire.plugin>2.21.0</version.surefire.plugin>
        <version.war.plugin>3.2.0</version.war.plugin>

        <!-- maven-compiler-plugin -->
        <maven.compiler.target>1.8</maven.compiler.target>
        <maven.compiler.source>1.8</maven.compiler.source>

        <version.org.jboss.spec.javax.batch.jboss-batch-api_1.0_spec>1.0.0.Final
        </version.org.jboss.spec.javax.batch.jboss-batch-api_1.0_spec>
        <version.org.jboss.spec.javax.ws.rs.jboss-jaxrs-api_2.0_spec>1.0.0.Final</version.org.jboss.spec.javax.ws.rs.jboss-jaxrs-api_2.0_spec>
        <version.org.jberet>1.3.0.Final</version.org.jberet>
        <version.javax.inject>1</version.javax.inject>
        <version.javax.enterprise>2.0</version.javax.enterprise>
    </properties>

    <build>
        <finalName>java-batch</finalName>
        <plugins>
            <plugin>
                <artifactId>maven-war-plugin</artifactId>
                <version>${version.war.plugin}</version>
            </plugin>
        </plugins>
    </build>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.jboss.spec.javax.batch</groupId>
                <artifactId>jboss-batch-api_1.0_spec</artifactId>
                <version>${version.org.jboss.spec.javax.batch.jboss-batch-api_1.0_spec}</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>javax.inject</groupId>
                <artifactId>javax.inject</artifactId>
                <version>${version.javax.inject}</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>javax.enterprise</groupId>
                <artifactId>cdi-api</artifactId>
                <version>${version.javax.enterprise}</version>
                <scope>provided</scope>
            </dependency>

            <dependency>
                <groupId>org.jberet</groupId>
                <artifactId>jberet-rest-api</artifactId>
                <version>${version.org.jberet}</version>
                <scope>runtime</scope>
            </dependency>
            <dependency>
                <groupId>org.jberet</groupId>
                <artifactId>jberet-rest-commons</artifactId>
                <version>${version.org.jberet}</version>
                <scope>runtime</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.jberet</groupId>
                        <artifactId>jberet-core</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.jberet</groupId>
                <artifactId>jberet-schedule-executor</artifactId>
                <version>${version.org.jberet}</version>
                <scope>runtime</scope>
            </dependency>
            <dependency>
                <groupId>org.jberet</groupId>
                <artifactId>jberet-schedule-timer</artifactId>
                <version>${version.org.jberet}</version>
                <scope>runtime</scope>
            </dependency>
            <dependency>
                <groupId>org.jberet</groupId>
                <artifactId>jberet-support</artifactId>
                <version>${version.org.jberet}</version>
                <scope>runtime</scope>
            </dependency>
            <dependency>
                <groupId>org.jboss.spec.javax.ws.rs</groupId>
                <artifactId>jboss-jaxrs-api_2.0_spec</artifactId>
                <version>${version.org.jboss.spec.javax.ws.rs.jboss-jaxrs-api_2.0_spec}</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <dependencies>
        <dependency>
            <groupId>org.jboss.spec.javax.batch</groupId>
            <artifactId>jboss-batch-api_1.0_spec</artifactId>
        </dependency>
        <dependency>
            <groupId>javax.inject</groupId>
            <artifactId>javax.inject</artifactId>
        </dependency>
        <dependency>
            <groupId>javax.enterprise</groupId>
            <artifactId>cdi-api</artifactId>
        </dependency>

        <dependency>
            <groupId>org.jberet</groupId>
            <artifactId>jberet-rest-api</artifactId>
        </dependency>
        <dependency>
            <groupId>org.jberet</groupId>
            <artifactId>jberet-rest-commons</artifactId>
        </dependency>
        <dependency>
            <groupId>org.jberet</groupId>
            <artifactId>jberet-schedule-executor</artifactId>
        </dependency>
        <dependency>
            <groupId>org.jberet</groupId>
            <artifactId>jberet-schedule-timer</artifactId>
        </dependency>
        <dependency>
            <groupId>org.jberet</groupId>
            <artifactId>jberet-support</artifactId>
        </dependency>
        <dependency>
            <groupId>org.jberet</groupId>
            <artifactId>jberet-core</artifactId>
            <version>${version.org.jberet}</version>
        </dependency>
        <dependency>
            <groupId>org.jboss.spec.javax.ws.rs</groupId>
            <artifactId>jboss-jaxrs-api_2.0_spec</artifactId>
        </dependency>

        <dependency>
            <groupId>com.github.fge</groupId>
            <artifactId>json-schema-validator</artifactId>
            <version>2.2.6</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>LATEST</version>
            <scope>compile</scope>
        </dependency>

    </dependencies>
</project>

我尝试了 @Produce、@JobScoped (org.jberet.cdi.JobScoped) 的各种组合，并使用 @JobScoped、@Default 和 @ApplicationScoped 注入带注释的类，但都产生相同的结果（使用注入的对象时出现 NullPointerException )。

我错过了什么？

【问题讨论】：

JsonValidator 不是容器管理的，并且您的 MyReader 类不是由知道如何提供它的 Jackson 上下文管理的。你需要手动添加一个bean来解决它...
@Produces on getJsonValidator() 在 Factory 类下应该使它成为一个管理 bean。它按预期使用 MyResource 进行注入，但没有使用 MyReader。

标签： java jakarta-ee cdi java-batch jberet

【解决方案1】：

尝试将@Named 添加到您的阅读器、处理器和编写器类，并删除 src/main/resources/META-INF/batch.xml。这将让 CDI 发现作为 CDI bean 的批处理工件并执行依赖注入。

【讨论】：

我已经用完整的类引用更新了 src/main/resources/META-INF/batch-jobs/myjob.xml。并删除了文件 src/main/resources/META-INF/batch.xml。还将@Named（并尝试使用@Named("MyReader")...）添加到MyReader 类等等。它没有工作:(
如果你想使用cdi注入，你不应该使用batch.xml来定义批处理工件，也不应该在job.xml中使用类名来定义它们。如果您仍然看到错误，请在issues.jboss.org/browse/… 向复制者提交问题，我会仔细查看。
我已经用@Named 中提到的引用名称而不是完整的类名更新了 myjob.xml，它可以工作 :) 谢谢 Chengspan>