java - Spring调度器多次执行任务

Question

如标题所述，我在 spring web 应用程序中设置了一个调度程序，它似乎在一个循环中运行，随机时间，从 8 次调用开始，然后随机添加。我正在使用 spring 版本 3.1.3.RELEASE。我绝不是这方面的专家，但我过去已经为大约 5-6 个其他项目完成了相同的调度配置。我总是添加 spring 任务配置，如调度程序和注释驱动指令。然后在方法上添加一个 @Scheduled 注释，效果非常好。我也在 1 个月前使用相同版本的 Spring 成功调度，所以我相信这不是 Spring 版本问题。我在下面给出了配置和 bean 代码。请不要犹豫，询问更多信息:)

感谢您的宝贵时间!

pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.fileExport</groupId>
  <artifactId>FileExportDaemon</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>war</packaging>

  <properties>
        <spring.version>3.1.3.RELEASE</spring.version>
  </properties>

  <dependencies>

        <!-- The SFL4J logging implementation you prefer -->
        <!-- 
         <dependency>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-simple</artifactId>
          <version>1.6.1</version>
        </dependency> 
          -->

        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.5</version> 
        </dependency>

          <!--
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>log4j-over-slf4j</artifactId>
             <version>1.7.5</version> 
        </dependency>
          -->
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>1.7.5</version>
        </dependency>


        <!-- JCR API -->
        <dependency>
          <groupId>javax.jcr</groupId>
          <artifactId>jcr</artifactId>
          <version>2.0</version>
        </dependency>

        <!-- All the Jackrabbit libraries needed for DavEx, plus JcrUtils -->
        <dependency>
            <groupId>org.apache.jackrabbit</groupId>
            <artifactId>jackrabbit-jcr2dav</artifactId>
            <version>2.7.1</version>
        </dependency>



        <dependency>
            <groupId>org.apache.jackrabbit</groupId>
            <artifactId>jackrabbit-api</artifactId>
            <version>2.7.1</version>
        </dependency>


        <dependency>
            <groupId>org.freemarker</groupId>
            <artifactId>freemarker</artifactId>
            <version>2.3.19</version>
        </dependency>

        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-email</artifactId>
            <version>1.2</version>
        </dependency>

        <dependency>
            <groupId>commons-net</groupId>
            <artifactId>commons-net</artifactId>
            <version>3.3</version>
        </dependency>


        <dependency>
            <groupId>commons-collections</groupId>
            <artifactId>commons-collections</artifactId>
            <version>3.2</version>
        </dependency>

        <dependency>
            <groupId>commons-lang</groupId>
            <artifactId>commons-lang</artifactId>
            <version>2.4</version>
        </dependency>

        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>jstl</artifactId>
            <version>1.2</version>
        </dependency>

        <dependency>
            <groupId>taglibs</groupId>
            <artifactId>standard</artifactId>
            <version>1.1.2</version>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.10</version>
            <scope>test</scope>
        </dependency>


        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>



        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>${spring.version}</version>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-web</artifactId>
            <version>${spring.version}</version>
        </dependency>


        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-orm</artifactId>
            <version>${spring.version}</version>
        </dependency>

  </dependencies>

  <profiles>
        <profile>
            <id>dev</id>
            <activation>
                <activeByDefault>true</activeByDefault>
            </activation>
            <properties>
                <env>dev</env>
            </properties>
        </profile>
        <profile>
            <id>prod</id>
            <properties>
                <env>prod</env>
            </properties>
        </profile>
    </profiles>

    <build>
        <finalName>fileExportDaemon</finalName>
        <filters>
            <filter>${env}.properties</filter>
        </filters>
        <resources>
            <resource>
                <directory>src/main/resources</directory>
                <filtering>true</filtering>
            </resource>
        </resources>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-resources-plugin</artifactId>
                <version>2.4.2</version>
                <configuration>
                    <encoding>UTF-8</encoding>
                </configuration>
            </plugin>
        </plugins>
    </build>  


</project>

