2016-07-01 83 views
0

我使用Spring Boot 1.3.3.RELEASESpring Batch 3.0.6.RELEASE,并且无法使Spring Batch/Spring Boot变为而不是自动启动我的工作。Spring批处理/ Spring Boot始终自动启动我的作业

这个问题是类似于how to stop spring batch scheduled jobs from running at first time when executing the code?

我有以下的测试类:

@RunWith(SpringJUnit4ClassRunner.class) 
@Configuration 
@ComponentScan(useDefaultFilters = false, 
    includeFilters = @ComponentScan.Filter(value = GetMarkerViaSpringBatchApplicationTest.class, 
     type = FilterType.ASSIGNABLE_TYPE)) 
@EnableBatchProcessing 
//@IntegrationTest({"spring.batch.job.enabled=false"}) 
@EnableAutoConfiguration 
@TestPropertySource(
    locations = {"classpath:env.properties", "classpath:application.properties", "classpath:database.properties"}, 
    properties = {"spring.batch.job.enabled=false"}) 
@SpringApplicationConfiguration(classes = {GetMarkerViaSpringBatchApplicationTest.class}, 
    locations = {"classpath:**/GetMarkerViaSpringBatchApplicationTest-context.xml"}) 
public class GetMarkerViaSpringBatchApplicationTest { 
    @Autowired 
    private JobLauncherTestUtils jobLauncherTestUtils; 

    @Test 
    public void testLaunchJob() throws Exception { 
    JobExecution jobExecution = jobLauncherTestUtils.launchJob(); 
    assertThat(jobExecution.getStatus()).isEqualTo(BatchStatus.COMPLETED); 
    } 
} 

在同一目录中(包)作为测试I类有配置文件GetMarkerViaSpringBatchApplicationTest-context.xml

GetMarkerViaSpringBatchApplicationTest-context.xml内容:

<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:batch="http://www.springframework.org/schema/batch" 
    xmlns:jdbc="http://www.springframework.org/schema/jdbc" 
    xsi:schemaLocation="http://www.springframework.org/schema/batch http://www.springframework.org/schema/batch/spring-batch.xsd 
     http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd 
     http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"> 

    <import resource="classpath:/META-INF/spring/get-marker-job-new.xml" /> 

    <bean id="jobLauncherTestUtils" class="org.springframework.batch.test.JobLauncherTestUtils" /> 

    <bean id="batchConfigurer" class="org.springframework.batch.core.configuration.annotation.DefaultBatchConfigurer"> 
     <constructor-arg name="dataSource" ref="hsqlDataSource" /> 
    </bean> 
</beans> 

get-marker-job-new.xml内容:

<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:batch="http://www.springframework.org/schema/batch" xmlns:task="http://www.springframework.org/schema/task" 
    xmlns:file="http://www.springframework.org/schema/integration/file" xmlns:p="http://www.springframework.org/schema/p" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" 
    xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:util="http://www.springframework.org/schema/util" 
    xsi:schemaLocation=" 
    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd  
    http://www.springframework.org/schema/integration/file http://www.springframework.org/schema/integration/file/spring-integration-file.xsd 
    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
    http://www.springframework.org/schema/batch http://www.springframework.org/schema/batch/spring-batch.xsd 
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd 
    http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd 
    http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd 
    http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd 
    http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd"> 

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

    <!-- The @EnableBatchProcessing on the main class sets up: job-repository, jobLauncher, and jobRepository --> 
    <!-- Spring Boot with Spring Batch doesn't like multiple DataSources since it doesn't know which one --> 
    <!-- to pick for Spring Batch. This class will therefore coerce to pick the proper HSQL dataSource. --> 
    <!-- See https://stackoverflow.com/questions/25540502/use-of-multiple-datasources-in-spring-batch --> 
    <bean id="batchConfigurer" class="org.springframework.batch.core.configuration.annotation.DefaultBatchConfigurer"> 
     <constructor-arg name="dataSource" ref="hsqlDataSource" /> 
    </bean> 

    <bean id="foo" class="myClass" /> 

    <bean id="myTasklet" class="org.springframework.batch.core.step.tasklet.MethodInvokingTaskletAdapter"> 
     <property name="targetObject" ref="myClass" /> 
     <property name="targetMethod" value="deliver" /> 
    </bean> 

    <batch:job id="batchJob" restartable="false"> 
     <batch:step id="step1"> 
      <batch:tasklet ref="myTasklet"/> 
     </batch:step> 
    </batch:job> 
