webclient远程调用

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

import cn.dev33.satoken.same.SaSameUtil;
import cn.hutool.core.map.MapUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.nacos.common.utils.JacksonUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import java.util.List;

@Service
public class AuthService {

    private final WebClient webClient;

    @Autowired
    public AuthService(WebClient.Builder webClientBuilder) {
        this.webClient = webClientBuilder.baseUrl("http://auth-service/user").build();
    }

    public Mono<List<String>> getPermissionList(Object loginId, String loginType) {
        MultiValueMap<String, String> param = new LinkedMultiValueMap<>(2);
        param.add("loginId", loginId.toString());
        param.add("loginType", loginType);
        return webClient.post()
                .uri("/getPermissionList")
                .headers(m -> {
                    m.add(SaSameUtil.SAME_TOKEN, SaSameUtil.getToken());
                })
                .body(BodyInserters.fromFormData(param))
                .retrieve()
                .bodyToFlux(String.class)
                .flatMap(str -> {
                    Hsswonse res = JacksonUtils.toObj(str, HsswResp.class);
                    return Flux.fromIterable((List<String>) res.getData());
                })
                .collectList()
                .doOnError(Throwable::printStackTrace);
    }

    public Mono<List<String>> getRoleList(Object loginId) {
        MultiValueMap<String, String> param = new LinkedMultiValueMap<>(2);
        param.add("loginId", loginId.toString());
        return webClient.post()
                .uri("/getRoleList")
                .headers(m -> {
                    m.add(SaSameUtil.SAME_TOKEN, SaSameUtil.getToken());
                })
                .contentType(MediaType.APPLICATION_JSON)
                .body(Mono.just(JSONUtil.toJsonStr(MapUtil.of("loginId", loginId))), String.class)
                .retrieve()
                .bodyToFlux(String.class)
                .doOnError(Throwable::printStackTrace)
                .flatMap(str -> {
                    HsswResponse = JacksonUtils.toObj(str, HsswResponse.cla
                    return Flux.fromIterable((List<String>) res.getData());
                })
                .collectList()
                .doOnError(Throwable::printStackTrace);
    }
}