我有一份工作,负责处理所有文件并将其从一个目录复制到另一个目录。在执行此步骤之后,我想删除第一个目录,但是在尝试删除最后一个已处理(已复制)的文件时出现错误,结果是一个文件夹中只有一个无法删除的文件,而这个文件恰好是最后一个文件已处理的
My StepExecutionListener如下所示:
public class CleanUpListener implements StepExecutionListener {
private static final Logger logger = LoggerFactory.getLogger(CleanUpListener.class);
private String folderToBeDeleted;
@Override
public ExitStatus afterStep(StepExecution arg0) {
try {
logger.info("Deleting folder: " + folderToBeDeleted + " ...");
File file = new File(folderToBeDeleted);
logger.info("folder contains: " + file.listFiles().length);
FileUtils.deleteDirectory(file);
logger.info("Deleted folder: " + folderToBeDeleted);
} catch (IOException e) {
logger.error("Failed to delete folder: " + folderToBeDeleted + " with exception: " + e.toString());
}
return null;
}
@Override
public void beforeStep(StepExecution arg0) {
// TODO Auto-generated method stub
}
public String getFolderToBeDeleted() {
return folderToBeDeleted;
}
public void setFolderToBeDeleted(String folderToBeDeleted) {
this.folderToBeDeleted = folderToBeDeleted;
}
}
产生结果:
11/03/2014 13:53:56.804 [http-bio-8080-exec-2] [] INFO CleanUpListener - Line (29) Deleting folder: C:/Myfolder ...
11/03/2014 13:53:56.806 [http-bio-8080-exec-2] [] INFO CleanUpListener - Line (31) folder contains: 14
11/03/2014 13:53:56.826 [http-bio-8080-exec-2] [] ERROR CleanUpListener - Line (35) Failed to delete folder: C:/Myfolder with exception: java.io.IOException: Unable to delete file: C:/Myfolder/14.xml
除最后一个已处理的文件(14.xml)外,所有文件均被删除。
更新:该步骤的读者:
<bean id="modelReader"
class="org.springframework.batch.item.file.MultiResourceItemReader"
scope="step">
<property name="resources" value="file:${step3.reader.resource}/*.xml"></property>
<property name="delegate" ref="staxPatentReader"></property>
<property name="strict" value="true"></property>
</bean>
<bean id="staxPatentReader" class="org.springframework.batch.item.xml.StaxEventItemReader">
<property name="fragmentRootElementName" value="Root" />
<property name="unmarshaller" ref="modelMarshaller" />
</bean>
<bean id="modelMarshaller" class="org.springframework.oxm.jaxb.Jaxb2Marshaller">
<property name="classesToBeBound">
<list>
<value>com.sample.MyModel</value>
</list>
</property>
</bean>
对于此类步骤,请使用自定义Tasklet实现。
class DeleteFilesTasklet implements Tasklet {
execute(StepContribution, ChunkContext) throws Exception {
// do deletion and return the right value
}
}
在你的job.xml中
<job>// previous steps
<step id="deleteFiles">
<tasklet ref="deleteFiles" />
</step>
<bean class="DeleteFilesTasklet" id="deleteFiles" />
</job>
这样,您可以确保在上一步中已关闭所有文件(和其他资源)。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句