</beans>  

application-context.xml内容:

<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mybatis="http://mybatis.org/schema/mybatis-spring" 
    xmlns:oxm="http://www.springframework.org/schema/oxm" xmlns:util="http://www.springframework.org/schema/util" 
    xsi:schemaLocation="http://www.springframework.org/schema/oxm http://www.springframework.org/schema/oxm/spring-oxm.xsd 
     http://mybatis.org/schema/mybatis-spring http://mybatis.org/schema/mybatis-spring.xsd 
     http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd 
     http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd"> 

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

    <!-- load properties from config files --> 
    <context:property-placeholder location="classpath:env.properties,classpath:application.properties,classpath:database.properties" /> 

    <bean id="transactionManager" class="org.springframework.batch.support.transaction.ResourcelessTransactionManager" /> 
</beans> 

database.xml内容:

<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation=" 
    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd 
    http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd"> 

    <bean id="myDataSource" class="com.zaxxer.hikari.HikariDataSource" destroy-method="close"> 
     <property name="driverClassName" value="${jdbc.myco.driverClassName}" /> 
     <property name="username" value="${jdbc.myco.username}" /> 
     <property name="password" value="${jdbc.myco.encpassword}" /> 
     <property name="jdbcUrl" value="${jdbc.myco.url}" /> 
     <property name="maximumPoolSize" value="${jdbc.myco.pool.maxactive}" /> 
    </bean> 
    <alias alias="dataSource" name="myDataSource" /> 

    <bean id="hsqlDataSource" class="com.zaxxer.hikari.HikariDataSource" destroy-method="close" primary="true"> 
     <property name="driverClassName" value="${jdbc.hsqldb.driverClassName}" /> 
     <property name="username" value="${jdbc.hsqldb.username}" /> 
     <property name="password" value="${jdbc.hsqldb.password}" /> 
     <property name="jdbcUrl" value="${jdbc.hsqldb.url}" /> 
     <property name="maximumPoolSize" value="${jdbc.hsqldb.pool.maxactive}" /> 
    </bean> 

</beans> 

application.properties(在根目录这也是在类路径):

spring.datasource.platform=sqlserver 
spring.profiles.active=local 
spring.batch.job.enabled=true 
spring.batch.initializer.enabled=true 
spring.batch.schema=classpath:org/springframework/batch/core/schema-hsqldb.sql 

注意,在application.propertiesspring.batch.job.enabled=true但在@IntegrationTest@TestPropertySource假。
每当我在application.properties设置spring.batch.job.enabled=true无论在@IntegrationTest,每当我运行这个测试之前jobLauncherTestUtils.launchJob()作业越来越拉开序幕被称为@TestPropertySource努力的spring.batch.job.enabled=false各种连续技。从运行
日志:

15:52:49,083 (o.s.test.context.support.AbstractDirtiesContextTestExecutionListener) - Before test class: context [[email protected] testClass = GetMarkerViaSpringBatchApplicationTest, testInstance = [null], testMethod = [null], testException = [null], mergedContextConfiguration = [[email protected] testClass = GetMarkerViaSpringBatchApplicationTest, locations = '{classpath:**/GetMarkerViaSpringBatchApplicationTest-context.xml}', classes = '{class xxx.myco.batch.client.GetMarkerViaSpringBatchApplicationTest}', contextInitializerClasses = '[]', activeProfiles = '{}', propertySourceLocations = '{classpath:env.properties, classpath:application.properties, classpath:database.properties}', propertySourceProperties = '{spring.batch.job.enabled=false, marker=SELC_ALPHA_DONE, marker_date=2016/06/21, interval=1, times=1, is_fail=true, fail_path=${pkg.out}\\failed_alpha_report}', contextLoader = 'o.s.boot.test.SpringApplicationContextLoader', parent = [null]]], class annotated with @DirtiesContext [false] with mode [null]. 