应用程序上下文.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:security="http://www.springframework.org/schema/security"
  xmlns:context="http://www.springframework.org/schema/context"
  xmlns:tx="http://www.springframework.org/schema/tx"
  xmlns:jee="http://www.springframework.org/schema/jee"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xmlns:mvc="http://www.springframework.org/schema/mvc"
  xmlns:webflow="http://www.springframework.org/schema/webflow-config"
  xmlns:task="http://www.springframework.org/schema/task"
  xmlns:util="http://www.springframework.org/schema/util"
  xsi:schemaLocation="http://www.springframework.org/schema/beans
          http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
          http://www.springframework.org/schema/context 
          http://www.springframework.org/schema/context/spring-context-3.1.xsd
          http://www.springframework.org/schema/tx 
          http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
          http://www.springframework.org/schema/jee 
          http://www.springframework.org/schema/jee/spring-jee-3.1.xsd
          http://www.springframework.org/schema/security
          http://www.springframework.org/schema/security/spring-security-3.1.3.xsd
          http://www.springframework.org/schema/mvc 
          http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd
          http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.1.xsd
          http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd
          http://www.springframework.org/schema/webflow-config
          http://www.springframework.org/schema/webflow-config/spring-webflow-config-2.3.xsd">

    <bean id="propertyConfigurer"
        class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <list>
                <value>classpath:configuration.properties</value>
            </list>
        </property>
        <property name="fileEncoding" value="utf-8"/>
    </bean>

    <import resource="fileExportDaemon-service.xml"/>

    <import resource="fileExportDaemon-servlet.xml"/>

    <!-- Tasks Configuration -->
     <task:annotation-driven scheduler="myScheduler" /> 
     <task:scheduler id="myScheduler" pool-size="100" /> 

    <!-- 
    <util:properties id="applicationProps" location="classpath:configuration.properties" />
    <context:property-placeholder properties-ref="applicationProps" />

    <task:annotation-driven />
    <task:scheduled-tasks>
        <task:scheduled ref="fileExportService" method="cronExport" cron="#{applicationProps['exportDaemon.execution.cron']}"/>
    </task:scheduled-tasks>
     -->

    <context:annotation-config />

    <tx:annotation-driven />

    <mvc:annotation-driven />


</beans>

fileExportDaemon-service.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:security="http://www.springframework.org/schema/security"
  xmlns:context="http://www.springframework.org/schema/context"
  xmlns:tx="http://www.springframework.org/schema/tx"
  xmlns:jee="http://www.springframework.org/schema/jee"
  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-3.1.xsd
          http://www.springframework.org/schema/context 
          http://www.springframework.org/schema/context/spring-context-3.1.xsd
          http://www.springframework.org/schema/tx 
          http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
          http://www.springframework.org/schema/jee 
          http://www.springframework.org/schema/jee/spring-jee-3.1.xsd
          http://www.springframework.org/schema/security
          http://www.springframework.org/schema/security/spring-security-3.1.3.xsd">



    <!-- Services -->
    <bean id="fileExportService" class="com.fileExportDaemon.service.FileExportService" />


</beans>

fileExportDaemon-servlet.xml

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:p="http://www.springframework.org/schema/p"
  xmlns:security="http://www.springframework.org/schema/security"
  xmlns:context="http://www.springframework.org/schema/context"
  xmlns:tx="http://www.springframework.org/schema/tx"
  xmlns:jee="http://www.springframework.org/schema/jee"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xmlns:mvc="http://www.springframework.org/schema/mvc"
  xsi:schemaLocation="http://www.springframework.org/schema/beans
          http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
          http://www.springframework.org/schema/context 
          http://www.springframework.org/schema/context/spring-context-3.0.xsd
          http://www.springframework.org/schema/tx 
          http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
          http://www.springframework.org/schema/jee 
          http://www.springframework.org/schema/jee/spring-jee-3.0.xsd
          http://www.springframework.org/schema/security
          http://www.springframework.org/schema/security/spring-security-3.0.3.xsd
          http://www.springframework.org/schema/mvc 
          http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd">

    <context:component-scan base-package="com.fileExportDaemon" />

    <bean
        class="org.springframework.web.servlet.view.InternalResourceViewResolver"
        p:prefix="/WEB-INF/jsp/" p:suffix=".jsp" />

