mica-http 是 okhttp 的封装，Fluent 语法的 http 工具包，语法参考 HttpClient Fluent API。
<dependency> <groupId>net.dreamlu</groupId> <artifactId>mica-http</artifactId> <version>${version}</version></dependency>gradlecompile("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 处理// xml、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(); // 异步最后发起请求
示例代码2// 设置全局日志级别HttpRequest.setGlobalLog(LogLevel.BODY);// 直接用 jackson json path 语法private String getUserEmail(String accessToken) {return HttpRequest.get("https://api.linkedin.com/v2/emailAddress?q=members&projection=(elements*(handle~))").addHeader("Host", "api.linkedin.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();}
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", Base64Util.encode("123&$#%")).queryEncoded("abc", Base64Util.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();