CDI 注入和 Java 批处理 (JSR-352)

Question

TLDR：将 Web 配置文件示例迁移到成熟的 EE 应用程序后，CDI 的行为与我预期的不同

首先让我说我对 CDI 比较陌生。我喜欢认为我理解了这个概念，但实现的细微差别还有待克服。

我正在尝试 EJB 化并随后使用 RESTful API Java Batch (JSR-352) 进行包装。

首先，我为 Payroll 提取了 javaee7 示例，并将逻辑和工作规范提取到一个完整的 EE7 项目（ejb、web、ear 模块）中。

当我调用 RESTful 服务时，我最初遇到了这个问题（为了保持理智而缩短了）：

WARNING:   Caught exception executing step: java.lang.RuntimeException: com.ibm.jbatch.container.exception.BatchContainerRuntimeException: Tried but failed to load artifact with id: SimpleItemProcessor
Caused by: com.ibm.jbatch.container.exception.BatchContainerRuntimeException: Tried but failed to load artifact with id: SimpleItemProcessor
Caused by: java.lang.ClassNotFoundException: SimpleItemProcessor

请记住，应用程序的这一部分应该基本没有变化。 SimpleItemProcessor 定义相同，如下所示。

@Named("SimpleItemProcessor")
public class SimpleItemProcessor
implements ItemProcessor {

@Inject
private JobContext jobContext;


public Object processItem(Object obj) throws Exception {
    Properties jobParameters = BatchRuntime.getJobOperator().getParameters(jobContext.getExecutionId());

    PayrollInputRecord inputRecord = (PayrollInputRecord) obj;
    PayrollRecord payrollRecord = new PayrollRecord();
    payrollRecord.setMonthYear((String) jobParameters.get("monthYear"));

    int base = inputRecord.getBaseSalary();
    float tax = base * 27 / 100.0f;
    float bonus = base * 15 / 100.0f;

    payrollRecord.setEmpID(inputRecord.getId());
    payrollRecord.setBase(base);
    payrollRecord.setTax(tax);
    payrollRecord.setBonus(bonus);
    payrollRecord.setNet(base + bonus - tax);

    return payrollRecord;
}

}

此 SimpleItemProcessor 由 PayrollJob.xml 定义中的 CDI 名称引用（Batch 环境清楚地找到了该名称）。本规范也是有效 JavaEE7 示例的抄本。

<job id="payroll" xmlns="http://xmlns.jcp.org/xml/ns/javaee" version="1.0">
<step id="process">
    <chunk item-count="3">
        <reader ref="SimpleItemReader"></reader> 
        <processor ref="SimpleItemProcessor"></processor>
        <writer ref="SimpleItemWriter"></writer> 
    </chunk>
</step>

如果我使用 SimpleItemProcessor (com.mycompany.SimpleItemProcessor) 的完全限定名称，它似乎可以工作。其他两个批处理组件（Reader 和 Writer）似乎不需要这个。

我的猜测是我在 CDI 领域缺少一些东西。

这一切都在 Glassfish 4 上运行。

我的 web 模块的 WEB-INF 和 EJB 模块的 META-INF 中都有空 beans.xml。

请给我您对此的任何见解。我一直在搅动。

编辑： 增加了引发异常的 Batch 组件的日志记录，并获得了一些有趣的东西，这些东西可能与 CDI 相关。

FINER:   ENTRY Loading batch artifact id = SimpleItemReader
FINER:   Delegating to preferred artifact factorycom.ibm.jbatch.container.services.impl.CDIBatchArtifactFactoryImpl@4ac13bc2
FINER:   ENTRY Loading batch artifact id = SimpleItemReader
FINER:   RETURN For batch artifact id = SimpleItemReader, loaded artifact instance: com.mycompany.SimpleItemReader@4862cec7 of type: com.mycompany.SimpleItemReader
FINER:   ENTRY Loading batch artifact id = SimpleItemProcessor
FINER:   Delegating to preferred artifact factorycom.ibm.jbatch.container.services.impl.CDIBatchArtifactFactoryImpl@4ac13bc2
FINER:   ENTRY Loading batch artifact id = SimpleItemProcessor
FINE:   Tried but failed to load artifact with id: SimpleItemProcessor, Exception = java.util.NoSuchElementException
FINER:   RETURN For batch artifact id = SimpleItemProcessor, FAILED to load artifact instance
FINER:   Preferred artifact factory failed to load artifact SimpleItemProcessor. Defaulting to batch.xml.
FINE:   TCCL = EarClassLoader : 

执行失败的 CDI 部分（bm.getBeans(id) 返回为空）：

