Zuul Api Gateway映射了错误的服务URL（字符集）？

2 回答

• 0

  当你使用Spring启动时，我建议你为zuul网关使用注释，并为zuul创建自定义过滤器，它将照顾每一件事 .

  请找到下面的代码，看看它是否适合您：

  主类

  @EnableZuulProxy
  @SpringBootApplication
  @EnableScheduling
  @EnableFeignClients(basePackages = { Constants.FEIGN_BASE_PACKAGE })
  @ComponentScan(basePackages = { Constants.BASE_PACKAGE, Constants.LOGGING_PACKAGE })
  @EntityScan(basePackages = { Constants.ENTITY_BASE_PACKAGE })
  @EnableDiscoveryClient
  public class GatewayInitializer {
  
      /**
       * The main method.
       *
       * @param args the arguments
       */
      public static void main(String[] args) {
  
          Security.setProperty("networkaddress.cache.ttl", "30");
          ConfigurableApplicationContext context = SpringApplication.run(Initializer.class, args);
  
      }
  

  ZUUL过滤器

  package com.sxm.aota.gateway.filters;
  
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.context.MessageSource;
  import org.springframework.util.ReflectionUtils;
  
  import com.fasterxml.jackson.databind.ObjectMapper;
  import com.netflix.zuul.ZuulFilter;
  import com.netflix.zuul.context.RequestContext;
  import com.netflix.zuul.exception.ZuulException;
  
  
  /**
   * This CustomErrorFilter involve to handle ZuulException.
   */
  public class CustomErrorFilter extends ZuulFilter {
  
      /** The logger. */
      private static final Logger logger = LoggerFactory.getLogger(CustomErrorFilter.class);
      /** The message source. */
      @Autowired
      private MessageSource messageSource;
      /** The properties. */
      @Autowired
      private Properties properties;
  
      /*
       * (non-Javadoc)
       * 
       * @see com.netflix.zuul.ZuulFilter#filterType()
       */
      @Override
      public String filterType() {
          return "post";
      }
  
      /*
       * (non-Javadoc)
       * 
       * @see com.netflix.zuul.ZuulFilter#filterOrder()
       */
      @Override
      public int filterOrder() {
          return -1; // Needs to run before SendErrorFilter which has filterOrder == 0
      }
  
      /*
       * (non-Javadoc)
       * 
       * @see com.netflix.zuul.IZuulFilter#shouldFilter()
       */
      @Override
      public boolean shouldFilter() {
          // only forward to errorPath if it hasn't been forwarded to already
          return RequestContext.getCurrentContext().containsKey("error.status_code");
      }
  
      /*
       * (non-Javadoc)
       * 
       * @see com.netflix.zuul.IZuulFilter#run()
       */
      @Override
      public Object run() {
          try {
              RequestContext ctx = RequestContext.getCurrentContext();
              Object e = ctx.get("error.exception");
              if (e != null && e instanceof ZuulException) {
                  ZuulException zuulException = (ZuulException) e;
                  logger.error("Zuul failure detected: " + zuulException.getMessage(), zuulException);
                  // Remove error code to prevent further error handling in follow up filters
                  ctx.remove("error.status_code");
  
                  } else {
                      error.setMessage(messageSource.getMessage(Constants.REQUESTED_SERVICE_UNAVAILABLE, new Object[] { zuulException.getCause() }, properties.getCurrentLocale()));
                      ctx.setResponseBody(mapper.writeValueAsString(error));
                      ctx.getResponse().setContentType("application/json");
                      ctx.setResponseStatusCode(500); // Can set any error code as excepted
                  }
              }
          } catch (Exception ex) {
              logger.error("Exception filtering in custom error filter", ex);
              ReflectionUtils.rethrowRuntimeException(ex);
          }
          return null;
      }
  }
  

  回复于 2024-05-02T08:55:53+08:00
• 0

  我通过为toLowerCase（Locale.ROOT）选项创建扩展的EurekaDiscoveryClient来解决问题 .

  import com.netflix.appinfo.EurekaInstanceConfig;
  import com.netflix.discovery.EurekaClient;
  import com.netflix.discovery.shared.Application;
  import com.netflix.discovery.shared.Applications;
  import org.springframework.beans.factory.annotation.Qualifier;
  import org.springframework.cloud.client.discovery.DiscoveryClient;
  import org.springframework.cloud.netflix.eureka.EurekaDiscoveryClient;
  import org.springframework.stereotype.Component;
  
  import java.util.*;
  
  @Component
  public class CustomEurekaDiscoveryClient extends EurekaDiscoveryClient implements DiscoveryClient {
  
  
      private final EurekaInstanceConfig config;
  
      private final EurekaClient eurekaClient;
  
      public CustomEurekaDiscoveryClient(EurekaInstanceConfig config, @Qualifier("eurekaClient") EurekaClient eurekaClient) {
          super(config, eurekaClient);
          this.config = config;
          this.eurekaClient = eurekaClient;
      }
  
      @Override
      public List<String> getServices() {
          Applications applications = this.eurekaClient.getApplications();
          if (applications == null) {
              return Collections.emptyList();
          }
          List<Application> registered = applications.getRegisteredApplications();
          List<String> names = new ArrayList<>();
          for (Application app : registered) {
              if (app.getInstances().isEmpty()) {
                  continue;
              }
              names.add(app.getName().toLowerCase(Locale.ROOT));
  
          }
          return names;
      }
  }
  

  大写'I'转换为土耳其语OS和jvm中的小写'ı'而不是'i'这就是我需要覆盖 public List getServices() 方法的原因 .

  如果toLowerCase（Locale.ROOT）方法在没有 Locale.ROOT java转换字符的情况下调用'ı'但使用 Locale.ROOT 选项，方法转换为'i'并且项目工作正常 .

  回复于 2024-05-02T08:55:53+08:00