修改了TimerTask无法重复使用的问题

src/main/java/com/comleader/ldmapdownload/bean/SocketResultData.java

@@ -4,6 +4,8 @@ import com.comleader.ldmapdownload.util.OperationTypeEnum;
 
 import java.io.Serializable;
 import java.util.Map;
+import java.util.Timer;
+import java.util.TimerTask;
 
 /**
  * @ClassName ResultData
@@ -77,4 +79,25 @@ public class SocketResultData  implements Serializable {
     public void setBody(Map<String, Object> body) {
         this.body = body;
     }
+
+    //public static void main(String[] args) throws InterruptedException {
+    //
+    //    Timer timer = new Timer();
+    //    timer.schedule(new TimerTask() {
+    //        @Override
+    //        public void run() {
+    //            System.out.println("timer start");
+    //        }
+    //    }, 0, 1000);
+    //    Thread.sleep(1000);
+    //    timer.cancel();
+    //    timer.cancel();
+    //    timer = new Timer();
+    //    timer.schedule(new TimerTask() {
+    //        @Override
+    //        public void run() {
+    //            System.out.println("after cancel");
+    //        }
+    //    }, 1000, 2000);
+    //}
 }

src/main/java/com/comleader/ldmapdownload/service/DownMapService.java

@@ -59,6 +59,10 @@ public class DownMapService {
 
     public static volatile boolean isBusy = false; // 正在下载
 
+    private Timer scheduleTimer;
+
+    private Timer speedTimer;
+
     /**
      * @param body
      * @param session
@@ -111,7 +115,7 @@ public class DownMapService {
             }
         }
         // 启动一个定时器,每秒刷新下载速度
-        Timer speedTimer = new Timer();
+        speedTimer = new Timer();
         speedTimer.schedule(new TimerTask() {
             @Override
             public void run() {
@@ -123,7 +127,7 @@ public class DownMapService {
             }
         }, 1000, 1000);
         // 刷新进度
-        Timer scheduleTimer = new Timer();
+        scheduleTimer = new Timer();
         scheduleTimer.schedule(new TimerTask() {
             @Override
             public void run() {
@@ -149,8 +153,11 @@ public class DownMapService {
             countSuccessFile++;
             System.out.println(result);
         }
+        // 完成标志
+        this.finished = true;
         // 结束定时器
         speedTimer.cancel();
+        scheduleTimer.cancel();
         long end = System.currentTimeMillis();
         // 封装执行结果
         // 失败的个数
@@ -159,8 +166,6 @@ public class DownMapService {
         resBody.put("totalTime", (end - start) / 1000 + " s");
         // 总文件大小
         resBody.put("totalSize", CLStringUtil.getDownTotalSize());
-        // 完成标志
-        this.finished = true;
         log.info("falidNum > "+errResults.size());
         log.info("totalTime > "+(end - start) / 1000 + " s");
         log.info("totalSize > "+CLStringUtil.getDownTotalSize());

src/main/java/com/comleader/ldmapdownload/socket/DownLoadMapWebSocket.java

@@ -44,6 +44,10 @@ public class DownLoadMapWebSocket {
 
     private String name; // 当前连接的客户端的用户名
 
+    private Timer scheduleTimer;
+
+    private Timer speedTimer;
+
     /*
      * @description:  websocket无法通过@Autowried注入Service,需要通过如下方式进行解决
      **/
@@ -166,14 +170,14 @@ public class DownLoadMapWebSocket {
 
     private void downLoadMap(SocketResultData socketData, Session session) throws Exception {
         // 创建定时任务向前端发送速度\进度
-        Timer speedTimer = new Timer();
+        speedTimer = new Timer();
         // 每隔三秒汇报一次
         speedTimer.schedule(new TimerTask() {
             @Override
             public void run() {
                 // 发送了停止命令或者已经完成
                 if (DownMapService.stoped || DownMapService.finished) {
-                    speedTimer.cancel();
+                    speedTimer.purge();
                 }else {
                     // 发送速度
                     SocketResultData speed = new SocketResultData(OperationTypeEnum.SYS_SUCCESS, "下载速度" + DownMapService.speed + "张/s", null);
@@ -182,7 +186,7 @@ public class DownLoadMapWebSocket {
             }
         }, 1000, 1000);
         // 创建定时任务向前端发送进度
-        Timer scheduleTimer = new Timer();
+        scheduleTimer = new Timer();
         // 每隔0.2秒汇报一次
         scheduleTimer.schedule(new TimerTask() {
             @Override

src/main/resources/config/download-map.properties

 # 下载地图的保存路径
-file.basepath=E:/em-downloadmap
+file.basepath=G:/em-map
 # 项目的发布地址
-file.mapImgPath=E:/em-downloadmap
+file.mapImgPath=G:/em-map
 
 # 下载地图的地址
 #天地图服务器t0-t8间选一个