SpringCloud两天

2023-12-19 09:12:39

服务架构

消费者和提供者的概念

远程调用RestTemplate

RestTemplate使用有2个步骤：
- 1)注册RestTemplate
- 2)使用restTemplate.getForObject(url,T.class)远程调用
RestTemplate底层是封装了HttpURLConnection请求
服务提供者、服务消费者
- 服务提供者：一次业务中，被其它微服务调用的服务。（提供接口给其它微服务）
- 服务消费者：一次业务中，调用其它微服务的服务。（调用其它微服务提供的接口）

Eureka

注册中心与服务架构的关系

环境搭建

Ribbon

负载均衡流程

负载均衡算法

轮询调用会涉及到很多负载均衡算法，负载均衡算法比较多，关系图如下：

使用负载均衡的两种方式

Ribbon负载均衡算法的使用有2种方式

代码方式: 全局，所有的服务提供提供者采用相同的负载均衡策略
- 注册IRule接口的实现类(负载均衡算法)：在itheima-order的启动类中添加如下负载均衡注册代码：
```
/**
 * 随机负载均衡算法
 * @return
 */
@Bean
public IRule randomRule() {
    return new RandomRule();
}
```
配置方式局部配置，为每个服务提供者制定不同的负载均衡策略
- 为指定服务配置负载均衡算法：在itheima-order的核心配置文件中添加如下配置：
```
#注意配置到跟节点

#指定服务使用指定负载均衡算法
itheima-user:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #负载均衡规则
```

从懒加载变为饥饿加载

Ribbon默认是采用懒加载，即第一次访问时才会去创建LoadBalanceClient，请求时间会很长。
而饥饿加载则会在项目启动时创建，降低第一次访问的耗时，在itheima-order的核心配置文件中，添加如下配置开启饥饿加载：

#注意配置到根节点

#饥饿加载
ribbon:
  eager-load:
    clients: itheima-user #开启饥饿加载 
    enabled: true #指定对user这个服务饥饿加载

Feign

替代RestTemplate

Nacos

服务注册

服务提供者和消费者在注册中心进行注册统一管理

分级存储

集群，1w个访问地址，分10个地区安放。业务之间的调用优先访问地区内地址，访问有压力才给外地分配访问

权重配置

访问比例

环境隔离

使用环境：开发运维测试环境等

配置管理

统一配置

在nacos上添加配置管理类型，使用配置信息对某一类服务做统一配置

配置热跟新

不需要关闭服务就可以更改配置信息进行部署

配置共享

可以做一个公共配置对所有的服务进行配置

集群

微服务网关

什么是网关

类似nginx反向代理，比如说我们有很多微服务在后方部署，与客户端接触的接触的中间有一个关卡作为路由给客户端分配微服务路径，可以做请求、返回增强、负载均衡等...

断言工厂

我们在配置文件中写的断言规则只是字符串，这些字符串会被Predicate Factory读取并处理，转变为路由判断的条件

例如Path=/user/**是按照路径匹配，这个规则是由

org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory类来

处理的，像这样的断言工厂在SpringCloudGateway还有十几个:

名称	说明	示例
After	是某个时间点后的请求	- After=2037-01-20T17:42:47.789-07:00[America/Denver]
Before	是某个时间点之前的请求	- Before=2031-04-13T15:14:47.433+08:00[Asia/Shanghai]
Between	是某两个时间点之前的请求	- Between=2037-01-20T17:42:47.789-07:00[America/Denver], 2037-01-21T17:42:47.789-07:00[America/Denver]
Cookie	请求必须包含某些cookie	- Cookie=chocolate, ch.p
Header	请求必须包含某些header	- Header=X-Request-Id, \d+
Host	请求必须是访问某个host（域名）	- Host=.somehost.org,.anotherhost.org
Method	请求方式必须是指定方式	- Method=GET,POST
Path	请求路径必须符合指定规则	- Path=/red/{segment},/blue/**
Query	请求参数必须包含指定参数	- Query=name, Jack或者- Query=name
RemoteAddr	请求者的ip必须是指定范围	- RemoteAddr=192.168.1.1/24
Weight	权重处理

我们只需要掌握Path这种路由工程就可以了。

  application:
    name: gateway
  cloud:
    gateway:
      routes: # 网关路由配置
        - id: user-service # 路由id，自定义，只要唯一即可
          # uri: http://127.0.0.1:18081 # 路由的目标地址 http就是固定地址
          uri: lb://user # 路由的目标地址 lb就是负载均衡，后面跟服务名称
          predicates: # 路由断言，也就是判断请求是否符合路由规则的条件
            - Path=/user/** # 这个是按照路径匹配，只要以/user/开头就符合要求
        - id: order-service
          uri: lb://order
          predicates:
            - Path=/order/**
            - After=2020-12-30T23:59:59.789+08:00[Asia/Shanghai] #这个时间之后才可以用
            - Before=2022-12-30T23:59:59.789+08:00[Asia/Shanghai]
            - Between=2020-12-30T23:59:59.789+08:00[Asia/Shanghai],2022-12-30T23:59:59.789+08:00[Asia/Shanghai]
            - Cookie=uname, itheima
            - Header=X-Request-Id, \d+
            - Host=localhost:7001
            - Method=GET,POST
            - Query=uname,zhangsan
            - RemoteAddr=127.0.0.1/16

过滤器工厂

Spring提供了31种不同的路由过滤器工厂。例如：

名称	说明
AddRequestHeader	给当前请求添加一个请求头
RemoveRequestHeader	移除请求中的一个请求头
AddResponseHeader	给响应结果中添加一个响应头
RemoveResponseHeader	从响应结果中移除有一个响应头
RequestRateLimiter	限制请求的流量

过滤器的作用是什么？

① 对路由的请求或响应做加工处理，比如添加请求头

② 配置在路由下的过滤器只对当前路由的请求生效

③default-filters的作用是什么？对所有路由都生效的过滤器

全局过滤器

全局过滤器作用

全局过滤器的作用也是处理一切进入网关的请求和微服务响应，与GatewayFilter的作用一样。区别在于GatewayFilter通过配置定义，处理逻辑是固定的；而GlobalFilter的逻辑需要自己写代码实现。

定义方式是实现GlobalFilter接口。

public interface GlobalFilter {
    /**
     *  处理当前请求，有必要的话通过{@link GatewayFilterChain}将请求交给下一个过滤器处理
     *
     * @param exchange 请求上下文，里面可以获取Request、Response等信息
     * @param chain 用来把请求委托给下一个过滤器 
     * @return {@code Mono<Void>} 返回标示当前过滤器业务结束
     */
    Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain);
}

在filter中编写自定义逻辑，可以实现下列功能：

登录状态判断
权限校验
请求限流等

自定义全局过滤器

需求：定义全局过滤器，拦截请求，判断请求的参数是否满足下面条件：

参数中是否有authorization，
authorization参数值是否为admin

如果同时满足则放行，否则拦截

实现：在gateway中定义一个过滤器：

package com.itheima.filters;

import org.apache.commons.lang.StringUtils;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.core.annotation.Order;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;

@Component // 注册到spring容器
//@Order(1)
public class AuthorizeFilter implements GlobalFilter, Ordered {

    /**
     * @param exchange the current server exchange  里面，请求，响应对象
     * @param chain    provides a way to delegate to the next filter, 过滤链
     * @return {@code Mono<Void> }响应式编程 to indicate when request processing is complete,
     */
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        //1. 获取请求对象
        ServerHttpRequest request = exchange.getRequest();
        //2. 获取请求参数, getQueryParams 请求参数, getFirst获取第一个参数
        String authorization = request.getQueryParams().getFirst("authorization");
        //3. 请求参数是否有值
        if(StringUtils.isNotEmpty(authorization)) {
            //3.1 有值，还要判断是否为admin
            if("admin".equals(authorization)){
                // 相同 【注意】 要返回, 放行
                return chain.filter(exchange);
            }
        }
        //4 没有参数或参数值不为admin
        //5 获取响应对象
        ServerHttpResponse response = exchange.getResponse();
        //6. 设置响应状态码
        response.setStatusCode(HttpStatus.FORBIDDEN);
        //7. 结束处理
        return response.setComplete();
    }

    /**
     * 决定过滤器将来执行的顺序
     * @return
     */
    @Override
    public int getOrder() {
        // 值越小越先执行
        return Ordered.LOWEST_PRECEDENCE;
    }
}

