如何在spring-webflux中调用微服务来获取数据

Question

我想在spring-flux中使用webclient从另一个服务调用微服务。但是，我不能正确地编写代码。你能建议一下如何呼叫其他服务吗。请在下面找到我的代码。

我需要拨打以下服务

public Mono<ServerResponse> load(ServerRequest res){
String c1name = res.pathVariable("cust");
String c2name = res.queryParam("cl").orElse("");
String oname = res.queryParam("ol").orElse("");
return res.body()
}

public Mono<ResponseEntity<Void>> ftpFileSend(MultipartFile fileData, String cust, MultiValueMap<String,String) qpar {
MultiValueMap<String,String> qpar=new LinkedMultiValueMap<String,String>();
qpar.add("name","spring");
MultiValueMap<String,Object> body=new LinkedMultiValueMap<String,Object>();
String url="http://localhost:8088/"+ cust+"/load";
try {
body.add("file", fileData.getBytes());
} catch (IOException e) {
return Mono.error(e);   // <-- note how to create an error signal
}

return webClient
.post()
.uri(uriBuilder -> uriBuilder.path(url).queryParams(qpar).build() )
.contentType(MediaType.MULTIPART_FORM_DATA)
.body(BodyInserters.fromMultipartData(body))
.retrieve()
.toBodilessEntity();
}

Answer 1

如果你提供了一些错误日志，那就太好了。无论如何，如果你想创建一个多部分的主体，有一个生成器MultipartBodyBuilder(在org.springframework.http.client.MultipartBodyBuilder中(。

示例用法如下，

MultipartBodyBuilder builder = new MultipartBodyBuilder();
builder.part("file", new MultipartFileResource(fileData));
MultiValueMap<String, HttpEntity<?>> multipartBody = builder.build();

然后在webClient调用中使用此multipartBody。

return webClient
...
.body(BodyInserters.fromMultipartData(multipartBody))
.retrieve()
.toBodilessEntity();