From b62d6e18c85837649bb3fb6063e92a06ab433ba2 Mon Sep 17 00:00:00 2001 From: Achilles Date: Thu, 4 Jan 2024 15:20:43 +0800 Subject: [PATCH] =?UTF-8?q?=E8=82=A1=E7=A5=A8=E8=AF=A6=E6=83=85=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E6=8F=90=E4=BE=9B=E9=87=8D=E8=AF=95=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../stock/market/web/MoneyApiController.java | 24 +++++++++++++++---- 1 file changed, 19 insertions(+), 5 deletions(-) diff --git a/src/main/java/cn/stock/market/web/MoneyApiController.java b/src/main/java/cn/stock/market/web/MoneyApiController.java index 17101c6..7c359d1 100644 --- a/src/main/java/cn/stock/market/web/MoneyApiController.java +++ b/src/main/java/cn/stock/market/web/MoneyApiController.java @@ -10,9 +10,7 @@ import io.swagger.annotations.ApiResponses; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpMethod; import org.springframework.http.ResponseEntity; -import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.RestController; @@ -137,9 +135,25 @@ public class MoneyApiController { @ResponseBody public JSONObject forwardRequest(@RequestParam String stockType, @RequestParam String symbol) { String url = String.format("https://priceapi.moneycontrol.com/pricefeed/%s/equitycash/%s",stockType,symbol); - ResponseEntity responseEntity = restTemplate.exchange(url, HttpMethod.GET, null, String.class); - if (responseEntity.getStatusCode().value()==200&&responseEntity.getBody()!=null){ - return JSONObject.parseObject(responseEntity.getBody()); + + // 设置重试次数 + int maxRetries = 3; + for (int retry = 1; retry <= maxRetries; retry++) { + ResponseEntity responseEntity = restTemplate.exchange(url, HttpMethod.GET, null, String.class); + + if (responseEntity.getStatusCode().value() == 200 && responseEntity.getBody() != null) { + return JSONObject.parseObject(responseEntity.getBody()); + } + + // 如果不是最后一次重试，则等待一段时间再进行下一次重试 + if (retry < maxRetries) { + try { + // 你可以根据需要调整等待的时间 + Thread.sleep(100); // 1秒钟 + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); + } + } } return null; }