> 文章列表 > SpringCloud学习笔记(三)Feign和Gateway

SpringCloud学习笔记(三)Feign和Gateway

SpringCloud学习笔记(三)Feign和Gateway

一、什么是Feign?

  • Feign是一个声明式的http客户端,其作用就是帮助我们优雅地实现http请求的发送

二、使用Feign的步骤

  • 引入依赖
<!--feign客户端依赖-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
  • 在微服务的启动类添加注解开启Feign的功能
@EnableFeignClients
public class OrderApplication { ... }
  • 编写Feign客户端,即写一个Feign客户类;主要是基于SpringMVC的注解来声明远程调用的信息
@FeignClient(value = "userservice")
public interface UserClient {@GetMapping("/user/{id}")User findById(@PathVariable("id") Long id);
}
  • 用Feign客户端代替RestTemplate
@Autowired
private UserClient userClient;public Order queryOrderById(Long orderId) {// 1.查询订单Order order = orderMapper.findById(orderId);// 2.用Feign远程调用User user = userClient.findById(order.getUserId());// 3.封装user到Orderorder.setUser(user);// 4.返回return order;
}

三、Feign的自定义配置

1、可以修改的配置如下

SpringCloud学习笔记(三)Feign和Gateway
2、配置Feign日志有两种方式

  • 方式一:配置文件格式
feign:client:config:default:	#这里用default就是全局配置loggerLevel: FULL #日志级别feign:client:config:userservice:	#如果是写服务名称,则是针对某个微服务的配置loggerLevel: FULL #日志级别
  • 方式二:Java代码实现,先写一个配置类,然后注入
public class DefaultFeignConfiguration {@Beanpublic Logger.Level logLevel(){return Logger.Level.BASIC;}
}
//如果是全局配置,就放到@EnableFeignClients这个注解中
@EnableFeignClients(defaultConfiguration = DefaultFeignConfiguration.class)
//如果是局部配置,就放到@FeignClient中
@FeignClients(value="userservice",defaultConfiguration = DefaultFeignConfiguration.class)

四、Feign的性能优化

1、Feign底层的客户端实现:

  • URLConnection:默认实现,不支持连接池
  • Apache HttpClient:支持连接池
  • OKHttp:支持连接池

2、因此优化Feign的性能主要包括

  • 使用连接池代替默认的URLConnection
  • 日志级别,最好用basic或none,如果是full会消耗一部分性能

3、Feign添加HttpClient的支持:

  • 引入依赖
<!--引入HttpClient依赖-->
<dependency><groupId>io.github.openfeign</groupId><artifactId>feign-httpclient</artifactId>
</dependency>
  • 配置连接池
feign:httpclient:enabled: true # 支持HttpClient的开关max-connections: 200 # 最大连接数max-connections-per-route: 50 # 单个路径的最大连接数

五、Feign的最佳实践

1、方式一:继承,给消费者的FeignClient和提供者的controller定义统一的父接口作为标准

  • 服务紧耦合
  • 父接口参数列表中的映射不会被继承

2、方法二、抽取,将FeignClient抽取为独立模块,并且把接口有关的POJO、默认的Feign配置都放到这个模块中,提供给所有消费者使用;其实现步骤如下:

  • 首先创建一个module,命名为feign-api,然后引入feign的starter依赖
  • 将消费者中编写的UserClient、User、DefaultFeignConfiguration都复制到feign-api项目中
  • 在消费者中引入feign-api的依赖
  • 修改order-service中的所有与上述三个组件有关的import部分,改成导入feign-api中的包
  • 重启测试

注意,当定义的FeignClient不再SpringBootApplication的扫描包范围时,这些FeignClient无法使用,有以下两种解决办法

  • 指定FeignClient所在包,把所有client都导入
@EnableFeignClients(basePackages="cn.itcast.feign.clients")
  • 指定FeignClient字节码,导入具体的client
@EnableFeignClients(clients={UserClient.class})

六、网关

1、网关的功能:

  • 身份认证和权限校验
  • 服务路由、负载均衡
  • 请求限流

2、SpringCloud中网关的实现:

  • Gateway:基于Spring5中提供的WebFlux,属于响应式编程,具备更好的性能
  • Zuul:基于Servlet的实现,属于阻塞式编程

七、搭建Gateway网关服务

  • 创建新的module,引入SpringCloudGateway的依赖和nacos的服务发现依赖:
