springboot zuul实现网关的代码

dependencies {  implementation('org.springframework.cloud:spring-cloud-starter-netflix-eureka-client')  implementation('org.springframework.cloud:spring-cloud-starter-netflix-zuul')  testImplementation('org.springframework.boot:spring-boot-starter-test')  implementation('com.marcosbarbero.cloud:spring-cloud-zuul-ratelimit:1.3.2.RELEASE')}

server: port: 8300spring: application:  name: microservice-gateway-zuuleureka: client:  register-with-eureka: true  fetch-registry: true  service-url:   defaultZone: http://localhost:6761/eureka instance:  ip-address: truezuul: routes:  users:    path: /lind/** #以lind开头的路径被重定向到lind服务    serviceId: lind add-host-header: true #显示真实的http头 retryable: false #关闭Hystrix的重试功能 ratelimit:  enabled: true  # repository: REDIS  behind-proxy: true  policies:    users:     limit: 5 #限流，每分钟请求5次     refresh-interval: 60     type:      - user      - origin      - url     #    url类型的限流就是通过请求路径区分     #    origin是通过客户端IP地址区分     #    user是通过授权用户进行区分，也包括匿名用户

public class PreRequestLogFilter extends ZuulFilter { private static final Logger logger = LoggerFactory.getLogger(PreRequestLogFilter.class); private final RateLimiter rateLimiter = RateLimiter.create(1000.0); @Override public Object run() {  try {   RequestContext currentContext = RequestContext.getCurrentContext();   HttpServletResponse response = currentContext.getResponse();   HttpServletRequest reqeust = currentContext.getRequest();   currentContext.addZuulRequestHeader("userId","123");//向子系统http头写数据   currentContext.addZuulRequestHeader("userName","test");   PreRequestLogFilter.logger.info(     String.format("send %s request to %s",       reqeust.getMethod(),       reqeust.getRequestURL().toString()));   if (!rateLimiter.tryAcquire()) {    HttpStatus httpStatus = HttpStatus.TOO_MANY_REQUESTS;    response.setContentType(MediaType.TEXT_PLAIN_VALUE);    response.setStatus(httpStatus.value());    response.getWriter().append(httpStatus.getReasonPhrase());    currentContext.setSendZuulResponse(false);    throw new ZuulException(      httpStatus.getReasonPhrase(),      httpStatus.value(),      httpStatus.getReasonPhrase()    );   }  } catch (java.lang.Exception e) {   ReflectionUtils.rethrowRuntimeException(e);  }  return null; } @Override public boolean shouldFilter() {  // 判断是否需要过滤  return true; } @Override public String filterType() {  return FilterConstants.PRE_TYPE; } @Override public int filterOrder() {  return Ordered.HIGHEST_PRECEDENCE; }}

@Bean public PreRequestLogFilter preRequestLogFilter() {  return new PreRequestLogFilter(); }