Блог

У меня есть сценарий, в котором мне нужно прочитать данные из источника. Я создал пользовательский InputReader, поскольку источник отправляет данные json, сериализованные в objects, а возвращаемый тип — это интерфейс. Мне нужно иметь несколько заданий, поскольку содержимое будет варьироваться в зависимости от типа. Например, тип может быть PlacedOrder или RejectedOrder или CompletedOrder, все они реализуют интерфейс OrderDomain

Согласно приведенному выше примеру, если у меня может быть 3 задания с 3 разными шагами, но с одинаковым CustomItemReader, и тип будет PlacedOrder / RejectedOrder / CompletedOrder в качестве параметра задания. Я сомневаюсь, что «тип», полученный из JobParameter из StepExecution, будет иметь условие гонки, если 3 задания имеют 3 шага, но один и тот же объект CustomReader. Экземпляр reader создается в классе конфигурации в Spring boot, например:

 @Bean
public ItemReader<OrderDomain> orderReader()
{
    return new CustomOrderReader();
} 
  

Я могу создать «тип» в качестве глобальной переменной для использования в методе doRead(), но я сомневаюсь, будет ли он перезаписан другим потоком.

Какие варианты у меня есть? создайте несколько объектов пользовательского средства чтения, используя @Qualifier, а затем используйте их на соответствующих этапах, используя квалификатор?

Запрашиваю у всех вас наилучшую практику, которой можно следовать здесь.

Спасибо