</beans>

文件导出服务.java

package com.fileExportDaemon.service;


public class FileExportService {

    @Value("${exportDaemon.jcr.repository.url}")
    private String jcrURL;

    @Value("${exportDaemon.filesystem.separator}")
    private String filesystemSeparator;

    @Value("${exportDaemon.path.complete}")
    private String pathComplete;

    @Value("${exportDaemon.path.incomplete}")
    private String pathIncomplete;

    Log logger = LogFactory.getLog(FileExportService.class);


    public void exportFilesWithRules(){ 

        Session jcrSession = getJcrSession(jcrURL);

        try {

             Node root = jcrSession.getRootNode();
             Node dsNode = root.getNode("DS");
             Node applicationsNode= dsNode.getNode("applications");

             NodeIterator applicationNodes = applicationsNode.getNodes();


             while (applicationNodes.hasNext()) {
                    handleNode(applicationNodes.nextNode()); 
            } 

        } catch (RepositoryException e) {
            logger.error("Repository error", e);
        } 

        logger.debug("done exporting with rules!");
    }



    public void exportFilesAll(){
        logger.debug("done exporting without rules!");
    }


    private void handleNode(Node node) throws RepositoryException { 

        logger.debug(node.getPath()); 

        Node attachments = node.getNode("attachments");
        boolean isComplete = isCompleteFiling(attachments);
        if(isComplete){

            File completedEfiling = new File(pathComplete + filesystemSeparator + node.getName());

            if (!completedEfiling.exists()){
                exportNodeFiles(attachments,pathComplete);
            }else{
                logger.debug("File exists, go to next: " + node.getName());
                return;
            }

        }else{
            logger.debug("filing Incomplete!");
            File incompletedEfilingDir = new File(pathIncomplete + filesystemSeparator + node.getName());

            if(!incompletedEfilingDir.exists()){
                exportNodeFiles(attachments, pathIncomplete);
            }else if( attachments.getNodes().getSize() != incompletedEfilingDir.list().length ){
                exportNodeFiles(attachments, pathIncomplete);
            }else{
                logger.debug("files found identical on:" + node.getName());
                return;
            }

        }

        // Skip the virtual (and large!) jcr:system subtree 
        if (node.getName().equals("jcr:system")) { 
            return; 
        }
    }


