常见的分布式应用架构风格：
- 分布式对象（Distributed Objects，简称 DO），架构实例有 CORBA、RMI、EJB、DCOM、.NET Remoting 等
- 远程过程调用（Remote Procedure Call，简称 RPC），架构实例有 SOAP、XML-RPC、Hessian/Flash AMF、DWR 等
- 表述性状态转移（Representational State Transfer，简称 REST），架构实例有 HTTP、WebDAV

REST 概念

REST（Representational State Transfer）：表述性状态转移，Web 应用架构设计指导原则
使用 REST 作为指导原则设计的 URI（统一资源标识符）特点是：该 URI 只体现资源（resource）的具体位置，不体现资源的表现形式（Representation），也不体现资源的状态转变（State Transfer），而是通过在 HTTP 请求的头信息中用 Accept 和 Content-Type 字段指定资源的表现形式，通过 HTTP/1.1 协议定义的操作资源的统一接口（Uniform Interface）来对资源执行各种操作
RESTful 风格：符合 REST 原则的应用程序或设计
图 1 Richardson 成熟度模型

可以利用缓存 Cache 来提高相应速度
通信本身的无状态性可以让不同的服务器处理一系列请求中的不同请求，提高服务器可扩展性
浏览器即可作为客户端，简化软件需求
相对于其他叠加在 HTTP 协议之上的机制，REST 的软件依赖性更小
不需要额外的资源发现机制
在软件技术演进中长期的兼容性更好

统一接口（以 HTTP1.1 协议）

GET（SELECT）：从服务器取出资源（一项或多项），返回资源对象的列表（数组）或单个资源对象
POST（CREATE）：在服务器新建一个资源，返回新生成的资源对象
PUT（UPDATE）：在服务器更新资源（客户端提供改变后的完整资源），返回完整的资源对象
PATCH（UPDATE）：在服务器更新资源（客户端提供改变的属性【补丁】），返回完整的资源对象
DELETE（DELETE）：从服务器删除资源，返回一个空文档
HEAD：获得一个资源的元数据，比如一个资源的 hash 值或者最后修改日期
OPTIONS：获得客户端针对一个资源能够实施的操作

Accept：代表发送端（客户端）希望接受的数据类型，
Content-Type：代表发送端（客户端或服务器）发送的实体数据的数据类型

200 OK - [GET]：服务器成功返回用户请求的数据
201 CREATED - [POST/PUT/PATCH]：用户新建或修改数据成功
202 Accepted - [ * ]：表示一个请求已经进入后台排队（异步任务）
204 NO CONTENT - [DELETE]：用户删除数据成功
400 INVALID REQUEST - [POST/PUT/PATCH]：用户发出的请求有错误，服务器没有进行新建或修改数据的操作，该操作是幂等的
401 Unauthorized - [ * ]：表示用户没有权限（令牌、用户名、密码错误）
403 Forbidden - [ * ] 表示用户得到授权（与 401 错误相对），但是访问是被禁止的
404 NOT FOUND - [ * ]：用户发出的请求针对的是不存在的记录，服务器没有进行操作，该操作是幂等的
406 Not Acceptable - [GET]：用户请求的格式不可得（比如用户请求 JSON 格式，但是只有 XML 格式）
410 Gone - [GET]：用户请求的资源被永久删除，且不会再得到的。
422 Unprocesable entity - [POST/PUT/PATCH] 当创建一个对象时，发生一个验证错误
500 INTERNAL SERVER ERROR - [ * ]：服务器发生错误，用户将无法判断发出的请求是否成功

识别资源：能用 CRUD 操作的名词、将资源组织为集合、将资源合并为复合资源、计算或处理函数
选择合适的资源粒度：网络效率、表述的多少、客户端的易用程度；可缓存性、修改频率、可变性
设计 URI：
- 使用域及子域对资源进行合理的分组或划分
- 在 URI 的路径部分使用斜杠分隔符 ( / ) 来表示资源之间的层次关系
- 在 URI 的路径部分使用逗号 ( , ) 和分号 ( ; ) 来表示非层次元素
- 使用连字符 ( - ) 和下划线 ( _ ) 来改善长路径中名称的可读性
- 在 URI 的查询部分使用“与”符号 ( & ) 来分隔参数
- 在 URI 中避免出现文件扩展名- 选择合适的 HTTP 方法和返回码
设计资源的表述：JSON、XML、HTML、ProtoBuf

Hypermedia API

HATEOAS 是 Hypertext As The Engine Of Application State 的缩写
采用 Hypermedia 的 API 在响应（response）中除了返回资源（resource）本身外，还会额外返回一组 Link。这组 Link 描述了对于该资源，消费者（consumer）接下来可以做什么以及怎么做

使用 Spring MVC 开发 RESTful 服务

使用 Swagger2 生成 REST API 文档

添加依赖：springfox:springfox-swagger2、springfox:springfox-swagger-ui
配置 Swagger2


@Configuration
public class Swagger2 {
    @Bean
    public Docket createRestApi() {
        return new Docket(DocumentationType.SWAGGER_2)
                .apiInfo(apiInfo())
                .select()
                .apis(RequestHandlerSelectors.basePackage("com.forezp.controller"))
                .paths(PathSelectors.any())
                .build();
    }
    private ApiInfo apiInfo() {
        return new ApiInfoBuilder()
                .title("SpringBoot 利用 Swagger2 构建 API 文档")
                .description("简单优雅的 RESTful 风格")
                .termsOfServiceUrl("http://example.com/rest")
                .version("1.0")
                .build();
    }
}

添加视图解释器，使用 Swagger UI（Spring Boot 中无须此操作）

@Component
public class SwaggerMvcConfigurerAdapter extends WebMvcConfigurerAdapter {
    @Override
    public void addResourceHandlers(ResourceHandlerRegistry registry) {
        registry.addResourceHandler("swagger-ui.html").addResourceLocations("classpath:/META-INF/resources/");
        registry.addResourceHandler("/webjars/**").addResourceLocations("classpath:/META-INF/resources/webjars/");
    }
}

访问 /swagger-ui.html

Swagger2 常用注解

@Api：修饰类，表示这个类是 Swagger 的文档资源，属性：value url 的路径值，description 对 API 资源的描述
@ApiOperation：修饰方法，表示一个 HTTP 请求的操作，属性：value 用于方法描述，notes 用于提示内容
@ApiResponses、@ApiResponse：修饰方法，表示请求的响应信息，属性：code 响应码（可自定义），message 状态码对应的响应信息
@ApiImplicitParams、@ApiImplicitParam：修饰方法，表示请求参数说明
@ApiParam：修饰参数，表示对参数添加元数据，属性：name 参数名，value 参数说明，required–是否必填 required 是否必填
@ApiModel：修饰类，表示对实体类进行说明，属性：value 表示对象名，description 描述
@ApiModelProperty：修饰方法、字段，表示对 model 属性的说明或者数据操作更改，属性：value 字段说明，name 重写属性名字，dataType 重写属性类型，required 是否必填，example 举例说明，hidden 隐藏
@ApiIgnore：修饰类、方法、参数，可以不被 Swagger 显示在页面上

REST Clients

Spring 提供的用于访问 Web 服务器端 RESTful 服务的客户端

创建请求的通用接口：ClientHttpRequestFactory
默认使用的实现类：SimpleClientHttpRequestFactory（uses standard JDK facilities）
- Netty4ClientHttpRequestFactory（Netty，已过时）
- OkHttp3ClientHttpRequestFactory（OkHttp）
优底层请求策略：
- 连接管理：PoolingHttpClientConnectionManager、ConnectionKeepAliveStrategy（默认实现类 DefaultConnectionKeepAliveStrategy ）
- 超时设置：connectTimeout、readTimeout
- SSL 校验：证书检查策略（SkipSslVerificationHttpRequestFactory）

// security.key-store=classpath:springbucks.p12
// security.key-pass=spring
// @Value("${security.key-store}")
// private Resource keyStore;
// @Value("${security.key-pass}")
// private String keyPass;
@Bean
public HttpComponentsClientHttpRequestFactory requestFactory() {
    // 连接池配置
    PoolingHttpClientConnectionManager connectionManager =
        new PoolingHttpClientConnectionManager(30, TimeUnit.SECONDS);
    connectionManager.setMaxTotal(200); // 设置连接池最大连接数
    connectionManager.setDefaultMaxPerRoute(20); // 路由是对 maxTotal 的细分
    // 信任所有 SSL 证书，关闭主机名验证
    SSLContext sslContext = null;
    try {
        sslContext = SSLContexts.custom().loadTrustMaterial(TrustAllStrategy.INSTANCE).build();
        // sslContext = SSLContextBuilder.create()
                // 设置证书位置及密码
                // .loadTrustMaterial(keyStore.getURL(), keyPass.toCharArray())
                // 信任所有 SSL 证书
                // .loadTrustMaterial(null, (certificate, authType) -> true)
                // .build();
    } catch (Exception e) {
        log.error("Exception occurred while creating SSLContext.", e);
    }
    // SSLConnectionSocketFactory sslSocketFactory = new SSLConnectionSocketFactory(sslContext, NoopHostnameVerifier.INSTANCE);
    CloseableHttpClient httpClient = HttpClients.custom()
        .setConnectionManager(connectionManager)
        .evictIdleConnections(30, TimeUnit.SECONDS)
        .disableAutomaticRetries() // 禁用自动重试
        // DefaultConnectionKeepAliveStrategy.INSTANCE：响应头有 Keep-Alive 则设置为其值，没有的则永久有效
        .setKeepAliveStrategy(new CustomConnectionKeepAliveStrategy())
        // .setSSLSocketFactory(sslSocketFactory)
        .setSSLContext(sslContext)
        .setSSLHostnameVerifier(NoopHostnameVerifier.INSTANCE)
        .build();
    return new HttpComponentsClientHttpRequestFactory(httpClient);
}
@Bean
public RestTemplate restTemplate(RestTemplateBuilder restTemplateBuilder) {
    RestTemplate restTemplate = restTemplateBuilder
        .setConnectTimeout(Duration.ofMillis(100))
        .setReadTimeout(Duration.ofMillis(500))
        .requestFactory(this::requestFactory)
        .build();
    // RestTemplate 的默认构造方法初始化的 StringHttpMessageConverter 的默认字符集是 ISO-8859-1
    // RestTemplateBuilder#additionalMessageConverters，在构建器上配置的所有转换器将替换 RestTemplate 的默认 MessageConverter
        if(converter instanceof StringHttpMessageConverter) {
            ((StringHttpMessageConverter) converter).setDefaultCharset(StandardCharsets.UTF_8);
        }
    });
    // 添加自定义的拦截器（implements ClientHttpRequestInterceptor）
    // restTemplate.getInterceptors().add(new MyInterceptor());
    // 设置 ErrorHandler（extends DefaultResponseErrorHandler）
    // restTemplate.setErrorHandler(new MyResponseErrorHandler());
    return restTemplate;
}
@Bean
public ClientHttpRequestFactory requestFactory() {
    OkHttpClient okHttpClient = null;
    try {
        KeyStore keyStore = KeyStore.getInstance(KeyStore.getDefaultType());
        keyStore.load(this.keyStore.getInputStream(), keyPass.toCharArray());
        TrustManagerFactory tmf = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
        tmf.init(keyStore);
        SSLContext sslContext = SSLContext.getInstance("TLS");
        sslContext.init(null, tmf.getTrustManagers(), null);
        okHttpClient = new OkHttpClient.Builder()
                .sslSocketFactory(sslContext.getSocketFactory(), (X509TrustManager) tmf.getTrustManagers()[0])
                .hostnameVerifier((hostname, session) -> true)
                .build();
    } catch (Exception e) {
        log.error("Exception occurred!", e);
    }
    return new OkHttp3ClientHttpRequestFactory(okHttpClient);
}

11 种 HTTP 请求操作
- exchange()：在 URL 上执行特定的 HTTP 方法，返回包含对象的 ResponseEntity
- execute()：在 URL 上执行特定的 HTTP 方法，返回从响应体映射得到的对象
- getForEntity()：发送一个 HTTP GET 请求，返回的 ResponseEntity 包含了从响应体中映射得到的对象以及响应相关的额外信息（如 HTTP 状态码和响应头）
- getForObject()：发送一个 HTTP GET 请求，返回从响应体映射得到的对象
- postForEntity()：POST 数据到一个 URL，返回的 ResponseEntity 包含了从响应体中映射得到的对象以及响应相关的额外信息
- postForObject()：POST 数据到一个 URL，返回从响应体映射得到的对象
- postForLocation()：POST 数据到一个 URL，返回新创建资源的 URL
- put()：PUT 资源到特定的 URL
- delete()：在特定的 URL 上对资源执行 HTTP DELETE 操作
- headForHeaders()：发送 HTTP HEAD 请求，返回包含特定资源 URL 的 HTTP 头
- optionsForAllow()：发送 HTTP OPTIONS 请求，返回对特定 URL 的 Allow 头信息
大多数操作都以三种方法的形式进行了重载
- T getForObject(URI url, Class<T> responseType)：使用 java.net.URI 作为 URL 格式，不支持参数化 URL
- T getForObject(String url, Class<T> responseType, Map<String, ?> uriVariables)：使用 String 作为 URL 格式，并使用 Map 指明 URL 参数
- T getForObject(String url, Class<T> responseType, Object… uriVariables)：使用 String 作为 URL 格式，并使用可变参数列表指明 URL 参数
- T postForObject(String url, Object request, Class<T> responseType, Map<String, ?> uriVariables)
- T postForObject(String url, Object request, Class<T> responseType, Object… uriVariables)
- T postForObject(URI url, Object request, Class<T> responseType)
注意：使用 String 作为 URL 格式的方法已经被假定URL字符串不被编码且需要编码

发送 GET 请求

@GetMapping("accounts/filter")
public Account filter(String name, Integer age) {
    return new Account();
}
    String url = "http://192.168.1.121:9001/rest-server/accounts/filter?name={name}&age={age}";
    Map<String, Object> params = new HashMap<>();
    params.put("age", "26");
    params.put("name", "libai");
    Account account = restTemplate.getForObject(url, Account.class, params);
    // 等价于
    /*ResponseEntity<Account> response = restTemplate.getForEntity(url, Account.class, params);
    if (response.getStatusCode().is2xxSuccessful()) {
        Account account = response.getBody();
    }*/
}

发送 POST 请求

发送带有 HttpHeader 信息的请求

@PostMapping("accounts/authorization")
public Account create(@RequestHeader("authorization") String authorization,
                      @RequestHeader("token") String token,
                      @RequestBody Account account) {
    return new Account();
}
public void httpHeaderTest() {
    String url = "http://192.168.1.121:9001/rest-server/accounts/authorization";
    HttpHeaders headers = new HttpHeaders();
    headers.add("authorization", "12345678");
    headers.add("token", "bce235emn97jjf00");
    // headers.add(HttpHeaders.COOKIE,"key1=value1");
    Map<String, Object> params = new HashMap<>();
    params.put("id", "10001");
    HttpEntity<Map<String, Object>> httpEntity = new HttpEntity<>(params, headers);
    Account account = restTemplate.postForObject(url, httpEntity, Account.class);
}
public void httpHeaderTest2() {
    URI uri = UriComponentsBuilder.fromHttpUrl("http://192.168.1.121:9001/rest-server/accounts/authorization").build().toUri();
    Map<String, Object> params = new HashMap<>();
    params.put("id", "10001");
    params.put("name", "libai");
    RequestEntity<Map<String, Object>> requestEntity = RequestEntity.post(uri)
        .header("authorization", "12345678")
        .header("token", "bce235emn97jjf00")
        // .header(HttpHeaders.COOKIE,"key1=value1")
        .body(params);
    ResponseEntity<Account> response = restTemplate.exchange(requestEntity, Account.class);
}

文件上传

@Data
public class UploadReqDTO implements Serializable {
    private static final long serialVersionUID = 1L;
    @NotNull
    private MultipartFile file;
    @NotBlank
    private String nickname;
}
@PostMapping("accounts/logo", consumes = "multipart/form-data")
public Boolean changeLogo(@Validated UploadReqDTO reqDTO) {
    return Boolean.TRUE;
}
@PostMapping("accounts/logo", consumes = "multipart/form-data")
public Boolean changeLogo(@RequestPart("file") MultipartFile file,
                          @RequestParam(value = "nickname") String nickname) {
    return Boolean.TRUE;
}
public void fileUploadTest() {
    String url = "http://192.168.1.121:9001/rest-server/accounts/logo";
    HttpHeaders headers = new HttpHeaders();
    headers.setContentType(MediaType.MULTIPART_FORM_DATA);
    MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
    params.add("file", new FileSystemResource("D:\\abc.jpg"));
    // params.add("file", new InMemoryResource("abc.jpg", "", FileCopyUtils.copyToByteArray(new File("D:\\abc.jpg")), System.currentTimeMillis()));
    params.add("nickname", "nick");
    HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity<>(params, headers);
    Boolean result = restTemplate.postForObject(url, httpEntity, Boolean.class);
    // Boolean result = restTemplate.postForObject(url, params, Boolean.class);
}
// 自定义一个 Resource 的实现类，用于上传数据流/字节数组
public class InMemoryResource extends ByteArrayResource {
    private final String filename;
    private final long lastModified;
    public InMemoryResource(String filename, String description, byte[] content, long lastModified) {
        super(content, description);
        this.lastModified = lastModified;
        this.filename = filename;
    }
    @Override
    public long lastModified() {
        return this.lastModified;
    }
    @Override
    public String getFilename() {
        return this.filename;
    }
}

文件下载

处理有泛型类型字段的返回值

ParameterizedTypeReference<Result<XXX>> typeRef = new ParameterizedTypeReference<Result<XXX>>() {};
ResponseEntity<Result<XXX>> response = restTemplate.exchange(url, HttpMethod.POST, httpEntity, typeRef);

WebClient

Spring 提供的一个以 Reactive 方式处理 HTTP 请求的非阻塞式的客户端
支持的底层 HTTP 库：
- ReactorClientHttpConnector（Reactor Netty）
- JettyClientHttpConnector（Jetty ReactiveStream HttpClient）
发起请求：get()、post()、put()、delete()、patch()
获得结果：retrieve()、exchange()
应答正文：bodyToMono()、bodyToFlux()

26 RES Tful

REST 概念

统一接口（以 HTTP1.1 协议）

Hypermedia API

使用 Spring MVC 开发 RESTful 服务

使用 Swagger2 生成 REST API 文档

Swagger2 常用注解

REST Clients

发送 GET 请求

发送 POST 请求

发送带有 HttpHeader 信息的请求

文件上传

文件下载

处理有泛型类型字段的返回值

WebClient