集团主站
欢迎来到成都达内官方网站!达内—美国上市公司 亿元级外企IT培训企业!
成都it培训哪家好
成都it培训哪家好
全国服务监督电话:15023458194  |   联系客服   |
当前位置:主页 > 培训课程 > Java >

成都java培训:GET请求阻塞与非阻塞调用方法详解

发布者: 成都达内     浏览次数:     发布时间:2020-08-21 10:58:26

成都java培训:WebClient客户端既支持同步异步、阻塞与非阻塞IO,我们先来为大家介绍一下同步阻塞式的编程方式。即:在请求发送之后使用block()方法,阻塞当前线程等待获取响应结果。...

  一、block()阻塞式获取响应结果

  WebClient客户端既支持同步异步、阻塞与非阻塞IO,我们先来为大家介绍一下同步阻塞式的编程方式。即:在请求发送之后使用block()方法,阻塞当前线程等待获取响应结果。

  1.1.使用Mono接收单个对象

  创建测试用例,成员变量WebClient,以 "http://jsonplaceholder.typicode.com" 为访问服务基础路径,该网站是一个免费提供RESTful API进行接口测试的一个网站。

  public class GetTest {

  //创建webClient

  private WebClient webClient = WebClient.builder()

  .baseUrl("http://jsonplaceholder.typicode.com")

  .build();

  @Test

  public void testMono() {

  Mono mono = webClient

  .get() // 发送GET 请求

  .uri("/posts/1") //服务请求路径,基于baseurl

  .retrieve() // 获取响应体

  .bodyToMono(PostDTO.class); //响应数据类型转换

  System.out.println(mono.block());

  }

  }

  get() 方法表示使用HTTP GET method

  uri() 指定服务接口路径,以baseurl为基础

  retrieve() 获取响应体,即HTTP body

  bodyToMono()将响应体转换为一个对象,Mono英文是单声道、单体的意思,用于接收单个对象

  通过浏览器访问 "http://jsonplaceholder.typicode.com/posts/1" 得到JSON响应结果,和我们通过程序打印出的响应结果数据内容一致。程序控制台截图如下:

  成都java培训:GET请求阻塞与非阻塞调用方法详解

  接收响应结果的java POJO实体对象如下:

  import lombok.Data;

  @Data

  public class PostDTO {

  private int userId;

  private int id;

  private String title;

  private String body;

  }

  1.2.使用Flux接收集合对象

  访问http://jsonplaceholder.typicode.com/posts 可以获得JSON数组方式的请求结果如图(一共100条我截图截取3条记录):

  成都java培训:GET请求阻塞与非阻塞调用方法详解

  所以我们需要通过bodyToFlux方法将请求结果转为Flux,通过flux.collectList().block();接收响应数据为 List集合。Flux英文含义:流动的,用于接收集合元素响应结果。

  @Test

  public void testFlux() {

  Flux flux = webClient

  .get() // 发送GET 请求

  .uri("/posts") //服务请求路径,基于baseurl

  .retrieve() // 获取响应体

  .bodyToFlux(PostDTO.class); //响应数据类型转换

  List posts = flux.collectList().block();

  assert posts != null;

  System.out.println("获取posts集合元素数量:" + posts.size());

  }

  控制台打印结果如下:

  成都java培训:GET请求阻塞与非阻塞调用方法详解

  二、subscribe()非阻塞式获取响应结果

  与block()阻塞式获取响应结果不同,使用subscribe()异步订阅响应结果,不会阻塞主线程继续向下执行。获取到响应结果之后,由回调函数handleResponse处理响应结果。

  @Test

  public void testSubscribe() throws InterruptedException {

  Mono mono = webClient

  .get() // 发送GET 请求

  .uri("/posts/1") //服务请求路径,基于baseurl

  .retrieve() // 获取响应体

  .bodyToMono(PostDTO.class); //响应数据类型转换

  //异步非阻塞处理响应结果

  mono.subscribe(GetTest::handleResponse);

  //为了避免测试用例主线程执行完成,导致看不到异步处理结果

  Thread.currentThread().sleep(10000);

  }

  //响应结果处理回调方法

  private static void handleResponse(PostDTO postDTO) {

  System.out.println("handle response:=======================");

  System.out.println(postDTO);

  }

  控制台打印输出结果如下:

  成都java培训:GET请求阻塞与非阻塞调用方法详解

  三、exchange()获取HTTP响应完整内容

  上文中retrieve()只能获取HTTP报文中的Body,也就是响应体。如果我们想获取HTTP报文中的状态码、headers、cookies等信息,需要使用exchange()方法。

  @Test

  public void testExchange() {

  Mono mono = webClient

  .get() // 发送GET 请求

  .uri("/posts/1") //服务请求路径,基于baseurl

  .exchange();

  System.out.println(mono.block());

  // 获取完整的响应对象

  ClientResponse response = mono.block();

  assert response != null;

  HttpStatus httpStatus = response.statusCode(); // 获取响应状态

  int statusCodeValue = response.rawStatusCode(); // 获取响应状态码

  ClientResponse.Headers headers = response.headers(); // 获取响应头

  // 获取响应体

  Mono resultMono = response.bodyToMono(PostDTO.class);

  PostDTO postDTO = resultMono.block();

  // 输出结果

  System.out.println("响应状态:" + httpStatus);

  System.out.println("响应状态码值:" + statusCodeValue);

  System.out.println("HTTP Headers:" + headers.asHttpHeaders());

  System.out.println("响应体:" + postDTO);

  }

  HTTP报文信息详情控制台打印结果

  成都java培训:GET请求阻塞与非阻塞调用方法详解

  四、占位符传参

  非占位符传参,写死的参数方式不灵活

  .uri("/posts/1") //服务请求路径,基于baseurl

  第一种占位符传参:数字顺序占位符

  Mono mono = webClient.uri("/{1}/{2}", "posts", "1")

  第二种占位符传参:参数名称占位符

  String type = "posts";

  int id = 1;

  Mono mono = webClient.uri("/{type}/{id}", type, id)

  第三种通过map传参

  Map map = new HashMap<>();

  map.put("type", "posts");

  map.put("id", 1);

  Mono mono = webClient

  .uri("/{type}/{id}", map)

