0
点赞
收藏
分享

微信扫一扫

网关Zuul+route+Filter+Fallback+Retry笔记20221202

是归人不是过客 2022-12-19 阅读 94

一、ek2014
1、pom.xml
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  </dependency>

2、application.properties
# 应用名称
spring.application.name=eureka

server.port=2013
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false
eureka.client.service-url.defaultZone=http://localhost:2013/eureka/
eureka.server.eviction-interval-timer-in-ms=5

 

3、Ek2013Application
@EnableEurekaServer
@SpringBootApplication
public class Ek2013Application {
  public static void main(String[] args) {
    SpringApplication.run(Ek2013Application.class, args);
  }
}

网关Zuul+route+Filter+Fallback+Retry笔记20221202_.net

 

 

网关Zuul+route+Filter+Fallback+Retry笔记20221202_.net_02

 

 

二、Provider2033
1、pom.xml
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

2、application.properties
# 应用名称
spring.application.name=provider2033
# 应用服务 WEB 访问端口
server.port=2033
##eureka
eureka.client.service-url.defaultZone=http://localhost:2013/eureka/
eureka.instance.prefer-ip-address=true
eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port}
eureka.instance.lease-renewal-interval-in-seconds=5
eureka.instance.lease-expiration-duration-in-seconds=10

 

3、Provider2033Application
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@EnableDiscoveryClient
@SpringBootApplication
public class Provider2033Application {

       private final Logger logger= (Logger) LoggerFactory.getLogger(FallbackProvider.class);

  public static void main(String[] args) {
    SpringApplication.run(Provider2033Application.class, args);
  }

  @Value("${server.port}")
  String port;

  @RequestMapping("/")
  public String home(){    

    logger.info("request tow name");
    try {
      Thread.sleep(1000000);
    }catch (Exception e){
      logger.error("hello tow error",e);
    }
    return "软件老五,端口"+port+" ,this is twn message";

  }

}

 

网关Zuul+route+Filter+Fallback+Retry笔记20221202_ide_03

 

 

 

三、Zull2041
1、pom.xml
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
  </dependency>

  <dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
  </dependency>

2、application.properties

# 应用名称
spring.application.name=zuul2041
server.port=2041

##eureka
eureka.client.service-url.defaultZone=http://localhost:2013/eureka/
eureka.client.registry-fetch-interval-seconds=30
eureka.instance.lease-renewal-interval-in-seconds=15
eureka.instance.lease-expiration-duration-in-seconds=45

#####route id: api-provider
#####service-id:provider2033
##http://localhost:2033  ==> http://localhost:2041/provider

######1、第一种
##-----zuul.routes.api-provider.path=/provider/**
##-----zuul.routes.api-provider.service-id=provider2033

