◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。
spring 5 webflux 中 dopostandsavelist 方法返回数据的问题
代码中,dopostandsavelist 方法被定义为返回 mono
解决方法
要让 dopostandsavelist 方法返回请求回来的 flatmap 中的 jsonarray,可以采用以下方法:
修改后的代码如下:
public Mono<JSONArray> doPostAndSaveList(String token, Map<String, Object> bodyMap) { log.info("进入doPost方法"); return WebClient.create(baseUrl) .post() .uri(uriBuilder -> uriBuilder.path(uri) .queryParam("access_token", token) .build()) .bodyValue(bodyMap) .retrieve() .bodyToMono(JSONObject.class) .subscribeOn(Schedulers.elastic()) .flatMap(jsonObject -> { JSONArray groupsStr = jsonObject.getJSONArray("group_chat_list"); log.info("groupsStr: {}", groupsStr); if (groupsStr == null) { return Mono.empty(); } else { return Mono.just(groupsStr); } }); }
◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。