下载完关闭流

src/main/java/com/ann/job/ScheduledJob.java

@@ -5,10 +5,7 @@ import com.ann.service.MessageSubordinateService;
 import com.ann.service.impl.QueueService;
 import com.ann.utils.ExceptionPrintUtil;
 import com.ann.utils.QuartzUtils;
-import org.quartz.Job;
-import org.quartz.JobExecutionContext;
-import org.quartz.JobExecutionException;
-import org.quartz.Scheduler;
+import org.quartz.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -16,6 +13,7 @@ import org.springframework.util.StopWatch;
 
 import java.time.LocalTime;
 import java.util.List;
+import java.util.concurrent.atomic.AtomicBoolean;
 
 /**
  * 取从属表未解析的数据
@@ -23,6 +21,7 @@ import java.util.List;
  * @Author: LeiJiaXin
  * @Date: 2019/8/16 10:11
  */
+@DisallowConcurrentExecution
 public class ScheduledJob implements Job {
 
     static final Logger logger = LoggerFactory.getLogger(ScheduledJob.class);

src/main/java/com/ann/utils/FTPUtil.java

@@ -66,6 +66,9 @@ public class FTPUtil {
             }
         } catch (IOException e) {
             throw e;
+        }finally {
+            ftpClient.abort();
+            ftpClient.disconnect();
         }
         return ftpClient;
     }