15:52:49,099 (o.s.test.context.support.DependencyInjectionTestExecutionListener) - Performing dependency injection for test context [[[email protected] testClass = GetMarkerViaSpringBatchApplicationTest, testInstance = [email protected]9360f, testMethod = [null], testException = [null], mergedContextConfiguration = [[email protected] testClass = GetMarkerViaSpringBatchApplicationTest, locations = '{classpath:**/GetMarkerViaSpringBatchApplicationTest-context.xml}', classes = '{class xxx.myco.batch.client.GetMarkerViaSpringBatchApplicationTest}', contextInitializerClasses = '[]', activeProfiles = '{}', propertySourceLocations = '{classpath:env.properties, classpath:application.properties, classpath:database.properties}', propertySourceProperties = '{spring.batch.job.enabled=false, marker=SELC_ALPHA_DONE, marker_date=2016/06/21, interval=1, times=1, is_fail=true, fail_path=${pkg.out}\\failed_alpha_report}', contextLoader = 'o.s.boot.test.SpringApplicationContextLoader', parent = [null]]]]. 

15:52:50,572 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [database.properties]] 
15:52:50,572 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [application.properties]] 
15:52:50,572 (o.s.core.env.PropertySourcesPropertyResolver) - Found key 'spring.batch.job.enabled' in [class path resource [application.properties]] with type [String] and value 'false' 

15:52:50,665 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [database.properties]] 
15:52:50,665 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [application.properties]] 
15:52:50,665 (o.s.core.env.PropertySourcesPropertyResolver) - Found key 'spring.batch.job.enabled' in [class path resource [application.properties]] with type [String] and value 'false' 

15:52:50,665 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [database.properties]] 
15:52:50,665 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [application.properties]] 
15:52:50,665 (o.s.core.env.PropertySourcesPropertyResolver) - Found key 'spring.batch.job.enabled' in [class path resource [application.properties]] with type [String] and value 'false' 

15:52:52,132 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [database.properties]] 
15:52:52,132 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [application.properties]] 
15:52:52,132 (o.s.core.env.PropertySourcesPropertyResolver) - Found key 'spring.batch.job.enabled' in [class path resource [application.properties]] with type [String] and value 'false' 

15:53:00,861 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [database.properties]] 
15:53:00,861 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [application.properties]] 
15:53:00,861 (o.s.core.env.PropertySourcesPropertyResolver) - Found key 'spring.batch.job.enabled' in [class path resource [application.properties]] with type [String] and value 'false' 

15:53:00,861 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [database.properties]] 
15:53:00,861 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [application.properties]] 
15:53:00,861 (o.s.core.env.PropertySourcesPropertyResolver) - Found key 'spring.batch.job.enabled' in [class path resource [application.properties]] with type [String] and value 'false' 

15:53:00,861 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [database.properties]] 
15:53:00,861 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [application.properties]] 
15:53:00,861 (o.s.core.env.PropertySourcesPropertyResolver) - Found key 'spring.batch.job.enabled' in [class path resource [application.properties]] with type [String] and value 'false' 

