首页 / JAVA / java-Spring Batch Job的集成测试失败

java-Spring Batch Job的集成测试失败

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java-Spring Batch Job的集成测试失败，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含9488字，纯文字阅读大概需要14分钟。

内容图文

好的,我知道从标题看这听起来很简单,但确实让我很困惑为什么会这样.

因此,我正在使用Spring Batch生成要使用Amazon的Simple Email Service发送的电子邮件.在我的CustomItemProcessor内部,我使用@Autowired正常连接我的AmazonEmailService服务. AmazonEmailService类实现了我的EmailSender接口.

AmazonEmailService具有@Autowired AmazonSimpleEmailServiceClient,它用于实际调用Amazon Simple Email Service来执行操作.

我的AmazonSimpleEmailServiceClient bean在我的root-servlet.xml中定义：

<bean id="amazonSimpleEmailServiceClient"
    class="com.amazonaws.services.simpleemail.AmazonSimpleEmailServiceClient">
    <constructor-arg ref="basicAWSCredentials" />
</bean>

<bean id="basicAWSCredentials" class="com.amazonaws.auth.BasicAWSCredentials">
    <constructor-arg index="0" value="${aws.accessKey}"/>
    <constructor-arg index="1" value="${aws.secretKey}" />
</bean>

所有这些都很好.

我的问题是,当我运行Spring Batch Job集成测试时.他们在尝试发送电子邮件时挂起.我的日志记录显示执行只是在对AmazonSimpleEmailServiceClient.send(emailRequest)的调用处停止,并且没有继续.

让我感到困惑的是,如果在为Spring Batch Jobs进行集成测试之前运行AmazonEmailService的单元测试,那么一切都将成功完成.我想知道为什么会这样.值得一提的是,实际发送电子邮件的批处理作业具有在单个线程上运行的TaskExecutor.

应对Spring Batch作业进行集成测试,以验证该作业是否成功为其收到的每个输入生成了一封电子邮件,并且可以使用Amazon SES发送这些电子邮件.它还测试它是否正确地将对象读取和写入设置的队列,但这与我的问题无关. AmazonEmailService的单元测试仅向Amazon电子邮件模拟器发送3封电子邮件.

我将在下面发布一个简化的类图,以便您可以看到事物如何结合在一起.

> EmailService接口是我自己的接口.
> AmazonEmailService是我自己的服务.该服务实际上使用AmazonSimpleEmailServiceClient执行电子邮件的发送,该对象是Amazon提供给我的对象.
> CustomItemProcessor是我自己的实现ItemProcessor接口的对象.这就是Spring Batch用来对批处理作业中的项目进行实际处理的东西.电子邮件应由此类生成和发送.
> AmazonEmailServiceTest只是测试功能的单元测试
以实际发送电子邮件.

在考虑为什么我遇到这个愚蠢的问题时,您可能会想到的事情：

>我已经正确配置了单元/集成测试以在Spring应用程序上下文中运行.
> AmazonEmailServiceTest独自成功运行.
>如果我恢复为使用简单的JavaMail电子邮件发件人,则Spring Batch集成测试将成功运行.
>使用XML config为我的所有其他类正确配置和定义了我的Spring Batch作业,应用程序上下文和bean.
>我的Amazon凭证有效并且可以正常工作.
>班级正确地自动接线.
>尝试单独或与AmazonEmailServiceTest一起运行Spring Batch测试的任何阶段都不会引发异常
>一起运行测试时,AmazonEmailService的相同实例将自动连接到两个测试中(即,两个测试使用相同的内存地址,等等)
>我无法检查实际单元测试中使用的凭据.
>我已经在XML配置中正确配置了PropertyPlaceholderConfigurer.
>在我手动停止单元测试之前,对amazonSimpleEmailServiceClient.send(emailRequest)的调用将挂起.
>可以在应用程序上下文中发现相关的Bean,以进行自动装配.

如果您需要更多信息,例如类或配置,请随时询问.我实际上是坐在电脑前等待回复.

AmazonEmailService：

@Service
public class AmazonEmailService implements EmailService {

    @Autowired
    private AmazonSimpleEmailServiceClient amazonSimpleEmailServiceClient;

    @Override
    public String sendEmail(Email email){
        //build request using Builder pattern//
        return amazonSimpleEmailServiceClient.sendEmail(emailRequest);
    }
}

CustomItemProcessor：

public class CustomProcessQueueItemProcessor implements
    ItemProcessor<Foo, Bar> {

    @Autowired
    private EmailService amazonEmailService;

    @Override
    public Bar process(Foo foo) throws Exception {
        //generate email from Foo object//
        String result = amazonEmailService.sendEmail(email);
        //create Bar object from result//
        return bar;
    }
}

AmazonEmailServiceTest：

public class AmazonEmailServiceTest extends SpringTest{

@Autowired
private EmailService amazonEmailService;

@Test
public void testSendEmailSuccess() {
    Email successEmail = MockObjectFactory.setTestSuccessEmail();
    String emailResultId = amazonEmailService.sendEmail(successEmail);
    assertNotNull("The returned emailResultId was null", emailResultId);
}
}

我在SpringTest类中配置单元测试以在Spring应用程序上下文中运行.顾名思义,我的MockObjectFactory是一个包含用于生成测试对象的静态方法的类.