<!--nacos服务注册发现依赖-->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!--网关gateway依赖-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
  • 编写路由配置及nacos地址
spring:application:name: gatewaycloud:nacos:server-addr: localhost:8849 # nacos地址gateway:routes:- id: user-service # 路由标示,必须唯一uri: lb://userservice # 路由的目标地址,lb指loadbalance,负载均衡predicates: # 路由断言,判断请求是否符合规则- Path=/user/ # 路径断言,判断路径是否是以/user开头,如果是则符合- id: order-serviceuri: lb://orderservicepredicates:- Path=/order/
  • 路由配置包括:
    • 路由id:路由的唯一标识
    • 路由目标uri:路由的目标地址
    • 路由断言predicates:判断路由的规则
    • 路由过滤器filters:对请求或响应做处理

八、路由断言工厂Route Predicate Factory

  • 我们在配置文件中写的断言规则只是字符串,这些字符串会被Predicate Factory读取并处理,转变为路由判断的条件
  • Path=/user/的含义就是:判断路径是否以/user开头
    SpringCloud学习笔记(三)Feign和Gateway

九、全局过滤器GlobalFilter

  • 全局过滤器的作用也是处理一切进入网关的请求和微服务响应,与GatewayFilter的作用一样
  • 区别在于GatewayFilter通过配置定义,处理逻辑是固定的。而GlobalFilter的逻辑需要自己写代码实现,并且可以自定义处理逻辑,定义方式是实现GlobalFilter接口
  • 自定义类,并实现GlobalFilter接口,具体实现如下
// @Order(-1)  //用于设置拦截器的优先级,越小优先级越高,效果和重写Ordered接口中的getOrder一样
@Component
public class AuthorizeFilter implements GlobalFilter, Ordered {//参数说明://exchange 请求上下文,里面可以获取Request、Response等信息//chain 用来把请求委托给下一个过滤器@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 1.获取请求参数ServerHttpRequest request = exchange.getRequest();MultiValueMap<String, String> params = request.getQueryParams();// 2.获取参数中的 authorization 参数String auth = params.getFirst("authorization");// 3.判断参数值是否等于 adminif ("admin".equals(auth)) {// 4.是,放行return chain.filter(exchange);}// 5.否,拦截// 5.1.设置状态码exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);// 5.2.拦截请求return exchange.getResponse().setComplete();}@Overridepublic int getOrder() {return -1;}
}

十、过滤器执行顺序

  • 请求进入网关后会碰到三类过滤器:当前路由的过滤器、DefaultFilter、GlobalFilter
  • 请求路由后,会将当前路由过滤器和DefaultFilter、GlobalFilter,合并到一个过滤器链中,排序后依次执行每个过滤器
  • 每一个过滤器都必须指定一个int类型的order值,order值越小,优先级越高,执行顺序越靠前
  • GlobalFilter由我们自己用上面的方法指定,路由过滤器和defaultFilter的order由Spring指定,默认是按照声明顺序从1递增
  • 当过滤器的order值一样时,会按照defaultFilter > 路由过滤器 > GlobalFilter的顺序执行

十一、跨域问题处理

  • 跨域:域名不一致就是跨域,主要包括域名不同和域名相同但端口不同这两种情况
  • 跨域问题:浏览器禁止请求的发起者与服务端发生跨域ajax请求,请求被浏览器拦截的问题
  • 解决方案:CORS,即跨域资源共享,
  • ajax和http请求的区别:
    • ajax通过xmlHttpRequest对象请求服务器,而http请求通过httpRequest对象请求服务器;
    • ajax请求:浏览器不会对界面进行任何更新操作,只是调用监视的回调函数并传入响应相关数据
    • 一般请求:浏览器一般会直接显示响应体数据,也就是我们常说的刷新/珠转页面
  • 网关处理跨域采用的同样是CORS方案,并且只需要简单配置即可实现,常用配置如下
spring:cloud:gateway:globalcors: #全局的跨域处理add-to-simple-url-handlar-mapping: true #解决options请求被拦截问题corsConfigurations:'[/]': #对所有请求都做处理allowedOrigins: #允许哪些网站的跨域请求- "http://localhost:8083"allowedMethods: #允许的跨域ajax的请求方式- "GET"- "POST"- "PUT"- "OPTIONS"allowedHeaders: "*" # 允许在请求中携带的头信息allowCredentials: true # 是否运行携带cookiemaxAge: 360000 # 这次跨域检测的有效期