15:53:00,876 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [database.properties]] 
15:53:00,876 (o.s.core.env.PropertySourcesPropertyResolver) - Searching for key 'spring.batch.job.enabled' in [class path resource [application.properties]] 
15:53:00,876 (o.s.core.env.PropertySourcesPropertyResolver) - Found key 'spring.batch.job.enabled' in [class path resource [application.properties]] with type [String] and value 'false' 
... 
    BatchAutoConfiguration#jobExplorer did not match 
     - @ConditionalOnMissingBean (types: o.s.batch.core.explore.JobExplorer; SearchStrategy: all) found the following [jobExplorer] (OnBeanCondition) 

    BatchAutoConfiguration#jobLauncherCommandLineRunner did not match 
     - @ConditionalOnMissingBean (types: o.s.boot.autoconfigure.batch.JobLauncherCommandLineRunner; SearchStrategy: all) found no beans (OnBeanCondition) 
     - @ConditionalOnProperty expected 'true' for properties spring.batch.job.enabled (OnPropertyCondition) 

    BatchAutoConfiguration.JpaBatchConfiguration did not match 
     - required @ConditionalOnClass classes not found: javax.persistence.EntityManagerFactory (OnClassCondition) 
... 
15:53:02,225 (o.s.test.context.cache.DefaultCacheAwareContextLoaderDelegate) - Storing ApplicationContext in cache under key [[[email protected] testClass = GetMarkerViaSpringBatchApplicationTest, locations = '{classpath:**/GetMarkerViaSpringBatchApplicationTest-context.xml}', classes = '{class xxx.myco.batch.client.GetMarkerViaSpringBatchApplicationTest}', contextInitializerClasses = '[]', activeProfiles = '{}', propertySourceLocations = '{classpath:env.properties, classpath:application.properties, classpath:database.properties}', propertySourceProperties = '{spring.batch.job.enabled=false, marker=SELC_ALPHA_DONE, marker_date=2016/06/21, interval=1, times=1, is_fail=true, fail_path=${pkg.out}\\failed_alpha_report}', contextLoader = 'o.s.boot.test.SpringApplicationContextLoader', parent = [null]]] 

15:53:02,256 (o.s.test.context.support.AbstractDirtiesContextTestExecutionListener) - Before test method: context [[email protected] testClass = GetMarkerViaSpringBatchApplicationTest, testInstance = [email protected]9360f, testMethod = [email protected], testException = [null], mergedContextConfiguration = [[email protected] testClass = GetMarkerViaSpringBatchApplicationTest, locations = '{classpath:**/GetMarkerViaSpringBatchApplicationTest-context.xml}', classes = '{class xxx.myco.batch.client.GetMarkerViaSpringBatchApplicationTest}', contextInitializerClasses = '[]', activeProfiles = '{}', propertySourceLocations = '{classpath:env.properties, classpath:application.properties, classpath:database.properties}', propertySourceProperties = '{spring.batch.job.enabled=false, marker=SELC_ALPHA_DONE, marker_date=2016/06/21, interval=1, times=1, is_fail=true, fail_path=${pkg.out}\\failed_alpha_report}', contextLoader = 'o.s.boot.test.SpringApplicationContextLoader', parent = [null]]], class annotated with @DirtiesContext [false] with mode [null], method annotated with @DirtiesContext [false] with mode [null]. 

15:53:04,669 (o.s.test.context.support.AbstractDirtiesContextTestExecutionListener) - After test method: context [[email protected] testClass = GetMarkerViaSpringBatchApplicationTest, testInstance = [email protected]9360f, testMethod = [email protected], testException = [null], mergedContextConfiguration = [[email protected] testClass = GetMarkerViaSpringBatchApplicationTest, locations = '{classpath:**/GetMarkerViaSpringBatchApplicationTest-context.xml}', classes = '{class xxx.myco.batch.client.GetMarkerViaSpringBatchApplicationTest}', contextInitializerClasses = '[]', activeProfiles = '{}', propertySourceLocations = '{classpath:env.properties, classpath:application.properties, classpath:database.properties}', propertySourceProperties = '{spring.batch.job.enabled=false, marker=SELC_ALPHA_DONE, marker_date=2016/06/21, interval=1, times=1, is_fail=true, fail_path=${pkg.out}\\failed_alpha_report}', contextLoader = 'o.s.boot.test.SpringApplicationContextLoader', parent = [null]]], class annotated with @DirtiesContext [false] with mode [null], method annotated with @DirtiesContext [false] with mode [null]. 

