温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

mica-http的使用指南有哪些

发布时间:2021-10-20 18:14:17 来源:亿速云 阅读:125 作者:柒染 栏目:大数据

本篇文章为大家展示了mica-http的使用指南有哪些,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。

mica-http

mica-httpokhttp 的封装,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 处理
// xml、html响应:asDocument,asDomValue、asDomList采用的 jsoup 处理
// file 文件:toFile
  • 同步

String html = HttpRequest.post("https://www.baidu.com")
    .execute()
    .onFailed((request, e) -&gt; {// 网络等异常情况的消费处理,可无
        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) -&gt; {    // 异常时的处理
        e.printStackTrace();
    })
    .onResponse(responseSpec -&gt; {  // 消费响应, 注意:响应的流只能读一次
        int httpCode = responseSpec.code();

    })
    .onSuccessful(responseSpec -&gt; { // 消费响应成功 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.linkedin.com/v2/emailAddress?q=members&amp;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) -&gt; {         // 异步失败,可无
            e.printStackTrace();
        })
        .execute();
}

示例代码2

HttpRequest.setGlobalLog(LogLevel.BODY);

// 同步,异常时 返回 null
String html = HttpRequest.get("www.baidu.com")
    .connectTimeout(Duration.ofSeconds(1000))
    .query("test", "a")
    .query("name", "張三")
    .query("x", 1)
    .query("abd", Base64Util.encode("123&amp;$#%"))
    .queryEncoded("abc", Base64Util.encode("123&amp;$#%"))
    .execute()
    .onFailed(((request, e) -&gt; {
        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);

// 同步,成功时消费(处理) response
HttpRequest.post("https://www.baidu.com/some-form")
    .addHeader("X-Custom-header", "stuff")
    .execute()
    .onSuccessful(responseSpec -&gt; {
        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) -&gt; {
        e.printStackTrace();
    })
    .execute();

上述内容就是mica-http的使用指南有哪些,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注亿速云行业资讯频道。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI