diff --git a/src/main/java/com/llthunder/csdn/AutoRefreshService.java b/src/main/java/com/llthunder/csdn/AutoRefreshService.java index 1b64d516189006f67a4beedc5d15519d0f908e06..455a93f78502690d4176c97a84cef4a4570ededc 100644 --- a/src/main/java/com/llthunder/csdn/AutoRefreshService.java +++ b/src/main/java/com/llthunder/csdn/AutoRefreshService.java @@ -78,18 +78,22 @@ public class AutoRefreshService { this.getAllArticleUrl(); long i = 1; while (true){ - System.out.println("第" + i + "遍访问开始"); - allArticleUrl.parallelStream().forEach(articleUrl -> { - ResponseEntity forEntity = new RestTemplate().getForEntity(articleUrl, String.class); - String msg = forEntity.getStatusCode() == HttpStatus.OK ? "访问成功" : "访问失败"; - System.out.println(articleUrl + msg); - }); - System.out.println("第" + i + "遍访问结束"); - TimeUnit.SECONDS.sleep(sleepSecondNum); - if(i % 10 == 0){ - this.getAllArticleUrl(); + try { + System.out.println("第" + i + "遍访问开始"); + allArticleUrl.parallelStream().forEach(articleUrl -> { + ResponseEntity forEntity = new RestTemplate().getForEntity(articleUrl, String.class); + String msg = forEntity.getStatusCode() == HttpStatus.OK ? "访问成功" : "访问失败"; + System.out.println(articleUrl + msg); + }); + System.out.println("第" + i + "遍访问结束"); + TimeUnit.SECONDS.sleep(sleepSecondNum); + if(i % 10 == 0){ + this.getAllArticleUrl(); + } + i++; + }catch (Exception e){ + System.out.println(e.getMessage()); } - i++; } } }