我有一個(gè)使用 Springboot Resttemplate 的 springboot 項(xiàng)目。我們已經(jīng)從 1.5.3 遷移到 springboot 2.0.1，我們正試圖通過(guò)使用 WebClient 使它的其余調(diào)用異步。我們?cè)?jīng)使用 Resttemplate 處理接收到的字符串，如下所示。但 WebClient 僅返回 Mono 或 Flux 中的數(shù)據(jù)。如何獲取字符串形式的數(shù)據(jù)。已經(jīng)嘗試過(guò) block() 方法，但它執(zhí)行異步調(diào)用。@Retryable(maxAttempts = 4, value = java.net.ConnectException.class, backoff = @Backoff(delay = 3000, multiplier = 2))public Mono<String> getResponse(String url) { return webClient.get().uri(urlForCurrent).accept(APPLICATION_JSON) .retrieve() .bodyToMono(String.class);}使用 RestTemplate 呈現(xiàn)數(shù)據(jù)流控制器接收客戶端調(diào)用provider 獲取 String 格式的數(shù)據(jù)提供程序處理字符串?dāng)?shù)據(jù)被提供給控制器Controller.java@RequestMapping(value = traffic/, method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)public String getTraffic(@RequestParam("place") String location) throws InterruptedException, ExecutionException { String trafficJSON = Provider.getTrafficJSON(location) return trafficJSON;}Provider.javapublic String getTrafficJSON(String location) { String url = ----; ResponseEntity<String> response = dataFetcher.getResponse(url); /// RESPONSEBODY IS READ AS STRING AND IT NEEDS TO BE PROCESSED if (null != response { return parser.transformJSON(response.getBody(), params); } return null;}DataFetcher.java@Retryable(maxAttempts = 4, value = java.net.ConnectException.class, backoff = @Backoff(delay = 3000, multiplier = 2))public ResponseEntity<String> getResponse(String url) { /* ----------------------- */ return getRestTemplate().getForEntity(urlForCurrent, String.class);}
如何使用 WebClient 而不是 RestTemplate 來(lái)執(zhí)行非阻塞和異步調(diào)用
動(dòng)漫人物
2023-05-17 14:28:16
