【发布时间】:2016-04-08 14:28:33
【问题描述】:
你好还在学习希望有人能填补空白
我的JSVC石英弹簧批处理系统已经运行了一年多。 Job 启动器需要连接 2 个在系统其他部分成功运行的 Spring 服务。每个服务都有许多注入到其中的 sql 存储库或服务。 请注意包装声明。用于应用程序上下文条目。
package com.mycompany.business.services.impl;
....
@Service
public class BatchProcessService {
private final DomainSepcificRepository1 rep1;
...
private final DomainSepcificRepositoryN repN;
@Inject
public BatchProcessService(Final final DomainSepcificRepository1 rep1,..., final DomainSepcificRepositoryN repN) {
// injected values assigned to instance variables.
}
public List <...> findByCriteria(.....)(
.....
}
}
和
package com.mycompany.business.services.impl;
....
@Service
public class EmailNotificationServiceImpl implements EmailNotificationService {
private UserService userService;
private final MailMessage mailMessage;
private final MailTransport mailTransport;
@Inject
public EmailNotificationServiceImpl(final UserService userService, final MailMessage mailMessage, final MailTransport mailTransport) {
this.userService = userService;
this.mailMessage = mailMessage;
this.mailTransport = mailTransport;
}
.....
public void notifySupportStaff(....){
.....
}
}
在我的应用程序上下文 xml 文件中,有以下行应该允许我的作业启动器查看和实例化上述服务。我认为“base-package=”指定了要查找可以注入的@services、@components 和@repositories 的包。
<context:component-scan base-package="com.mycompany.common.batch, com.mycompany.batch, com.mycompany.business.services" >
<context:exclude-filter type="assignable" expression="com.mycompany.common.batch.scheduler.service.MyCompanySchedulerService"/>
</context:component-scan>
- 我认为@Component 应该允许此类查看服务并实例化它们以及它们拥有的任何依赖项(其他服务)。
- 出于某种原因,jsvc 系统只想使用 NO arg 构造函数调用下面的类。并且它没有注入这 2 个服务。
- 只有当我为 MOCK 服务提供 2 参数构造函数时,我的单元测试才能使用该服务测试该方法。 lll
关于为什么批处理系统不能注入依赖项的任何想法?
package com.mycompany.batch.scheduler;
....
@Inject
private BatchProcessService batchProcessService;
@Inject
private EmailNotificationService emailNotificationService;
@Component
public class MyCompanySchedulerJobLauncher extends SchedulerJobLauncher {
public MyCompanySchedulerJobLauncher() {
super();
}
// @Inject
public MyCompanySchedulerJobLauncher(final BatchProcessService batchProcessService, final EmailNotificationService emailNotificationService) {
super();
this.batchProcessService = batchProcessService;
this.emailNotificationService = emailNotificationService;
}
@Override
public int processJob(final JobExecutionContext context) throws JobRestartException, JobExecutionAlreadyRunningException, ParseException {
......
if(batchProcessSerive.findByCriteria(....).size() == 0) {
emailNotificationService.notifySupport(...)
}
}
【问题讨论】:
-
我的一位同事发现了我的问题
标签: spring spring-batch