同一spring批处理是否可以同时从不同的多个线程用不同的作业参数调用

Question

我们的要求是同时写多个文件。我们正在使用spring批处理来编写文件，并且我们正在从不同的线程中启动spring批处理。每个线程都有自己的应用程序上下文。因此我们可以确保单例bean不会跨多个线程共享。下面是我的代码片段。

<bean id="reportDataReader" class="com.test.ist.batch2.rrm.batch.readers.RRMItmeReader"
    scope="step">
    <property name="verifyCursorPosition" value="false" />
    <property name="dataSource" ref="dataSource" />
    <property name="sql" value="#{jobParameters['sqlquery']}" />
    <property name="rowMapper" ref="valueMapper" />
    <property name="fetchSize" value="5000" />
</bean>

<bean id="valueMapper" class="com.test.ist.batch2.rrm.batch.mappers.DBValueMapper" scope="step"></bean>

<bean id="velocityFileWritter"
    class="com.test.ist.batch2.rrm.batch.writers.RRMVelocityFileWriter"
    scope="step">
</bean>

<bean id="velocityEngine"
    class="org.springframework.ui.velocity.VelocityEngineFactoryBean">
    <property name="velocityProperties">
        <value>
            resource.loader = class
            class.resource.loader.class = org.apache.velocity.runtime.resource.loader.ClasspathResourceLoader
            class.resource.loader.cache = true
            class.resource.loader.modificationCheckInterval = 0
        </value>
    </property>
</bean>

<batch:job id="rrmReportGenJob">
    <batch:step id="rrmReportGenStep">
        <batch:tasklet>
            <batch:chunk reader="reportDataReader" writer="velocityFileWritter"
                commit-interval="${reportData.reader.commit-interval}">
            </batch:chunk>
        </batch:tasklet>
    </batch:step>
</batch:job>

这就是我们调用html" target="_blank">spring批处理的方式。

ThreadPoolExecutor TPE=new ThreadPoolExecutor(10,10,1000000,TimeUnit.milliseconds,new LinkedBlockingQueue（））；PetReportGenerator RRG=新建PetReportGenerator（空）；ThreadTest tt=new ThreadTest（new PetReportGenerator（null）,“161”）；ThreadTest tt2=新建ThreadTest（新建PetReportGenerator（null）,“162”）；ThreadTest TT3=新建ThreadTest（新建PetReportGenerator（null）,“163”）；ThreadTest TT4=新建ThreadTest（新建PetReportGenerator（null）,“165”）；执行(tt)；执行(tt2)；执行(tt3)；执行(tt4)；

在PetReportGenerator的构造函数中，我们正在初始化bean配置。下面是代码片段

public PetReportGenerator(ApplicationContext reportContext){
    if(null == reportContext){
        //if(null == appContext){
        appContext=new ClassPathXmlApplicationContext("spring-batch-jobs.xml");
        //}
    }else{
        setAppContext(reportContext);;
    }
}

下面是我们如何调用spring批处理的代码摘录

作业jobToExecute=(Job)SpringUtils.getBean（jobName）；JobParametersBuilder paramsBuilder=new JobParametersBuilder（）；//默认情况下，添加数据时间。这将有助于使用相同的参数paramsBuilder.AddLong（“job_time”,System.CurrentTimeMillis（））再次执行相同的作业；if（！jobParams.isEmpty（））{//验证输入字段。String sqlToUse=validator.validateInput（jobParams）；for（map.entry条目：jobParams.entrySet（））{

                    paramsBuilder.addString(entry.getKey(), entry.getValue());

            }

        }else{
            throw new ReportGenerationException("Job input parameter is Empty");
        }

        jobexe=jobLauncher.run(jobToExecute, paramsBuilder.toJobParameters());

如果它在一个线程中运行，它就可以正常工作。当它被多个线程调用时，我们将得到以下错误

有谁能帮我弄明白是什么地方出了问题吗？

Answer 1

MapJobRepository不是用于生产的。它不是线程安全的。如果您需要内存中作业存储库的性能（失去可重启性等），请使用内存中数据库，如hsqldb。

撇开这一点不谈，如果您使用的是线程安全组件，那么您没有理由不能用多个线程启动多个作业实例。