批处理Servlet：

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

    <import resource="jobs/fill-queue-job.xml" />
    <import resource="jobs/process-queue-job.xml" />

    <batch:job-repository id="jobRepository"
        data-source="dataSource" transaction-manager="transactionManager" />

    <bean id="jobLauncher"
        class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
        <property name="jobRepository" ref="jobRepository" />
        <property name="taskExecutor" ref="defaultTaskExecutor"></property>
    </bean>

    <bean id="jobRegistry"
        class="org.springframework.batch.core.configuration.support.MapJobRegistry" />

    <bean id="jobRegistryBeanPostProcessor"
        class="org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor">
        <property name="jobRegistry" ref="jobRegistry" />
    </bean>

    <bean id="jobLoader"
        class="org.springframework.batch.core.configuration.support.DefaultJobLoader">
        <property name="jobRegistry" ref="jobRegistry" />
    </bean>

    <bean id="jobExplorer"
        class="org.springframework.batch.core.explore.support.JobExplorerFactoryBean">
        <property name="dataSource" ref="dataSource" />
    </bean>

    <bean id="jobOperator"
        class="org.springframework.batch.core.launch.support.SimpleJobOperator">
        <property name="jobLauncher" ref="jobLauncher" />
        <property name="jobRepository" ref="jobRepository" />
        <property name="jobRegistry" ref="jobRegistry" />
        <property name="jobExplorer" ref="jobExplorer" />
    </bean>

    <bean id="domainObjectIdQueue" class="java.util.concurrent.ConcurrentLinkedQueue" />

    <bean id="mainQueue" class="java.util.concurrent.ConcurrentLinkedQueue" />

    <bean id="notificationQueue" class="java.util.concurrent.ConcurrentLinkedQueue" />

    <bean id="fillQueueItemReader"
        class="au.com.mail.batch.itemreaders.CustomServiceItemReader"
        scope="step">
        <constructor-arg ref="emailTaskServiceImpl" />
    </bean>

    <bean id="fillQueueItemProcessor"
        class="au.com.mail.batch.itemprocessors.CustomFillQueueItemProcessor"
        scope="step" />

    <bean id="fillQueueCompositeItemWriter"
        class="org.springframework.batch.item.support.CompositeItemWriter">
        <property name="delegates">
            <list>
                <bean id="fillQueueItemWriter"
                    class="au.com.mail.batch.itemwriters.CustomQueueItemWriter"
                    scope="step" />
                <bean id="emailTaskItemWriter"
                    class="au.com.mail.batch.itemwriters.CustomServiceItemWriter"
                    scope="step">
                    <constructor-arg ref="emailTaskServiceImpl" />
                </bean>
            </list>
        </property>
    </bean>

    <bean id="processQueueItemReader"
        class="au.com.mail.batch.itemreaders.CustomQueueItemReader"
        scope="step">
        <constructor-arg>
            <value type="java.lang.Class">au.com.mail.domainobject.messagewrappers.MainQueueMessageWrapper
            </value>
        </constructor-arg>
    </bean>

    <bean id="processQueueItemProcessor"
        class="au.com.mail.batch.itemprocessors.CustomProcessQueueItemProcessor"
        scope="step" />

    <bean id="processQueueItemWriter"
        class="au.com.mail.batch.itemwriters.CustomQueueItemWriter"
        scope="step" />

    <bean id="defaultTaskExecutor"
        class="org.springframework.scheduling.quartz.SimpleThreadPoolTaskExecutor">
        <property name="threadCount" value="5" />
    </bean>

    <bean id="processQueueTaskExecutor"
        class="org.springframework.scheduling.quartz.SimpleThreadPoolTaskExecutor">
        <property name="threadCount" value="1" />
    </bean>


    <bean id="customStepExecutionListener" class="au.com.mail.batch.CustomStepExecutionListener"
        scope="step" />

    <bean id="jobLauncherTestUtils" class="org.springframework.batch.test.JobLauncherTestUtils">
        <property name="job" ref="fillQueue" />
        <property name="jobRepository" ref="jobRepository" />
        <property name="jobLauncher" ref="jobLauncher" />
    </bean>
</beans>

流程队列作业定义：

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

    <beans:bean id="repeatQueueOpenTasklet"
        class="au.com.mail.batch.CustomQueueRetryTaskletImpl" scope="step" />

    <job id="processQueue" job-repository="jobRepository">
        <step id="getQueue">
            <tasklet ref="repeatQueueOpenTasklet" task-executor="processQueueTaskExecutor">
            </tasklet>
            <end on="FAILED" exit-code="NOOP" />
            <next on="*" to="sendEmail" />
        </step>
        <step id="sendEmail">
            <tasklet task-executor="processQueueTaskExecutor">
                <chunk reader="processQueueItemReader" processor="processQueueItemProcessor"
                    writer="processQueueItemWriter" commit-interval="5" />
            </tasklet>
            <listeners>
                <listener ref="customStepExecutionListener"></listener>
            </listeners>
        </step>
    </job>
</beans:beans>

大更新：
我从流程队列Tasklet上删除了processQueueTaskExecutor,并从jobLauncher中删除了defaultTaskExecutor,Amazon服务调用成功.现在我只需要知道为什么会这样.

解决方法:

从您的帖子中还不清楚您的“单元”测试实际上是在尝试测试.可以肯定地说,亚马逊的电子邮件服务已经过了良好的测试,并且不需要在单元测试中进行实际测试.

相反,您可以为您的单元测试创??建一个新的测试Spring上下文,以提供EmailService的模拟,然后在您的单元测试中验证在您期望的时候实际上正在调用emailService.sendEmail(…)方法,与您期望的内容.这样,您的测试就无需与任何实际的电子邮件服务进行交互.

内容总结

以上是互联网集市为您收集整理的java-Spring Batch Job的集成测试失败全部内容，希望文章能够帮你解决java-Spring Batch Job的集成测试失败所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/659273.html

来源：【匿名】