Problem with Spring cloud gateway filters

Viewed 150

I try use Spring Cloud Gateway Filter for my request. I tried use some variants realisation filters like below:

@Component
@Slf4j
@Order(-10000)
public class CustomFilter extends AbstractGatewayFilterFactory<CustomFilter.Config> {

    public CustomFilter() {
        super(Config.class);
        log.info("Loaded GatewayFilterFactory [Authorize]");
    }

    @Override
    public List<String> shortcutFieldOrder() {
        return Arrays.asList("enabled");
    }


    @Override
    public ShortcutType shortcutType() {
        return ShortcutType.DEFAULT;
    }

    @Override
    public GatewayFilter apply(CustomFilter.Config config) {
        log.info("Into apply");
        return (exchange, chain)->{
            log.info("Into exchange!");
            System.out.println(exchange.getRequest() + " request");

            return chain.filter(exchange);
        };
    }

    public static class Config {
        private boolean enabled;

        public Config() {}

        public boolean isEnabled() {
            return enabled;
        }

        public void setEnabled(boolean enabled) {
            this.enabled = enabled;
        }

    }
}

Component
@Slf4j
public class MainFilter implements GatewayFilterFactory<MainFilter.Config> {

    @Override
    public GatewayFilter apply(Config config) {
        log.info("[Apply]");
        return (exchange, chain) -> {
            log.info("[Apply: {}]", exchange);
            System.out.println("gateway filter name " + config.getName());
            return chain.filter(exchange);
        };
    }

    @Override
    public Class<Config> getConfigClass() {
        return Config.class;
    }

    @Override
    public Config newConfig() {
        return new Config("MainFilter");
    }

    public static class Config {

        public Config(String name) {
            this.name = name;
        }

        private String name;

        public String getName() {
            return name;
        }

        public void setName(String name) {
            this.name = name;
        }
    }
}

My gateway.yml file below:

server:
  port: 8080

management:
  endpoint:
    gateway:
      enabled: true
  endpoints:
    web:
      exposure:
        include: gateway

spring:
  cloud:
    discovery:
      enabled: true
    gateway:
      discovery:
        locator:
          enabled: true
          lowerCaseServiceId: true
#      default-filters:
#        - name: MainFilter
      routes:
        - id: second_route
          uri: lb://auth-service
          predicates:
          - Path=/api/v1/**
          filters:
          - MainFilter

  application:
    loadbalancer:
      ribbon:
        enabled: false

But when i create request for service localhost:8080/auth-service/api/v1/ Filter not working. I don't see mwssahe log.info() on my console. But when i use conditions default-filter in my gateway.yml my custom filter is working. What problem for use custom filter with my route?

0 Answers
Related