前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >toParamStr支持数组

toParamStr支持数组

作者头像
阿超
发布2024-03-23 09:58:07
760
发布2024-03-23 09:58:07
举报
文章被收录于专栏:快乐阿超快乐阿超

不登高山,不知天之高也;不临深溪,不知地之厚也;不闻先王之遗言,不知学问之大也。——荀子

代码语言:javascript
复制
import org.springframework.web.reactive.function.client.WebClient;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.util.*;

public class WebClientExample {

    private static final ObjectMapper objectMapper = new ObjectMapper();

    public static void main(String[] args) {
        // 示例对象
        var searchParams = // 你的复杂对象
        
        // 将对象转换为查询参数字符串
        String queryParamStr = toParamStr(searchParams);
        
        // 使用 WebClient 发起请求
        WebClient webClient = WebClient.create("http://example.com");
        String response = webClient.get()
                .uri(uriBuilder -> uriBuilder
                        .path("/your-api-endpoint")
                        .query(queryParamStr)
                        .build())
                .retrieve()
                .bodyToMono(String.class)
                .block();

        System.out.println(response);
    }
}

这里需要一个toParamStr方法

代码如下:

代码语言:javascript
复制


import cn.hutool.core.net.url.UrlQuery;
import com.fasterxml.jackson.core.type.TypeReference;
import lombok.experimental.UtilityClass;
import org.dromara.streamquery.stream.core.collection.Maps;
import org.dromara.streamquery.stream.core.stream.Steam;

import java.net.URI;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;

import static org.dromara.streamquery.stream.core.stream.collector.Collective.entryToMap;

/**
 * ParamUtil
 *
 * @author VampireAchao<achao @ hutool.cn>
 * @since 2023/10/21
 */
@UtilityClass
public class ParamUtil {

    public static Map<String, String> getParamMapFrom(String param) {
        var queryMap =
                UrlQuery.of(param, StandardCharsets.UTF_8).getQueryMap();
        return Steam.of(queryMap)
                .map(e -> Maps.entry(String.valueOf(e.getKey()), String.valueOf(e.getValue())))
                .collect(entryToMap());
    }

    public static Map<String, String> getParamMapFrom(URI uri) {
        return getParamMapFrom(uri.getQuery());
    }

    public static String toParamStr(Object object) {
        Map<String, Object> map = JsonUtils.mapper.convertValue(object, new TypeReference<>() {
        });
        Map<String, String> resultMap = new HashMap<>();
        buildQueryMap("", map, resultMap);
        return Steam.of(resultMap)
                .map(entry -> entry.getKey() + "=" + entry.getValue())
                .join("&");
    }

    private static void buildQueryMap(String str, Object value, Map<String, String> resultMap) {
        if (value instanceof Map) {
            ((Map<?, ?>) value).forEach((k, v) -> {
                String newPrefix = str.isEmpty() ? k.toString() : str + "." + k;
                buildQueryMap(newPrefix, v, resultMap);
            });
        } else if (value instanceof Iterable<?>) {
            Steam.of((Iterable<?>) value).forEachIdx((item, index) -> {
                String newPrefix = String.format("%s[%d]", str, index);
                buildQueryMap(newPrefix, item, resultMap);
            });
        } else {
            resultMap.put(str, Objects.toString(value, ""));
        }
    }
}

单测

代码语言:javascript
复制


import cn.hutool.core.util.URLUtil;
import org.dromara.streamquery.stream.core.collection.Maps;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

/**
 * ParamUtilTest
 *
 * @author VampireAchao<achao @ hutool.cn>
 * @since 2023/10/21
 */
class ParamUtilTest {

    @Test
    void getParamMapFromTest() {
        var uri = URLUtil.toURI("http://localhost:8080?userId=1&name=achao");
        var paramMapFrom = ParamUtil.getParamMapFrom(uri);
        Assertions.assertEquals("1", paramMapFrom.get("userId"));
        Assertions.assertEquals("achao", paramMapFrom.get("name"));

        paramMapFrom = ParamUtil.getParamMapFrom("?userId=1&name=achao");
        Assertions.assertEquals("1", paramMapFrom.get("userId"));
        Assertions.assertEquals("achao", paramMapFrom.get("name"));

        paramMapFrom = ParamUtil.getParamMapFrom("userId=1&name=achao");
        Assertions.assertEquals("1", paramMapFrom.get("userId"));
        Assertions.assertEquals("achao", paramMapFrom.get("name"));
    }

    @Test
    void toParamStrTest() {
        var map = Maps.of();
        map.put("name", "jack");
        map.put("data", Maps.of("age", 18));
        map.put("parameterTypes", new Class[]{String.class, Integer.class});
        map.put("position", new int[][]{new int[]{1, 2}, new int[]{3, 4}});
        var paramStr = ParamUtil.toParamStr(map);
        Assertions.assertEquals("parameterTypes[1]=java.lang.Integer&name=jack&position[1][0]=3&parameterTypes[0]=java.lang.String&data.age=18&position[1][1]=4&position[0][1]=2&position[0][0]=1", paramStr);
    }

}
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2024-03-22,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档