mica-http

mica-http 是 okhttp 的封装，Fluent 语法的 http 工具包，语法参考 HttpClient Fluent API。

使用

maven

<dependency>  <groupId>net.dreamlu</groupId>  <artifactId>mica-http</artifactId>  <version>${version}</version></dependency>

gradle

compile("net.dreamlu:mica-http:${version}")

使用文档

• 设定全局日志级别 NONE，BASIC，HEADERS，BODY， 默认：NONE

HttpRequest.setGlobalLog(LogLevel.BODY);

• 同步请求 url，方法支持 get、post、patch、put、delete

HttpRequest.get("https://www.baidu.com")    .log(LogLevel.BASIC)             //设定本次的日志级别，优先于全局    .addHeader("x-account-id", "mica001") // 添加 header    .addCookie(new Cookie.Builder()  // 添加 cookie        .name("sid")        .value("mica_user_001")        .build()    )    .query("q", "mica") //设置 url 参数，默认进行 url encode    .queryEncoded("name", "encodedValue")    .formBuilder()    // 表单构造器，同类 multipartFormBuilder 文件上传表单    .add("id", 123123) // 表单参数    .execute()                      // 发起请求    .asJsonNode();                  // 结果集转换，注：如果网络异常等会直接抛出异常。// 同类的方法有 asString、asBytes、asStream// json 类响应：asJsonNode、asValue、asList、asMap，采用 jackson 处理//  、html响应：asDocument，asDomValue、asDomList采用的 jsoup 处理// file 文件：toFile

• 同步

String html = HttpRequest.post("https://www.baidu.com")    .execute()    .onFailed((request, e) -> {// 网络等异常情况的消费处理，可无        e.printStackTrace();    })    .onResponse(ResponseSpec::asString);// 处理响应，有网络异常等直接返回 null

• 同步

String text = HttpRequest.patch("https://www.baidu.com")    .execute()    .onSuccess(ResponseSpec::asString);// onSuccess http code in [200..300) 处理响应，有网络异常等直接返回 null

• 异步请求

HttpRequest.delete("https://www.baidu.com")    .async() // 开启异步    .onFailed((request, e) -> {    // 异常时的处理        e.printStackTrace();    })    .onResponse(responseSpec -> {  // 消费响应， 注意：响应的流只能读一次        int httpCode = responseSpec.code();    })    .onSuccessful(responseSpec -> { // 消费响应成功 http code in [200..300)        // 注意：响应结果流只能读一次        JsonNode jsonNode = responseSpec.asJsonNode();    })    .execute(); // 异步最后发起请求

示例代码1

// 设置全局日志级别HttpRequest.setGlobalLog(LogLevel.BODY);// 直接用 jackson json path 语法private String getUserEmail(String accessToken) {    return HttpRequest.get("https://api. edin.com/v2/emailAddress?q=members&projection=(elements*(handle~))")            .addHeader("Host", "api. edin.com")            .addHeader("Connection", "Keep-Alive")            .addHeader("Authorization", "Bearer " + accessToken)            .execute()            .asJsonNode()            .at("/elements/0/handle~0/emailAddress")            .asText();}// 异步public static void test() {    HttpRequest.post("https://www.baidu.com/do-stuff")        .log(LogLevel.BASIC)                // 日志级别        .formBuilder()                      // 表单构造器        .add("a", "b")        .async()                            // 使用异步        .onSuccessful(System.out::println)  // 异步成功时的函数        .onFailed((request, e) -> {         // 异步失败，可无            e.printStackTrace();        })        .execute();}

示例代码2

HttpRequest.setGlobalLog(LogLevel.BODY);// 同步，异常时 返回 nullString html = HttpRequest.get("www.baidu.com")    .connectTimeout(Duration.ofSeconds(1000))    .query("test", "a")    .query("name", "張三")    .query("x", 1)    .query("abd",  64Util.encode("123&$#%"))    .queryEncoded("abc",  64Util.encode("123&$#%"))    .execute()    .onFailed(((request, e) -> {        e.printStackTrace();    }))    .onSuccess(ResponseSpec::asString);System.out.println(html);// 同步调用，返回 Optional，异常时返回 Optional.empty()Optional<String> opt = HttpRequest.post(URI.create("https://www.baidu.com"))    .bodyString("Important stuff")    .formBuilder()    .add("a", "b")    .execute()    .onSuccessOpt(ResponseSpec::asString);// 同步，成功时消费（处理） responseHttpRequest.post("https://www.baidu.com/some-form")    .addHeader("X-Custom-header", "stuff")    .execute()    .onSuccessful(responseSpec -> {        String text = responseSpec.asString();        System.out.println(text);    });// 同步，异常时直接抛出HttpRequest.get("https://www.baidu.com/some-form")    .execute()    .asString();// async，异步执行结果，失败时打印堆栈HttpRequest.get("https://www.baidu.com/some-form")    .async()    .onSuccessful(System.out::println)    .onFailed((request, e) -> {        e.printStackTrace();    })    .execute();

文档

• 文档地址（官网）：https://www.dreamlu.net/#/doc/docs
• 文档地址（语雀-可关注订阅）：https://www.yuque.com/dreamlu/mica
• 示例项目：https://github.com/lets-mica/mica-example

开源推荐

• Spring boot 微服务高效开发 mica 工具集：https://gitee.com/596392912/mica
• pig 宇宙最强微服务（架构师必备）：https://gitee.com/log4j/pig
• SpringBlade 完整的线上解决方案（企业开发必备）：https://gitee.com/smallc/SpringBlade
• 加入【如梦技术】Spring QQ群：479710041，了解更多。