了解：响应提示信息：

response.setStatusCode(HttpStatus.UNAUTHORIZED);
response.getHeaders().setContentType(MediaType.APPLICATION_JSON);
return response.writeWith(Flux.just(response.bufferFactory().wrap("请您先登录！".getBytes(Charset.forName("UTF-8")))));

测试：

http://localhost:7001/order/101?authorization=admin

http://localhost:7001/user/1?authorization=admin

过滤器执行顺序

请求进入网关会碰到三类过滤器：当前路由的过滤器、DefaultFilter、GlobalFilter

请求路由后，会将当前路由过滤器和DefaultFilter、GlobalFilter，合并到一个过滤器链（集合）中，排序后依次执行每个过滤器：

排序的规则是什么呢？

每一个过滤器都必须指定一个int类型的order值，order值越小，优先级越高，执行顺序越靠前。
GlobalFilter通过实现Ordered接口，或者添加@Order注解来指定order值，由我们自己指定
路由过滤器和defaultFilter的order由Spring指定，默认是按照声明顺序从1递增。
当过滤器的order值一样时，会按照 defaultFilter > 路由过滤器 > GlobalFilter的顺序执行。

详细内容，可以查看源码：

org.springframework.cloud.gateway.route.RouteDefinitionRouteLocator#getFilters()方法是先加载defaultFilters，然后再加载某个route的filters，然后合并。

org.springframework.cloud.gateway.handler.FilteringWebHandler#handle()方法会加载全局过滤器，与前面的过滤器合并后根据order排序，组织过滤器链

跨域问题【存小抄】

什么是跨域问题

跨域：域名不一致就是跨域，主要包括：

域名不同： www.taobao.com 和 www.taobao.org 和 www.jd.com 和 miaosha.jd.com
域名相同，端口不同：localhost:8080和localhost8081

跨域问题：浏览器禁止请求的发起者与服务端发生跨域ajax请求，请求被浏览器拦截的问题

模拟跨域问题

找到资料nginx-1.18.0跨域测试.7z 解压放到没有空格和中文目录下，启动并访问。

可以在浏览器控制台看到下面的错误：

从localhost:8090访问localhost:7001，端口不同，显然是跨域的请求。

解决跨域问题

如果没有网关下，可以在Controller类上加@CrossOrigin// 允许跨域访问

在gateway服务的application.yml文件中，添加下面的配置：

spring:
  cloud:
    gateway:
      ...
      globalcors: # 全局的跨域处理
        add-to-simple-url-handler-mapping: true # 解决options请求被拦截问题
        corsConfigurations:
          '[/**]':
            allowedOrigins: # 允许所有跨域请求 
              - "*"
            allowedMethods: # 允许的跨域ajax的请求方式
              - "GET"
              - "POST"
              - "DELETE"
              - "PUT"
              - "OPTIONS"
            allowedHeaders: "*" # 允许在请求中携带的头信息
            allowCredentials: true # 是否允许携带cookie
            maxAge: 360000 # 这次跨域检测的有效期

码农公寓

服务架构

消费者和提供者的概念

远程调用RestTemplate

Eureka

注册中心与服务架构的关系

环境搭建

Ribbon

负载均衡流程

负载均衡算法

使用负载均衡的两种方式

Feign

替代RestTemplate

Nacos

服务注册

服务注册

分级存储

权重配置

环境隔离

配置管理

统一配置

配置热跟新

配置共享

集群

微服务网关

什么是网关

断言工厂

过滤器工厂

全局过滤器

全局过滤器作用

自定义全局过滤器

过滤器执行顺序

跨域问题【存小抄】

什么是跨域问题

模拟跨域问题

解决跨域问题

相关文章