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

问题描述

我想在 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();
}

解决方法

嗯，如果您提供了一些错误日志，那就太好了。无论如何，如果您想创建一个多部分主体，则有一个构建器 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();