springcloud gateway概念精講
點(diǎn)擊上方藍(lán)色字體，選擇“標(biāo)星公眾號(hào)”
優(yōu)質(zhì)文章，第一時(shí)間送達(dá)
一、定義
網(wǎng)關(guān)解決方案對(duì)比
基礎(chǔ)說明
二、核心術(shù)語
Route路由
Predicate謂詞、斷言
Filter過濾器
三、簡單原理
四、概念講解
Route Predcate Factories
配置形式
模糊匹配和精確匹配
spring:
cloud:
gateway:
routes:
- id: {唯一標(biāo)識(shí)}
uri: http://www.itmuch.com
spring:
cloud:
gateway:
routes:
- id: {唯一標(biāo)識(shí)}
uri: http://www.itmuch.com/spring-cloud/spring-cloud-stream-pan-ta/
路由轉(zhuǎn)發(fā)到微服務(wù)
routes:
- id: user_route
uri: lb://user-center
predicates:
- Path=/users/**
自定義predicate工廠
routes:
- id: after_route
uri: lb://user-center
predicates:
# 當(dāng)且僅當(dāng)請(qǐng)求時(shí)的時(shí)間After配置的時(shí)間時(shí)，才會(huì)轉(zhuǎn)發(fā)到用戶微服務(wù)
# 目前配置不會(huì)進(jìn)該路由配置，所以返回404
# 將時(shí)間改成 < now的時(shí)間，則訪問localhost:8040/** -> user-center/**
# eg. 訪問http://localhost:8040/users/1 -> user-center/users/1
- After=2010-01-20T17:42:47.789-07:00[America/Denver]
- TimeBetween=00:00:00,12:44:13
@Data
public class TimeBetweenBean {
private String start;
private String end;
}
@Component
public class TimeBetweenRoutePredicateFactory
extends AbstractRoutePredicateFactory <TimeBetweenBean>{
public TimeBetweenRoutePredicateFactory() {
super(TimeBetweenBean.class);
}
/**
* 謂詞工廠的核心方法，控制路由的判斷人條件
* @param config
* @return
*/
@Override
public Predicate<ServerWebExchange> apply(TimeBetweenBean config) {
String start = config.getStart();
String end = config.getEnd();
return serverWebExchange ->{
LocalTime now = LocalTime.now();
System.out.println(now.isAfter(LocalTime.parse(start)));
return now.isAfter(LocalTime.parse(start)) && now.isBefore(LocalTime.parse(end));
};
}
/**
* 控制配置類和配置文件映射關(guān)系,和配置文件順序一致
* @return
*/
@Override
public List<String> shortcutFieldOrder() {
return Arrays.asList("start","end");
}
}
discovery:
locator:
enabled: true # 開啟從注冊(cè)中心動(dòng)態(tài)創(chuàng)建路由
五、Filter
生命周期
gateway自帶過濾器講解
1. RewritePath 請(qǐng)求地址重定向
pring:
cloud:
gateway:
routes:
- id: rewritepath_route
uri: https://example.org
predicates:
- Path=/red/**
filters:
- RewritePath=/red/?(?<segment>.*), /$\{segment}
2. PrefixPath 添加前綴
spring:
cloud:
gateway:
routes:
- id: prefixpath_route
uri: https://example.org
filters:
- PrefixPath=/mypath
3. StripPrefix 刪除前綴
spring:
cloud:
gateway:
routes:
- id: nameRoot
uri: https://nameservice
predicates:
- Path=/name/**
filters:
- StripPrefix=2
全局過濾器GlobalFilter
自定義過濾器工廠
自定義網(wǎng)關(guān)過濾器
@Component
@Slf4j
public class MyLogGateWayFilter implements GlobalFilter, Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
log.info("**** com int mylogglbalfiltert{}",new Date());
String uname = exchange.getRequest().getQueryParams().getFirst("uname");
if(uname==null){
log.info("非法用戶");
exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE); //返回狀態(tài)碼
return exchange.getResponse().setComplete();
}
return chain.filter(exchange);
}
@Override
public int getOrder() {
return 0;
}
}
@Configuration
public class GateWayConfig {
@Bean
public RouteLocator customRouteLocator(RouteLocatorBuilder routeLocatorBuilder){
RouteLocatorBuilder.Builder routes = routeLocatorBuilder.routes();
routes.route("path_route_kouryoushine",
r->r.path("guonei").
uri("http://news.baidu.com/guonei")).build();
return routes.build() ;
}
}
全局過濾器
核心API
filters:
- AddRequestHeader=X-Request-Foo,Bar
- PreLog=a,b
@Slf4j
@Component
public class PreLogGatewayFilterFactory extends AbstractNameValueGatewayFilterFactory {
@Override
public GatewayFilter apply(NameValueConfig config) {
log.info("請(qǐng)求建立了{(lán)}{}",config.getName(),config.getValue());
return (exchagne,chain)->{
log.info("請(qǐng)求建立了{(lán)}{}",config.getName(),config.getValue());
ServerHttpRequest request = exchagne.getRequest()
.mutate()
.build();
ServerWebExchange exchange = exchagne.mutate()
.request(request)
.build();
return chain.filter(exchange);
};
}
}
全局過濾器
全局監(jiān)控
版權(quán)聲明：本文為博主原創(chuàng)文章，遵循 CC 4.0 BY-SA 版權(quán)協(xié)議，轉(zhuǎn)載請(qǐng)附上原文出處鏈接和本聲明。
本文鏈接：
https://blog.csdn.net/kouryoushine/article/details/117048823
評(píng)論
圖片
表情