java - 在 Java EE 批处理中的步骤之间传递对象

Question

如何在 Java EE 批处理作业(不是 spring 批处理作业!)中将对象参数(不是字符串，而是对象列表)从步骤 1 传递到步骤 2。

我尝试了两种解决方案:

• 1 - 使用jobContext。 我。 e.

  • 在第 1 步中:

    jobContext.setTransientUserData("dataFromSubscribersManager");
    

  • 在第 2 步中:

    jobContext.getTransientUserData()
    

• 2 - 使用动态作业参数 .i。 e.

  Properties jobParameters = new Properties();
  jobParameters.put("objectToPass", "someObjectToPass");
  jobOperator.start("someJobName", jobParameters);
  

  但是这里我们只能传递String类型对象。

我需要传递非字符串对象。怎么做？

Answer 1

这个问题可能看起来很相似:

Accesing JobContext from a partitioned step in JSR 352

在上述解决方案中困扰我的一件事是使用:

step.setPersistentUserData(obj);

这意味着您的对象(obj - 可能是大块数据)可能会写入表中，批处理框架在其中保留有关作业的内部信息 - 如果您需要它持久存在，那很好，但如果您不需要，那就是一个缺点。

来自 jsr-352 docs :

The setPersistentUserData method stores a persistent data object into the current step. The user data type must implement java.util.Serializable. This data is saved as part of a step's checkpoint. For a step that does not do checkpoints, it is saved after the step ends. It is available upon restart.

作为一个更简单但不是“jsr-352 风格”的解决方案(上面帖子中“带有 HashMap 的单例 EJB”的替代方案)，我建议创建具有同步访问或哈希表的静态 Map 字段，以保留必要的数据。然而，这个解决方案很大程度上取决于你使用该 map 的密集程度。同步意味着其他线程必须等待获取对 Map 的访问权限，因此需要分析线程不会互相阻塞的可能的关键场景。

@Singleton EJB 具有内置的同步机制: https://docs.oracle.com/cd/E19798-01/821-1841/gipsz/index.html

但在这种情况下，我认为没有必要使用 EJB 技术 - 也许这是一个品味问题。