toParamStr支持数组

简介: toParamStr支持数组


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

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方法

代码如下:

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, ""));
        }
    }
}

单测

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);
    }
}
相关文章
|
前端开发 Java 数据安全/隐私保护
聊聊 OAuth 2.0 的 Token 续期处理
Token 校验逻辑 // CheckTokenEndpoint.checkToken @RequestMapping(value = "/oauth/check_token") @ResponseBody public Map checkToken(@RequestPara.
2316 0
|
安全 关系型数据库 数据安全/隐私保护
IAM最佳实践
企业上云最基本的账户权限安全实践
7697 0
|
9月前
|
数据采集 人工智能 JavaScript
Browser Use:40.7K Star!一句话让AI完全接管浏览器!自动规划完成任务,多标签页同时管理
Browser Use 是一款专为大语言模型设计的智能浏览器自动化工具,支持多标签页管理、视觉识别、内容提取等功能,并能记录和重复执行特定动作,适用于多种应用场景。
2478 21
Browser Use:40.7K Star!一句话让AI完全接管浏览器!自动规划完成任务,多标签页同时管理
|
10月前
|
JSON 搜索推荐 数据挖掘
Temu商品列表数据接口(Temu API系列)
Temu作为新兴跨境电商平台,为全球卖家和消费者搭建便捷交易桥梁。通过商品列表数据接口,开发者、分析师可获取商品名称、价格、销量等信息,助力市场调研、商品管理和数据分析。接口支持HTTP GET请求,参数包括品类、价格区间、排序方式等,响应格式为JSON。Python示例代码展示了如何调用API获取数据,应用场景涵盖竞争对手分析、选品参考、销售预测及个性化推荐系统开发等。
2845 24
|
JSON API 数据格式
Amazon商品详情API,json数据格式示例参考
亚马逊商品详情API接口返回的JSON数据格式通常包含丰富的商品信息,以下是一个简化的JSON数据格式示例参考
|
Java 关系型数据库 数据库连接
使用 Spring Boot 执行数据库操作:全面指南
使用 Spring Boot 执行数据库操作:全面指南
1897 1
|
网络协议 NoSQL Java
后端面试常见面试题
后端面试常见面试题
813 0
|
存储 数据库 数据安全/隐私保护
我拿回属于自己的数据,怎么了?|将印象笔记导入笔记软件Notion
我拿回属于自己的数据,怎么了?|将印象笔记导入笔记软件Notion
|
数据安全/隐私保护 安全
单点登录(SSO)看这一篇就够了
背景 在企业发展初期,企业使用的系统很少,通常一个或者两个,每个系统都有自己的登录模块,运营人员每天用自己的账号登录,很方便。但随着企业的发展,用到的系统随之增多,运营人员在操作不同的系统时,需要多次登录,而且每个系统的账号都不一样,这对于运营人员来说,很不方便。
278306 15