【DB系列】h2databse集成示例demo

2020-09-11

h2dabase

h2dabase基于内存的数据库，更常见于嵌入式数据库的使用场景，依赖小，功能齐全；一般来讲，正常的商业项目用到它的场景不多，但是在一些特殊的case中，还是比较有用的，比如用于单元测试，业务缓存，一些简单的示例demo等；本文将手把手教你创建一个继承h2dabase的项目，并支持从sql中导入预定好的schema和data

【WEB系列】WebFlux之header参数解析

2020-09-07

SpringBootWEB系列WebFlux

WebFlux

上一篇weblfux主要介绍了path参数的解析与映射关系，在我们进入url参数/post表单之前，先看一下另外的一种参数–请求头中的参数如何处理

【WBE系列】WebFlux之Path参数解析与url映射

2020-08-27

SpringBootWEB系列WebFlux

WebFlux

异步、反应式、函数式编程，近来可以说是逐渐主流了；Spring5通过Reactor增加了对反应式编程的支持，而Spring WebFlux不同于以往的web框架，作为一个非阻塞异步web框架，可以充分的利用多核CPU硬件资源，提供更强的并发支持；Spring官方对WebFlux的支持非常友好，基本上对于惯于Spring WEB的java开发者，可以很简单的迁移过来

接下来我们将进入WebFlux系列教程，努力使用最简明的语言，来介绍一下WebFlux的基本玩法，让各位小伙伴可以顺畅的切换和使用WebFlux来体验反应式编程的魅力

本文将主要介绍WebFlux提供web接口时的url匹配，以及对应的path参数解析

【WEB系列】WebClient之同步与异步

2020-08-20

SpringBootWEB系列WebClient

WebClient

回顾一下最开始介绍WebClient的使用姿势之前，我们介绍了AsyncRestTemplate来实现异步的网络请求；但是在Spring5之后，官方推荐使用WebClient来替换AsyncRestTemplate实现异步请求；所以一般来讲，WebClient适用于异步的网络访问，但是，假设我需要同步获取返回结果，可行么？

【WEB系列】WebClient之策略设置

2020-08-11

SpringBootWEB系列WebClient

WebClient

在前面介绍WebClient的常见参数中，有一个exchangeStrategies参数设置，通过它我们可以设置传输数据的内存占用大小限制，避免内存问题；也可以通过它设置数据的编解码

【WEB系列】WebClient之非200状态码信息捕获

2020-08-03

SpringBootWEB系列WebClient

WebClient

前面介绍的WebClient的使用姿势都是基于正常的200状态码返回，当然在实际的使用中，我们并不是总能获取到200的状态码的，在RestTemplate的学习中，我们知道如果不特殊处理，那么是无法正确获取非200状态码的ResponseBody的，会直接抛出异常，那么在WebClient中又应该怎样应对非200状态码返回的场景呢？

I. 项目环境

本项目借助SpringBoot 2.2.1.RELEASE + maven 3.5.3 + IDEA进行开发

1. 依赖

使用WebClient，最主要的引入依赖如下（省略掉了SpringBoot的相关依赖，如对于如何创建SpringBoot项目不太清楚的小伙伴，可以关注一下我之前的博文）

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

2. REST

一个简单的403返回

@GetMapping(path = "403")
public Mono<String> _403(ServerHttpRequest request, ServerHttpResponse response) throws IOException {
    response.setStatusCode(HttpStatus.FORBIDDEN);
    return Mono.just("403 response body!");
}

II. 实例说明

1. retrieve方式

上一篇介绍retrieve与exchange区别的博文中，我们知道retrieve更适用于只希望获取ResponseBody的场景；使用retrieve时，如需要捕获其他状态码的返回，可以如下操作

Mono<String> ans = webClient.get().uri("403").retrieve().onStatus(HttpStatus::is4xxClientError, response -> {
    System.out.println("inner retrieve 403 res: " + response.headers().asHttpHeaders() + "|" + response.statusCode());
    response.bodyToMono(String.class).subscribe(s -> System.out.println("inner res body: " + s));
    return Mono.just(new RuntimeException("403 not found!"));
}).bodyToMono(String.class);
ans.subscribe(s -> System.out.println("retrieve 403 ans: " + s));

请注意上面的 onStatus，上面演示的是4xx的捕获，返回如下

1	inner retrieve 403 res: [Content-Type:"text/plain;charset=UTF-8", Content-Length:"18"]\|403 FORBIDDEN

2. exchange方式

exchange本身就可以获取完整的返回信息，所以异常的case需要我们自己在内部进行处理

webClient.get().uri("403").exchange().subscribe(s -> {
    HttpStatus statusCode = s.statusCode();
    ClientResponse.Headers headers = s.headers();
    MultiValueMap<String, ResponseCookie> cookies = s.cookies();
    s.bodyToMono(String.class).subscribe(body -> {
        System.out.println(
                "error response detail: \nheader: " + headers.asHttpHeaders() + "\ncode: " + statusCode +
                        "\ncookies: " + cookies + "\nbody:" + body);
    });
});

返回结果如下

exchange error response detail: 
header: [Content-Type:"text/plain;charset=UTF-8", Content-Length:"18"]
code: 403 FORBIDDEN
cookies: {}
body:403 response body!