######2、第二种 简易配置(route id、service-id一样)
####若route id、service-id:一样 provider2033
zuul.routes.provider2033.path=/provider/**
##zuul.routes.api-provider.service-id=provider2033
####

 

 

3、Zull2041Application
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;

@EnableZuulProxy
@EnableEurekaClient
@SpringBootApplication
public class Zull2041Application {

  public static void main(String[] args) {
    SpringApplication.run(Zull2041Application.class, args);
  }

  //***********MyZullFilter第一种@Bean启用
  //MyZullFilter的@Component 注解掉
  @Bean
  public MyZullFilter myZullFilter(){
    return new MyZullFilter();
  }

  //***********MyZullFilter第二种的@Component启用
  //Zull2041Application的@Bean 注解掉

}

4、MyZullFilter

import com.google.common.util.concurrent.RateLimiter;
import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import com.netflix.zuul.exception.ZuulException;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;

@Component
public class MyZullFilter extends ZuulFilter {

每秒放多少个token(10个)
    private static final RateLimiter RATE_LIMITER=RateLimiter.create(10);
    /**
    * 过滤类型
    * @return
    */
    @Override
    public String filterType() {
      return "pre";
    }

    /**
    * 请求过滤顺序
    * @return
    */
    @Override
    public int filterOrder() {
      return 0;
    }

    /**
    * 判断过滤器是否生效
    * @return
    */
    @Override
    public boolean shouldFilter() {
      return true;
    }

    @Override
    public Object run() throws ZuulException {
      /* if(!RATE_LIMITER.tryAcquire()){
        System.out.println("限流.....................");
      }*/

      //获取token参数
      RequestContext rc=RequestContext.getCurrentContext();
      if(!RATE_LIMITER.tryAcquire()) {
        rc.setSendZuulResponse(false);
        rc.setResponseStatusCode(HttpStatus.TOO_MANY_REQUESTS.value());
        System.out.println("限流.....................");
      }

      HttpServletRequest request=rc.getRequest();

token");
      if(token!=null){
        return null;
      }
      //表示不进行路由
      rc.setSendZuulResponse(false);
      rc.setResponseStatusCode(401);
      try {
        rc.getResponse().setContentType("text/html;charset=utf-8");
        rc.getResponse().getWriter().write("没有传递正确参数,请校验后重试~");
      }catch (IOException e){
        e.printStackTrace();
      }
      return null;
    }

}

 

网关Zuul+route+Filter+Fallback+Retry笔记20221202_.net_04

 

 

网关Zuul+route+Filter+Fallback+Retry笔记20221202_spring_05

 

 

网关Zuul+route+Filter+Fallback+Retry笔记20221202_ide_06

 

 

 5、ProducerFallback

  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  import org.springframework.cloud.netflix.zuul.filters.route.FallbackProvider;
  import org.springframework.http.HttpHeaders;
  import org.springframework.http.HttpStatus;
  import org.springframework.http.MediaType;
  import org.springframework.http.client.ClientHttpResponse;
  import org.springframework.stereotype.Component;
  import java.io.ByteArrayInputStream;
  import java.io.IOException;
  import java.io.InputStream;

  /***
  * 熔断处理
  */
  @Component
  public class ProducerFallback implements FallbackProvider {
    private final Logger logger= (Logger) LoggerFactory.getLogger(FallbackProvider.class);

service-id:provider2033
    @Override
    public String getRoute() {
      return "provider2033";
    }

    public ClientHttpResponse fallbackResponse() {
      return new ClientHttpResponse(){

        @Override
        public HttpHeaders getHeaders() {
          HttpHeaders headers=new HttpHeaders();
          headers.setContentType(MediaType.APPLICATION_JSON);
          return headers;
        }

        @Override
        public InputStream getBody() throws IOException {
          return new ByteArrayInputStream("The service is unavailable.".getBytes());
        }

        @Override
        public HttpStatus getStatusCode() throws IOException {
          return HttpStatus.OK;
        }

        @Override
        public int getRawStatusCode() throws IOException {
          return 200;
        }

        @Override
        public String getStatusText() throws IOException {
          return "OK";
        }

        @Override
        public void close() {

        }
      };
  }

  @Override
  public ClientHttpResponse fallbackResponse(String route, Throwable cause) {
    if(cause!=null&&cause.getCause()!=null){
      String reason=cause.getCause().getMessage();
      logger.info("Exception{}"+reason);
    }
    return fallbackResponse();
  }
}

 

 

网关Zuul+route+Filter+Fallback+Retry笔记20221202_ide_07

 

 6、路由重启

网关Zuul+route+Filter+Fallback+Retry笔记20221202_spring_08

 

 

网关Zuul+route+Filter+Fallback+Retry笔记20221202_ide_09

 

 

 

 

四、Jmeter测试

测限流

网关Zuul+route+Filter+Fallback+Retry笔记20221202_spring_10

 

 

网关Zuul+route+Filter+Fallback+Retry笔记20221202_spring_11

 

 

网关Zuul+route+Filter+Fallback+Retry笔记20221202_spring_12

 

举报

相关推荐

0 条评论