目录
1.🍟网关是什么
2.🍿gateway是什么
3.🥚gateway能什么
4.🌭核心概念
5.🧂工作流程
6.🧈实例
1.建模块
2.添pom
<dependencies>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.example</groupId>
<artifactId>cloud-api-commons</artifactId>
<version>${project.version}</version>
</dependency>
<!--eureka的Client端-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<!--gateway-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
</dependencies>3.改yml
server:
port: 9527
spring:
application:
name: cloud-gateway
cloud:
gateway:
routes:
- id: payment_routh #路由的ID，没有固定当必须唯一
uri: http://localhost:8001 #匹配后提供服务的路由地址
predicates:
- Path=/payment/selectById/** #断言，路径匹配则进行断言
- id: payment_routh2
uri: http://localhost:8001
predicates:
- Path=/payment/lb/**
eureka:
instance:
hostname: cloud-gateway-service
client:
register-with-eureka: true
fetch-registry: true
service-url:
defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka,http://eureka7003.com:7003/eureka
4.主启动
@SpringBootApplication
@EnableEurekaClient
public class GateWayMain9527 {
public static void main(String[] args) {
SpringApplication.run(GateWayMain9527.class);
}
}5.测试
访问9527时，能路由到8001
7.🥓gateway网关配置的方式
@Configuration
public class GateWayConfig {
@Bean
public RouteLocator customRouteLocator(RouteLocatorBuilder routeLocatorBuilder) {
RouteLocatorBuilder.Builder routes = routeLocatorBuilder.routes();
routes.route("path_route_xz1",
r -> r.path("/board").uri("https://top.baidu.com/board")).build();
return routes.build();
}
}
8.🍳配置动态路由
server:
port: 9527
spring:
application:
name: cloud-gateway
cloud:
gateway:
discovery:
locator:
enabled: true #开启从注册中心动态创建路由功能，利用微服务名进行路由
routes:
- id: payment_routh #路由的ID，没有固定当必须唯一
uri: lb://COULD-PAYMENT-SERVICE #匹配后提供服务的路由地址
predicates:
- Path=/payment/selectById/** #断言，路径匹配则进行断言
- id: payment_routh2
uri: lb://COULD-PAYMENT-SERVICE
predicates:
- Path=/payment/lb/**
eureka:
instance:
hostname: cloud-gateway-service
client:
register-with-eureka: true
fetch-registry: true
service-url:
defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka,http://eureka7003.com:7003/eureka
9.🧇predicate的使用
1.After | Before | Between
spring:
application:
name: cloud-gateway
cloud:
gateway:
discovery:
locator:
enabled: true #开启从注册中心动态创建路由功能，利用微服务名进行路由
routes:
- id: payment_routh #路由的ID，没有固定当必须唯一
uri: lb://COULD-PAYMENT-SERVICE #匹配后提供服务的路由地址
predicates:
- Path=/payment/selectById/** #断言，路径匹配则进行断言
- After=2023-12-23T18:40:04.099+08:00[Asia/Shanghai] #在这个时间后才会生效
- Before=2023-12-23T18:40:04.099+08:00[Asia/Shanghai] #在这个时间之前才会生效
- Between=2023-12-23T18:40:04.099+08:00[Asia/Shanghai],2023-12-23T18:40:04.099+08:00[Asia/Shanghai] #在这个时间段才会生效
2.cookie
访问时必须携带cookie
spring:
application:
name: cloud-gateway
cloud:
gateway:
discovery:
locator:
enabled: true #开启从注册中心动态创建路由功能，利用微服务名进行路由
routes:
- id: payment_routh #路由的ID，没有固定当必须唯一
uri: lb://COULD-PAYMENT-SERVICE #匹配后提供服务的路由地址
predicates:
- Path=/payment/selectById/** #断言，路径匹配则进行断言
- Cookie=username,xz #访问时必须需携带cookie 10.🥞自定义filter
@Component
@Slf4j
public class MyLogGateWayFilter implements GlobalFilter, Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
log.info("com in MyLogGateWayFilter:"+new Date());
String uname = exchange.getRequest().getQueryParams().getFirst("uname");
if (uname==null){
log.info("用户名为null，非法");
exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);
return exchange.getResponse().setComplete();
}
log.info("uname="+uname);
return chain.filter(exchange);
}
@Override
public int getOrder() {
return 0;
}
}访问时必须添加uname，否则报错