    private void exportNodeFiles (Node attachmentsNode, String destinationDir){

        File directory = null;
        try {
            directory = new File(destinationDir + filesystemSeparator + attachmentsNode.getParent().getName());
        } catch (AccessDeniedException e1) {
            logger.error("Access denied error", e1);
        } catch (ItemNotFoundException e1) {
            logger.error("Item not found.", e1);
        } catch (RepositoryException e1) {
            logger.error("Repository error.", e1);
        }

        directory.mkdir();

        NodeIterator nodeIter = null;
        try {
            nodeIter = attachmentsNode.getNodes();
        } catch (RepositoryException e) {
            logger.error("Repository error.", e);
        }

        while( nodeIter.hasNext()){

            OutputStream outputStream = null;
            InputStream is = null;

            try {
                Node nodeToStore = nodeIter.nextNode().getNode("file").getNodes().nextNode();
                Node content = nodeToStore.getNodes().nextNode();

                is = content.getProperty("jcr:data").getBinary().getStream() ;

                String a = directory.getAbsolutePath() + filesystemSeparator +nodeToStore.getName();
                outputStream = new FileOutputStream(new File( directory.getAbsolutePath() + filesystemSeparator + nodeToStore.getName() ));

                int read = 0;
                byte[] bytes = new byte[1024];

                while ((read = is.read(bytes)) != -1) {
                    outputStream.write(bytes, 0, read);
                }


            } catch (PathNotFoundException e) {
                logger.error("Path not found.", e);
            } catch (RepositoryException e) {
                logger.error("Repository error.", e);
            } catch (FileNotFoundException e) {
                logger.error("File not found.", e);
            } catch (IOException e) {
                logger.error("IO error", e);
            } finally {
                if (is != null) {
                    try {
                        is.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
                if (outputStream != null) {
                    try {
                        outputStream.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }

                }
            }//finally
        }//while nodeIter has next

    }



    private boolean isCompleteFiling(Node node){
        boolean result = false;

        NodeIterator nodeIter = null;
        try {
            nodeIter = node.getNodes();
        } catch (RepositoryException e) {
            logger.error("Repository error", e);
        }

        while(nodeIter.hasNext()){

            Node attachmentNode = nodeIter.nextNode();

            try {
                if(StringUtils.endsWith(attachmentNode.getName(), ".pdf")){
                    if ( StringUtils.equals("receipt.pdf", attachmentNode.getNode("file").getNodes().nextNode().getName() )){
                        result = true;
                    }
                }else{
                    continue;
                }
            } catch (RepositoryException e) {
                logger.error("Repository error", e);
            }
        }
        return result;
    }


    private Session getJcrSession(String url){
        Repository repository = null;
        try {
            repository = JcrUtils.getRepository(url);
        } catch (RepositoryException e) {
            logger.error("Repository error", e);
        }

        SimpleCredentials creds = new SimpleCredentials("admin","admin".toCharArray());
        Session jcrSession = null;

        try {
            jcrSession = repository.login(creds, "default");
        } catch (LoginException e) {
            logger.error("could not log in to jcr", e);
        } catch (NoSuchWorkspaceException e) {
            logger.error("Could not find workspace", e);
        } catch (RepositoryException e) {
            logger.error("Repository error", e);
        }

        return jcrSession;
    }

    @Scheduled(cron="${exportDaemon.execution.cron}" )
    public void cronExport(){

        logger.debug("Starting cron export!");
        exportFilesWithRules();


    }

}

属性

exportDaemon.jcr.repository.url=http://192.168.3.3:10080/jackrabbit-webapp-2.6.2/server
exportDaemon.execution.cron=* */5 * * * *
exportDaemon.filesystem.separator=\\
exportDaemon.path.complete=C:\\files\\export\\complete
exportDaemon.path.incomplete=C:\\files\\export\\incomplete
exportDaemon.all.filings=false

网络.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
    id="WebApp_ID" version="2.5">


    <display-name>fileExportDaemon</display-name>

    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>/WEB-INF/application-context.xml</param-value>
    </context-param>

    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>

    <servlet>
      <servlet-name>fileExportDaemon</servlet-name>
      <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
      <load-on-startup>1</load-on-startup>
    </servlet>

    <servlet-mapping>
      <servlet-name>fileExportDaemon</servlet-name>
      <url-pattern>/</url-pattern>
    </servlet-mapping>

    <filter>
        <filter-name>encodingFilter</filter-name>
        <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
        <init-param>
            <param-name>encoding</param-name>
            <param-value>UTF-8</param-value>
        </init-param>
        <init-param>
            <param-name>forceEncoding</param-name>
            <param-value>true</param-value>
        </init-param>
    </filter>

    <filter-mapping>
      <filter-name>encodingFilter</filter-name>
      <url-pattern>/*</url-pattern>
    </filter-mapping>

</web-app>

Answer 1

仅供面临相同问题的任何人使用。对于所描述的行为，我还没有找到任何合乎逻辑的解决方案，但我找到了一个很好的解决方法。正如我在问题描述中所说，我多次使用了 Scheduled 注释，当然它有效。仅在这一次，我使用了 spring-quartz 配置，而且效果很好。变化不是很大，你会发现很多关于如何在 Spring 中使用 quartz 的教程。关于这个错误，它仍然是一个谜。此时，我面前有两个使用 Scheduled 的应用程序和一个使用 quartz 的应用程序。直到现在我也搞不懂为什么会这样。