springcloud gateway自定义断言规则详解,以后缀结尾进行路由

@Component

public class ExtCheckRoutePredicateFactory extends AbstractRoutePredicateFactory<ExtCheckRoutePredicateFactory.Config> {

     public ExtCheckRoutePredicateFactory() {

         super (Config. class );

     }

     @Override

     public Predicate<ServerWebExchange> apply(Config config) {

         return new Predicate<ServerWebExchange>() {

             @Override

             public boolean test(ServerWebExchange serverWebExchange) {

                 String url=serverWebExchange.getRequest().getURI().toString();

                 if (url.endsWith( ".html" )){

                     return true ;

                 }

                 return false ;

             }

         };

     }

     public static class Config{

         private String name;

         public String getName(){

             return name;

         }

         public void setName(String name){

             this .name=name;

         }

     }

}

gateway:

     routes:

       - id: abc

         uri: http: //localhost:8080

         predicates:

           - name: ExtCheck

@Bean

  public RouteLocator routeDefinitionRouteLocator(GatewayProperties properties,

   List<GatewayFilterFactory> gatewayFilters,

   List<RoutePredicateFactory> predicates,

   RouteDefinitionLocator routeDefinitionLocator,

   ConfigurationService configurationService) {

   predicates.add( new ExtCheckRoutePredicateFactory());

   return new RouteDefinitionRouteLocator(routeDefinitionLocator, predicates,

     gatewayFilters, properties, configurationService);

  }

server:

   port: 7000

spring:

   zipkin:

     base-url: http: //127.0.0.1:9411/  #zipkin server的请求地址

     discoveryClientEnabled: false #让nacos把它当成一个URL，而不要当做服务名

   sleuth:

     sampler:

       probability: 1.0   #采样的百分比

   application:

     name: api-gateway

   cloud:

     nacos:

       discovery:

         server-addr: localhost: 8848 # 将gateway注册到nacos

     gateway:

       discovery:

         locator:

           enabled: true # 让gateway从nacos中获取服务信息

       routes:

         - id: product_route

           uri: lb: //service-product

           order: 1

           predicates:

             - Path=/product-serv/**

           filters:

             - StripPrefix= 1

         - id: order_route

           uri: lb: //service-order

           order: 1

           predicates:

             - Path=/order-serv/**

             - Age= 18 , 60

           filters:

             - StripPrefix= 1

import lombok.Data;

import lombok.NoArgsConstructor;

import org.apache.commons.lang3.StringUtils;

import org.springframework.cloud.gateway.handler.predicate.AbstractRoutePredicateFactory;

import org.springframework.stereotype.Component;

import org.springframework.web.server.ServerWebExchange;

import java.util.Arrays;

import java.util.List;

import java.util.function.Predicate;

//这是一个自定义的路由断言工厂类,要求有两个

//1 名字必须是 配置+RoutePredicateFactory

//2 必须继承AbstractRoutePredicateFactory<配置类>

@Component

public class AgeRoutePredicateFactory extends AbstractRoutePredicateFactory<AgeRoutePredicateFactory.Config> {

     //构造函数

     public AgeRoutePredicateFactory() {

         super (Config. class );

     }

     //读取配置文件的中参数值 给他赋值到配置类中的属性上

     public List<String> shortcutFieldOrder() {

         //这个位置的顺序必须跟配置文件中的值的顺序对应

         return Arrays.asList( "minAge" , "maxAge" );

     }

     //断言逻辑

     public Predicate<ServerWebExchange> apply(Config config) {

         return new Predicate<ServerWebExchange>() {

             @Override

             public boolean test(ServerWebExchange serverWebExchange) {

                 //1 接收前台传入的age参数

                 String ageStr = serverWebExchange.getRequest().getQueryParams().getFirst( "age" );

                 //2 先判断是否为空

                 if (StringUtils.isNotEmpty(ageStr)) {

                     //3 如果不为空,再进行路由逻辑判断

                     int age = Integer.parseInt(ageStr);

                     if (age < config.getMaxAge() && age > config.getMinAge()) {

                         return true ;

                     } else {

                         return false ;

                     }

                 }

                 return false ;

             }

         };

     }

     //配置类,用于接收配置文件中的对应参数

     @Data

     @NoArgsConstructor

     public static class Config {

         private int minAge; //18

         private int maxAge; //60

     }

}