
spring 5 webflux 中 dopostandsavelist 方法返回数据的问题
代码中,dopostandsavelist 方法被定义为返回 mono
解决方法
要让 dopostandsavelist 方法返回请求回来的 flatmap 中的 jsonarray,可以采用以下方法:
- 将 string groupsstr 声明块移动到 log.info("进入dopost方法"); 语句下方。
- 将响应的处理代码放入 map 操作符中,并用 return mono.just(jsonobjectjsonarray); 替换 log.info("groupsstr:{}") 语句。
- 将 if 判断块改写为 if (jsonobjectjsonarray == null),并用 return mono.empty(); 替换 return null; 语句。
- 删除 subscribe(); 语句。
修改后的代码如下:
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);
}
});
}










