mica-http 完全使用指南【一】
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 处理 // 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(); // 异步最后发起请求
示例代码1
// 设置全局日志级别 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(); }
示例代码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&$#%")) .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); // 同步,成功时消费(处理) response HttpRequest.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,了解更多。
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
24、Python快速开发分布式搜索引擎Scrapy精讲—爬虫和反爬的对抗过程以及策略—scrapy架构源码分析图
【百度云搜索:http://www.lqkweb.com】 【搜网盘:http://www.swpan.cn】 1、基本概念 2、反爬虫的目的 3、爬虫和反爬的对抗过程以及策略 scrapy架构源码分析图
- 下一篇
Spring Cloud 微服务实战笔记
微服务知识 传统开发所有业务逻辑都在一个应用中, 开发,测试,部署随着需求增加会不断为单个项目增加不同业务模块;前端展现也不局限于html视图模板的形式,后端向前端支持需要更多的接口模块。 随着需求增多,项目变大,单体系统部署在一个进程内部,往往修改很小的功能,为了部署上线也会影响其他功能。后期维护成本会变得越来越大,难以控制。 微服务架构中不同模块拆分成不同服务,都能独立部署和扩展,运行在自己的进程内,有稳定的边界,更新也不会影响其他服务运营。而且由于是独立部署的,可以更准确的为每个服务评估性能容量,也更容易发现系统瓶颈位置。 Spring Cloud 微服务实战笔记微服务带来的问题 微服务架构有如此多优点,单也因为服务的拆分引入了许多问题。 运维人员需要维护的进程数量增多了, 所以需要自动化的工具。服务拆分了,但业务逻辑的依赖不会消除,只是从单体应用的代码依赖变为了服务间的通信依赖, 所以要保证接口的正确调用,需要完善的接口和版本管理工具。由于服务独立部署在各自进程内,所以它们间通信需要考虑网络延迟,分布式事务,异步消息,容错性等。微服务实施 服务调用 在微服务架构中通常通过两种方...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS8,CentOS7,CentOS6编译安装Redis5.0.7
- CentOS7,CentOS8安装Elasticsearch6.8.6
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- Linux系统CentOS6、CentOS7手动修改IP地址
- CentOS7安装Docker,走上虚拟化容器引擎之路
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题
- SpringBoot2全家桶,快速入门学习开发网站教程
- CentOS7设置SWAP分区,小内存服务器的救世主
- Docker快速安装Oracle11G,搭建oracle11g学习环境