从 JSR 352 中的分区步骤访问作业上下文

Question

我正在尝试在批处理之间传递对象，但在尝试从分区步骤（批处理）访问 jobContext 时遇到问题。

根据 JSR 352 规范

9.4.1.1 批处理上下文生命周期和范围： 批处理上下文具有线程亲和性，并且仅对批处理可见 在该特定线程上执行的工件。注入批处理上下文 超出范围时，字段可能为空。每种上下文类型都有不同的 范围和生命周期如下： 1.作业上下文 每个作业执行都有一个 JobContext。它为一个人的一生而存在 工作。 并行的每个子线程都有一个不同的 JobContext 执行（例如分区步骤）。 2. StepContext 每个步骤执行都有一个 StepContext。它终生存在 步骤。对于分区步骤，有一个 StepContext 用于 父步骤/线程；每个子线程都有一个不同的 StepContext。

我的（失败的）解决方案是使用 JobContext.setTransientUserData，但由于分区步骤使用不同的 JobContext，我无法获取 TransientUserData。

除了我正在尝试做的事情之外，还有其他选择吗？使用 PartitionMapper 属性是不可能的，因为我需要向每个分区传递一个对象，而不是一个字符串。

说清楚，我需要这样做：

1. NormalBatchlet -> 保存要在下一步中使用的对象。
2. PartitionedBatchlet -> 获取上一步中保存的对象。此对象不是简单的字符串，因此使用 PartitionMapper 属性不是解决方案。

更新

我现在使用带有 HashMap 的简单单例 EJB 来存储步骤之间的对象，当作业完成时，我清除此映射以避免资源泄漏。

这是一种解决方法，因为我真的只想使用 javax.batch 包而不依赖于 EJB，所以我不把它作为答案。

Answer 1

在规范中提到了访问上下文的唯一一种方法 - 注入。请参阅第 9.4.1 段。

"9.4.1 批处理上下文

通过使用标准@Inject 注解 (javax.inject.Inject) 的注入来访问批处理上下文。注入批处理上下文的字段不能是静态的，也不能是最终的。

例如：

@Inject JobContext _jctxt;

@Inject StepContext _sctxt;

批处理运行时负责确保根据当前执行的作业或步骤注入正确的上下文对象。”

Answer 2

你可以尝试这样的东西，它应该符合当前规范的编程模型。

使用 NormalBatchlet 中的持久步骤数据存储第一步中的对象：

stepCtx.setPersistentUserData(mySerializableData);

通过查找上一步从分区中的第一步检索数据：

Long execId = jobCtx.getExecutionId();

List<StepExecution> stepExecs = jobOperator.getStepExecutions(execID);

MyPersistentUserData myData;

for (StepExecution step : stepExecs) {
    if (step.getStepName().equals("somePreviousStepX") {
        myData = (MyPersistentUserData)step.getPersistentUserData();
    }
}

//use myData

Answer 3

没有规范定义的方式来在主线程的 JobContext 和分区级别的 JobContext(s) 之间共享临时用户数据。这是一个可以理解的混淆点，但这确实是预期的设计。