目录
Feign远程调用
基于Feign远程调用
先来看我们以前利用RestTemplate发起远程调用的代码：
•代码可读性差，编程体验不统一
•参数复杂URL难以维护
Feign替代RestTemplate
1.引入依赖
我们在order-service服务的pom文件中引入feign的依赖
-
<dependency>
-
<groupId>org.springframework.cloud</groupId>
-
<artifactId>spring-cloud-starter-openfeign</artifactId>
-
</dependency>
2.添加注解
3.编写Feign的客户端
在order-service中新建一个接口，内容如下
-
package com.tledu.order.client;
-
-
import com.tledu.order.pojo.User;
-
import org.springframework.cloud.openfeign.FeignClient;
-
import org.springframework.web.bind.annotation.GetMapping;
-
import org.springframework.web.bind.annotation.PathVariable;
-
-
@FeignClient("userservice")
-
public
interface
UserClient {
-
@GetMapping("/user/{id}")
-
User
findById
(@PathVariable("id") Long id);
-
}
4.测试
修改order-service中的OrderService类中的queryOrderById方法，使用Feign客户端代替RestTemplate：
5.总结
① 引入依赖
② 添加@EnableFeignClients注解
③ 编写FeignClient接口
④ 使用FeignClient中定义的方法代替RestTemplate
自定义配置
-
feign:
-
client:
-
config:
-
userservice:
# 针对某个微服务的配置
-
loggerLevel: FULL
# 日志级别
- NONE：不记录任何日志信息，这是默认值。
- BASIC：仅记录请求的方法，URL以及响应状态码和执行时间
- HEADERS：在BASIC的基础上，额外记录了请求和响应的头信息
- FULL：记录所有请求和响应的明细，包括头信息、请求体、元数据。
性能优化
Feign底层发起http请求，依赖于其它的框架。其底层客户端实现包括：
•URLConnection：默认实现，不支持连接池
•Apache HttpClient ：支持连接池
•OKHttp：支持连接池
因此提高Feign的性能主要手段就是使用连接池代替默认的URLConnection。
1.引入依赖
在order-service的pom文件中引入Apache的HttpClient依赖
-
<!--httpClient的依赖 -->
-
<dependency>
-
<groupId>io.github.openfeign</groupId>
-
<artifactId>feign-httpclient</artifactId>
-
</dependency>
2.配置连接池
在order-service的application.yml中添加配置
-
feign:
-
client:
-
config:
-
default:
# default全局的配置
-
loggerLevel: BASIC
# 日志级别，BASIC就是基本的请求和响应信息
-
httpclient:
-
enabled:
true
# 开启feign对HttpClient的支持
-
max-connections: 200
# 最大的连接数
-
max-connections-per-route: 50
# 每个路径的最大连接数
3.总结
Feign的优化：
2.使用HttpClient或OKHttp代替URLConnection
① 引入feign-httpClient依赖
② 配置文件开启httpClient功能，设置连接池参数
Gateway网关
Gateway网关是我们服务的守门神，所有微服务的统一入口。
权限控制：网关作为微服务入口，需要校验用户是是否有请求资格，如果没有则进行拦截。
路由和负载均衡：一切请求都必须先经过gateway，但网关不处理业务，而是根据某种规则，把请求转发到某个微服务，这个过程叫做路由。当然路由的目标服务有多个时，还需要做负载均衡。
限流：当请求流量过高时，在网关中按照下流的微服务能够接受的速度来放行请求，避免服务压力过大。
Gateway快速入门
- 创建SpringBoot工程gateway，引入网关依赖
- 编写启动类
- 编写基础配置和路由规则
- 启动网关服务进行测试
1.创建gateway服务，引入依赖
-
<!--网关-->
-
<dependency>
-
<groupId>org.springframework.cloud</groupId>
-
<artifactId>spring-cloud-starter-gateway</artifactId>
-
</dependency>
-
<!--nacos服务发现依赖-->
-
<dependency>
-
<groupId>com.alibaba.cloud</groupId>
-
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
-
</dependency>
-
2.编写启动类
-
package cn.itcast.gateway;
-
-
import org.springframework.boot.SpringApplication;
-
import org.springframework.boot.autoconfigure.SpringBootApplication;
-
-
@SpringBootApplication
-
public
class
GatewayApplication {
-
-
public
static
void
main
(String[] args) {
-
SpringApplication.run(GatewayApplication.class, args);
-
}
-
}
3.编写基础配置和路由规则
创建application.yml文件，内容如下
-
server:
-
port: 10010
# 网关端口
-
spring:
-
application:
-
name: gateway
# 服务名称
-
cloud:
-
nacos:
-
server-addr: localhost:8848
# nacos地址
-
gateway:
-
routes:
# 网关路由配置
-
-
id: user-service
# 路由id，自定义，只要唯一即可
-
# uri: http://127.0.0.1:8081 # 路由的目标地址 http就是固定地址
-
uri: lb://userservice
# 路由的目标地址 lb就是负载均衡，后面跟服务名称
-
predicates:
# 路由断言，也就是判断请求是否符合路由规则的条件
-
- Path=/user/**
# 这个是按照路径匹配，只要以/user/开头就符合要求
4.重启测试
重启网关，访问http://localhost:10010/user/1时，符合/user/**规则，请求转发到uri：http://userservice/user/1，得到了结果：
过滤器
路由过滤器
请求头过滤器
需求：给所有进入userservice的请求添加一个请求头：Truth=itcast is freaking awesome!
只需要修改gateway服务的application.yml文件，添加路由过滤即可：
-
spring:
-
cloud:
-
gateway:
-
routes:
-
-
id: user-service
-
uri: lb://userservice
-
predicates:
-
- Path=/user/**
-
filters:
# 过滤器
-
- AddRequestHeader=Truth, tledu is freaking awesome!
# 添加请求头
当前过滤器写在userservice路由下，因此仅仅对访问userservice的请求有效。
默认过滤器DefaultFilter
如果要对所有的路由都生效，则可以将过滤器工厂写到default下。格式如下
-
spring:
-
cloud:
-
gateway:
-
routes:
-
-
id: user-service
-
uri: lb://userservice
-
predicates:
-
- Path=/user/**
-
default-filters:
# 默认过滤项
-
- AddRequestHeader=Truth, tledu is freaking awesome!
-
@GetMapping("{orderId}")
-
public Order
queryOrderByUserId
(@PathVariable("orderId") Long orderId, HttpServletRequest request, @RequestHeader(value = "Truth") String va) {
-
System.out.println(va);
-
-
Enumeration<String> headerNames = request.getHeaderNames();
-
while (headerNames.hasMoreElements()){
-
String
s
= headerNames.nextElement();
-
if(
"Truth".equals(s)){
-
String
header
= request.getHeader(s);
-
System.out.println(header);
-
}
-
}
-
// 根据id查询订单并返回
-
return orderService.queryOrderById(orderId);
-
}
全局过滤器GlobalFilter
-
public
interface
GlobalFilter {
-
/**
-
* 处理当前请求，有必要的话通过{@link GatewayFilterChain}将请求交给下一个过滤器处理
-
*
-
* @param exchange 请求上下文，里面可以获取Request、Response等信息
-
* @param chain 用来把请求委托给下一个过滤器
-
* @return {@code Mono<Void>} 返回标示当前过滤器业务结束
-
*/
-
Mono<Void>
filter
(ServerWebExchange exchange, GatewayFilterChain chain);
-
}
自定义全局过滤器
需求：定义全局过滤器，拦截请求，判断请求的参数是否满足下面条件：
-
package cn.itcast.gateway.filters;
-
-
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
-
import org.springframework.cloud.gateway.filter.GlobalFilter;
-
import org.springframework.core.annotation.Order;
-
import org.springframework.http.HttpStatus;
-
import org.springframework.stereotype.Component;
-
import org.springframework.web.server.ServerWebExchange;
-
import reactor.core.publisher.Mono;
-
-
@Order(-1)
-
@Component
-
public
class
AuthorizeFilter
implements
GlobalFilter {
-
@Override
-
public Mono<Void>
filter
(ServerWebExchange exchange, GatewayFilterChain chain) {
-
// 1.获取请求参数
-
MultiValueMap<String, String> params = exchange.getRequest().getQueryParams();
-
// 2.获取authorization参数
-
String
auth
= params.getFirst(
"authorization");
-
// 3.校验
-
if (
"admin".equals(auth)) {
-
// 放行
-
return chain.filter(exchange);
-
}
-
// 4.拦截
-
// 4.1.禁止访问，设置状态码
-
exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);
-
// 4.2.结束处理
-
return exchange.getResponse().setComplete();
-
}
-
}
-
过滤器执行顺序
请求进入网关会碰到三类过滤器：当前路由的过滤器、DefaultFilter、GlobalFilter
请求路由后，会将当前路由过滤器和DefaultFilter、GlobalFilter，合并到一个过滤器链（集合）中，排序后依次执行每个过滤器：
- 每一个过滤器都必须指定一个int类型的order值，order值越小，优先级越高，执行顺序越靠前。
- GlobalFilter通过实现Ordered接口，或者添加@Order注解来指定order值，由我们自己指定
- 路由过滤器和defaultFilter的order由Spring指定，默认是按照声明顺序从1递增。
- 当过滤器的order值一样时，会按照 defaultFilter > 路由过滤器 > GlobalFilter的顺序执行。
总结
① 对路由的请求或响应做加工处理，比如添加请求头
② 配置在路由下的过滤器只对当前路由的请求生效
defaultFilters的作用是什么？对所有路由都生效的过滤器
转载：https://blog.csdn.net/qq_43009048/article/details/128856528