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; }