51  private Object More ...getArtifactById(String id) {
52
53      Object artifactInstance = null;
54
55      try {
56          InitialContext initialContext = new InitialContext();
57          BeanManager bm = (BeanManager) initialContext.lookup("java:comp/BeanManager");
58          Bean bean = bm.getBeans(id).iterator().next();
59          Class clazz = bean.getBeanClass();
60          artifactInstance = bm.getReference(bean, clazz, bm.createCreationalContext(bean));
61      } catch (Exception e) {
62          // Don't throw an exception but simply return null;
63          logger.fine("Tried but failed to load artifact with id: " + id + ", Exception = " + e);
64      }
65
66      return artifactInstance;
67  }

以下是工作网络配置文件示例的相同日志记录：

FINER:   ENTRY
FINER:   No preferred job xml loader is detected in configuration
FINER:   Preferred job xml loader failed to load PayrollJob. Defaulting to META-INF/batch-jobs/
FINER:   Loaded job xml with PayrollJob from META-INF/batch-jobs/
FINER:   ENTRY Loading batch artifact id = SimpleItemReader
FINER:   Delegating to preferred artifact factorycom.ibm.jbatch.container.services.impl.CDIBatchArtifactFactoryImpl@4ac13bc2
FINER:   ENTRY Loading batch artifact id = SimpleItemReader
FINER:   RETURN For batch artifact id = SimpleItemReader, loaded artifact instance: com.oracle.javaee7.samples.batch.api.SimpleItemReader@753908c of type: com.oracle.javaee7.samples.batch.api.SimpleItemReader
FINER:   ENTRY Loading batch artifact id = SimpleItemProcessor
FINER:   Delegating to preferred artifact factorycom.ibm.jbatch.container.services.impl.CDIBatchArtifactFactoryImpl@4ac13bc2
FINER:   ENTRY Loading batch artifact id = SimpleItemProcessor
FINER:   RETURN For batch artifact id = SimpleItemProcessor, loaded artifact instance: com.oracle.javaee7.samples.batch.api.SimpleItemProcessor@5376b860 of type: com.oracle.javaee7.samples.batch.api.SimpleItemProcessor
FINER:   ENTRY Loading batch artifact id = SimpleItemWriter
FINER:   Delegating to preferred artifact factorycom.ibm.jbatch.container.services.impl.CDIBatchArtifactFactoryImpl@4ac13bc2
FINER:   ENTRY Loading batch artifact id = SimpleItemWriter
FINER:   RETURN For batch artifact id = SimpleItemWriter, loaded artifact instance: com.oracle.javaee7.samples.batch.api.SimpleItemWriter@243e016c of type: com.oracle.javaee7.samples.batch.api.SimpleItemWriter

Answer 1

最近的一次搜索将我引到这里，所以让我给出一个部分答案，尽管这个问题已经很老了。

首先，作为背景，快速阅读 CDI 的“bean 发现模式”，例如见here。

现在，在 1.0 XSD 级别存在空 beans.xml 将被 CDI 视为 ALL 模式，而完全不存在 beans.xml 将被视为默认 注释模式。

批处理工件对于 CDI 来说并不是特别特殊。因此，与任何类一样，它们只会被视为 CDI 托管 bean，并且只能通过 bean 名称（@Named 值）访问：

• bean 发现模式 = 全部 或
• bean 发现模式 = ANNOTATED 当工件另外包含一个 bean 定义注释（并且@Dependent 确实是一个 bean 定义注释）。

我的猜测是，在您重新打包时，bean.xml 不再被 CDI 检测到，因此您有效地从 ALL 移动到 ANNOTATED 模式，需要 @ 987654324@ bean-defining annotation 按 bean name 加载批处理工件。

（为什么会这样？OP 没有详细说明，现在我确信已经继续前进了……所以没关系，我认为其余的答案仍然很有价值） .

希望这仍然可以帮助某人！

Answer 2

我和你的情况非常相似，直到我找到了一些对我有用的东西，我希望它也对你有用。

注意：我也不是 CDI 专家。

1) 您可以使用@Named 添加@Dependent (javax.enterprise.context.Dependent)。例如：

@Dependent
@Named("SimpleItemProcessor")
public class SimpleItemProcessor implements ItemProcessor {
    // ...
}

只需对所有 SimpleItemReader、SimpleItemProcessor 和 SimpleItemWriter 执行此操作。这包括您应用中的所有 Batchlet。

2) 尽量不要将 JobContext 设为私有，而是将其设为：

@Inject
protected JobContext jobContext;

或

@Inject
JobContext jobContext;

到目前为止，这些对我有用...