(责任编辑:范老师)
最新开班
  • 成都Java培训班
    免费试听名额发放中...
  • 成都C++培训班
    免费试听名额发放中...
  • 成都PHP培训班
    免费试听名额发放中...
  • 成都网络工程培训班
    免费试听名额发放中...
  • 成都Unity3D培训班
    免费试听名额发放中...
  • 成都大数据培训班
    免费试听名额发放中...
  • 成都uid培训班
    免费试听名额发放中...
  • 成都会计培训班
    免费试听名额发放中...
  • 成都Python培训班
    免费试听名额发放中...
  • 成都嵌入式培训班
    免费试听名额发放中...
  • 成都web培训班
    免费试听名额发放中...
  • 成都软件测试培训班
    免费试听名额发放中...
在线留言
提交

校区地址:成都市锦江区东大街紫东楼端35号明宇金融广场19楼1906室

联系电话:15023458194

公交路线:芷泉街(18路;21路;43路;48路;104路;152路;335路 ) 地铁路线:东门大桥站(地铁2号线)

校区地址:成都市高新区奥克斯广场蜀锦路209号一楼商铺

联系电话:15023458194

公交路线:益州大道锦城大道口(18路;21路;43路;48路;104路;152路;335路 ) 地铁路线:孵化园(地铁1号线)

校区地址:成都锦江区东大街芷泉街229号东方广场C座3楼303

联系电话:15023458194

公交路线:芷泉街(188路;115路;515路;236路;505路;501路;84路 ) 地铁路线:东门大桥站(地铁2号线)

校区地址:成都市武侯区佳灵路3号红牌楼广场2号写字楼11楼1115号

联系电话:15023458194

公交路线:红牌楼东(11路;92路;100路;111路;139路;g28路;快速公交K1/K2) 地铁路线:红牌楼站(地铁3号线)

校区地址:成都市锦江区红星路二段70号四川日报大厦502-2

联系电话:15023458194

公交路线:市二医院站(6路;49路;102路;5路;37路;g92路;) 地铁路线:地铁市二医院(地铁3号线)

校区地址:成都市锦江区东大街芷泉段229号东方广场C座16层

联系电话:15023458194

公交路线:芷泉街(18路;21路;43路;48路;104路;152路;335路 ) 地铁路线:东门大桥站(地铁2号线)

校区地址:四川省成都市武侯区高新科技孵化园9号园区E座7楼

联系电话:15023458194

公交路线:益州大道锦城大道口(18路;21路;43路;48路;104路;152路;335路 ) 地铁路线:孵化园(地铁1号线)

校区地址:成都市高新区奥克斯广场B座1708

联系电话:15023458194

公交路线:益州大道锦城大道口(18路;21路;43路;48路;104路;152路;335路 ) 地铁路线:孵化园(地铁1号线)

了解达内动态
关注成都达内教育公众号

首页 | 关于达内 | 课程中心 | 专家师资 | 视频教程 | 学员空间 | 校企合作 | 新闻资讯 | 就业指导 | 网站地图

2016-2025 达内时代科技集团有限公司 版权所有 京ICP证8000853号-56