JobParameters od Spring Batch

Question

Próbuję wprowadzić parametry pracy do niestandardowego ItemReadera. Przejrzałem wszystkie notatki StackOverflow na ten temat (przykład: How to get access to job parameters from ItemReader, in Spring Batch?) i widzę, że jest to często występujący problem, który jest w większości nierozwiązany. Mam nadzieję, że wiosenny guru (ktoś z Michaelem Minellą) to zobaczy i będzie miał wgląd.

Doszedłem do stwierdzenia, że ​​parametry pracy są dostępne w około jednym z 10 przebiegów, nawet bez zmian kodu lub konfiguracji. Jest to przypadek losowego sukcesu, a nie losowego niepowodzenia, więc trudno go wyśledzić.

Wkopałem się w kod źródłowy za pomocą debuggera i ustaliłem, że kiedy to się nie powiedzie, w okresie, w którym odbywa się wstrzyknięcie, nie jest rejestrowana żadna fasola o nazwie jobParameters na wiosnę.

Używam Wiosna 4.1.4 z wiosny partii 3.0.2 i wiosna-data-WZP 1.7.1 i wiosna-data-świetlicy 1.9.1, działa w java klasy 8.

Java

@Component("sourceSelectionReader") 
@Scope("step") 
public class SourceSelectionReaderImpl 
implements ItemReader<MyThing> { 
    private Map<String,Object> jobParameters; 

// ... snip ... 


    @Autowired 
    @Lazy 
    @Qualifier(value="#{jobParameters}") 
    public void setJobParameters(Map<String, Object> jobParameters) { 
     this.jobParameters = jobParameters; 
    } 
} 

Praca parametry uruchamiania:

launch-context.xml job1 jobid(long)=1 

uruchom context.xml (minus puch):

<context:property-placeholder location="classpath:batch.properties" /> 

<context:component-scan base-package="com.maxis.maximo.ilm" /> 

<jdbc:initialize-database data-source="myDataSource" enabled="false"> 
    <jdbc:script location="${batch.schema.script}" /> 
</jdbc:initialize-database> 

<batch:job-repository id="jobRepository" 
    data-source="myDataSource" 
    transaction-manager="transactionManager" 
    isolation-level-for-create="DEFAULT" 
    max-varchar-length="1000"/> 

<import resource="classpath:/META-INF/spring/module-context.xml" /> 

Module-context.xml (minus puch):

<description>Example job to get you started. It provides a skeleton for a typical batch application.</description> 

<import resource="classpath:/META-INF/spring/hibernate-context.xml"/> 
<import resource="classpath:/META-INF/spring/myapp-context.xml"/> 

<context:component-scan base-package="com.me" /> 
<bean class="org.springframework.batch.core.scope.StepScope" /> 

<batch:job id="job1"> 
    <batch:step id="step0002" >    
     <batch:tasklet transaction-manager="transactionManager" start-limit="100" > 
      <batch:chunk reader="sourceSelectionReader" writer="selectedDataWriter" commit-interval="1" /> 
     </batch:tasklet> 
    </batch:step> 
</batch:job> 

Answer 1

ważne kroki, aby uzyskać parametry pracy, aby zadaniem jest zdefiniowanie fasoli StepScope i upewnienie się, że twój czytnik jest komponentem @StepScope.

chciałbym spróbować wykonać następujące czynności:

Najpierw upewnij się, że jest to krok fasoli zdefiniowane. To miło z wykorzystaniem konfiguracji Konfiguracja Java:

@Configuration 
public class JobFrameworkConfig { 
    @Bean 
    public static StepScope scope() { 
     return new StepScope(); 
    } 
    // jobRegistry, transactionManager etc... 
} 

Następnie upewnij się, że fasola jest krok scoped o wykorzystaniu @StepScope -annotation (prawie jak w przykładzie). Wstrzyknij @Value, który nie jest @Lazy.

@Component("sourceSelectionReader") 
@StepScope // required, also works with @Scope("step") 
public class SourceSelectionReaderImpl implements ItemReader<MyThing> { 
    private final long myParam; 

    // Not lazy, specified param name for the jobParameters 
    @Autowired 
    public SourceSelectionReaderImpl(@Value("#{jobParameters['myParam']}") final long myParam) { 
     this.myParam = myParam; 
    } 

    // the rest of the reader... 
} 

Answer 2

Spróbuj dodać @DependsOn ("jobParameters") po @Component ("sourceSelectionReader")