15:53:04,685 (o.s.test.context.support.AbstractDirtiesContextTestExecutionListener) - After test class: context [[email protected] testClass = GetMarkerViaSpringBatchApplicationTest, testInstance = [null], testMethod = [null], testException = [null], mergedContextConfiguration = [[email protected] testClass = GetMarkerViaSpringBatchApplicationTest, locations = '{classpath:**/GetMarkerViaSpringBatchApplicationTest-context.xml}', classes = '{class xxx.myco.batch.client.GetMarkerViaSpringBatchApplicationTest}', contextInitializerClasses = '[]', activeProfiles = '{}', propertySourceLocations = '{classpath:env.properties, classpath:application.properties, classpath:database.properties}', propertySourceProperties = '{spring.batch.job.enabled=false, marker=SELC_ALPHA_DONE, marker_date=2016/06/21, interval=1, times=1, is_fail=true, fail_path=${pkg.out}\\failed_alpha_report}', contextLoader = 'o.s.boot.test.SpringApplicationContextLoader', parent = [null]]], class annotated with @DirtiesContext [false] with mode [null]. 

我读过http://forum.spring.io/forum/spring-projects/batch/748038-i-do-not-want-enablebatchprocessing-to-launch-a-jobhow to stop spring batch scheduled jobs from running at first time when executing the code?,但似乎无法得到jobLauncher到自动启动。
我的理解是,application.properties属性应该被2个地方覆盖,我试图直接在测试中设置它,但BatchAutoConfiguration似乎没有兑现该覆盖。
如果我在application.properties中设置spring.batch.job.enabled=false(或注释属性输出)并尝试从@IntegrationTest@TestPropertySource驱动它,则它的行为与预期相同。
我理解值的重写不正确吗?

任何帮助,将不胜感激。

+0

'@ ComponentScan'和'@ EnableAutoConfiguration'不属于测试类。这只是噪音,因为他们什么都不做。 –

+0

@DaveSyer工作原理(注意'@ EnableAutoConfiguration'): @RunWith(SpringJUnit4ClassRunner。类) @EnableBatchProcessing @IntegrationTest({ “spring.batch.job.enabled =假”}) @EnableAutoConfiguration @TestPropertySource(位置= { “类路径:env.properties”, “类路径:database.properties”}) @SpringApplicationConfiguration(类= {} GetMarkerViaSpringBatchApplicationTest.class, 位置= { “类路径:**/GetMarkerViaSpringBatchApplicationTest-context.xml的”}) 公共类GetMarkerViaSpringBatchApplicationTest { –

+0

@DaveSyer这不工作(注意没有'@ EnableAutoConfiguration' ) 获取“No bean named'jobRepository'is defined”error: @RunWith(SpringJUnit4ClassRunner.class) @EnableBatchProces唱 @IntegrationTest({“spring.batch.job.enabled = false”}) @TestPropertySource(locations = {“classpath:env.properties”,“classpath:database.properties”}) @SpringApplicationConfiguration(classes = { GetMarkerViaSpringBatchApplicationTest.class}, 位置= { “类路径:**/GetMarkerViaSpringBatchApplicationTest-context.xml的”}) 公共类GetMarkerViaSpringBatchApplicationTest { –

回答

1

如果您将application.properties添加到@TestPropertySource那么它最终将覆盖其他内容。如果您使用弹簧引导,则不需要它。

+0

确实,这似乎是问题所在。如果您可以查看针对您的'@ EnableAutoConfiguration'建议的回复评论,这将会有所帮助。我怀疑我的问题与将XML文件与Java类配置文件混合。 –

相关问题