Spring Cloud Feign резюмирует проблему, обратите внимание, настройка производительности, переключение okhttp3

Java

Сводка часто задаваемых вопросов о притворстве

Используемый интерфейс FeignClient@PathVariable, должен быть указан атрибут value

//在一些早期版本中， @PathVariable("id") 中的 "id" ，也就是value属性，必须指定，不能省略。
@FeignClient("microservice-provider-user")
public interface UserFeignClient {
  @RequestMapping(value = "/simple/{id}", method = RequestMethod.GET)
  public User findById(@PathVariable("id") Long id);
  ...
}

Точки и ямы для Java-кода для настройки Feign Client

@FeignClient(name = "microservice-provider-user", configuration = UserFeignConfig.class)
public interface UserFeignClient {
  @GetMapping("/users/{id}")
  User findById(@PathVariable("id") Long id);
}

/**
 * 该Feign Client的配置类，注意：
 * 1. 该类可以独立出去；
 * 2. 该类上也可添加@Configuration声明是一个配置类；
 * 配置类上也可添加@Configuration注解，声明这是一个配置类；
 * 但此时千万别将该放置在主应用程序上下文@ComponentScan所扫描的包中，
 * 否则，该配置将会被所有Feign Client共享，无法实现细粒度配置！
 * 个人建议：像我一样，不加@Configuration注解
 *
 * @author zhouli
 */
class UserFeignConfig {
  @Bean
  public Logger.Level logger() {
    return Logger.Level.FULL;
  }
}
  • В класс конфигурации также можно добавить аннотацию @Configuraiton, объявляющую, что это класс конфигурации, но в это время не размещайте его в пакете, сканируемом @ComponentScan в основном контексте приложения, иначе конфигурация будет расшарена всеми клиентами Feign (это эквивалентно тому, чтобы стать общей конфигурацией, на самом деле, суть проблемы, вызванной перекрытием пакетов сканирования родительского и дочернего контекста Spring), мелкозернистая конфигурация не может быть достигнута!
  • личное предложение:Как и я, не добавляйте аннотацию @Configuration, чтобы не попасть в яму.
  • Лучшие практики:Попробуйте настроить конфигурацию Feign с помощью свойств конфигурации! ! !

Атрибут аннотации @FeignClient

//@FeignClient(name = "microservice-provider-user")
//在早期的Spring Cloud版本中，无需提供name属性，从Brixton版开始，@FeignClient必须提供name属性，否则应用将无法正常启动！
//另外，name、url等属性支持占位符。例如：
@FeignClient(name = "${feign.name}", url = "${feign.url}")

@RequestMapping на уровне класса будет загружен Spring MVC

@RequestMapping("/users")
@FeignClient(name = "microservice-user")
public class TestFeignClient {
    // ...
}

класс@RequestMappingАннотации также загружаются Spring MVC. Теперь эта проблема решена, и в более ранних версиях было два решения:план 1:Не добавляйте аннотацию @RequestMapping к классу;Сценарий 2:Добавьте следующий код:

@Configuration
@ConditionalOnClass({ Feign.class })
public class FeignMappingDefaultConfiguration {
    @Bean
    public WebMvcRegistrations feignWebRegistrations() {
        return new WebMvcRegistrationsAdapter() {
            @Override
            public RequestMappingHandlerMapping getRequestMappingHandlerMapping() {
                return new FeignFilterRequestMappingHandlerMapping();
            }
        };
    }

    private static class FeignFilterRequestMappingHandlerMapping extends RequestMappingHandlerMapping {
        @Override
        protected boolean isHandler(Class<?> beanType) {
            return super.isHandler(beanType) && !beanType.isInterface();
        }
    }
}

первый запрос не удалсяРежим активной загрузки ленты

Для создания информации мониторинга Hystrix Stream требуются некоторые дополнительные операции.Сам Feign интегрировал Hystrix и может использоваться напрямую@FeignClient(value = "microservice-provider-user", fallback = XXX.class)Чтобы указать резервный класс, резервный класс наследует@FeignClientОтмеченный интерфейс можно использовать.

Но если вы хотите использовать Hystrix Stream для мониторинга, по умолчанию доступ к http://IP:PORT/actuator/hystrix.stream вернет 404, потому что Feign интегрирует Hystrix, но не интегрирует мониторинг Hystrix. Как добавить поддержку мониторинга? Требуются следующие шаги:

Шаг 1: Добавьте зависимости, например:

<!-- 整合hystrix，其实feign中自带了hystrix，引入该依赖主要是为了使用其中的hystrix-metrics-event-stream，用于dashboard -->
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>

Шаг 2: Добавьте аннотацию @EnableCircuitBreaker в класс запуска, например:

@SpringBootApplication
@EnableFeignClients
@EnableDiscoveryClient
@EnableCircuitBreaker
public class MovieFeignHystrixApplication {
  public static void main(String[] args) {
    SpringApplication.run(MovieFeignHystrixApplication.class, args);
  }
}

Шаг 3: Добавьте следующее в application.yml, чтобы открыть конечную точку hystrix.stream:

management:
  endpoints:
    web:
      exposure:
        include: 'hystrix.stream'

Таким образом, после доступа к API любого интерфейса Feign Client, а затем доступа к http://IP:PORT/actuator/hystrix.stream будет отображаться множество данных мониторинга Hystrix.

Исходная ссылка: http://www.itmuch.com/spring-cloud-sum/feign-problems/

Загрузить файл

добавить зависимость

<dependency>
    <groupId>io.github.openfeign.form</groupId>
    <artifactId>feign-form</artifactId>
    <version>3.0.3</version>
</dependency>
<dependency>
    <groupId>io.github.openfeign.form</groupId>
    <artifactId>feign-form-spring</artifactId>
    <version>3.0.3</version>
</dependency>

Написать фиктивный клиент

@FeignClient(name = "ms-content-sample", configuration = UploadFeignClient.MultipartSupportConfig.class)
public interface UploadFeignClient {
    @RequestMapping(value = "/upload", method = RequestMethod.POST,
            produces = {MediaType.APPLICATION_JSON_UTF8_VALUE},
            consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
    @ResponseBody
    String handleFileUpload(@RequestPart(value = "file") MultipartFile file);

    class MultipartSupportConfig {
        @Bean
        public Encoder feignFormEncoder() {
            return new SpringFormEncoder();
        }
    }
}

Как показано в коде, в этом клиенте Feign мы ссылаемся на класс конфигурацииMultipartSupportConfig,существуетMultipartSupportConfig, мы создаем экземплярSpringFormEncoder. Таким образом, клиент Feign может быть загружен.

будь осторожен

//RequestMapping注解中的produeces 、consumes 不能少；
@RequestMapping(value = "/upload", method = RequestMethod.POST,
            produces = {MediaType.APPLICATION_JSON_UTF8_VALUE},
            consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
  • Аннотации в определениях интерфейса@RequestPart(value = "file")нельзя записать как@RequestParam(value = "file"）.
  • Время ожидания Hystrix лучше установить больше, например, 5 секунд, иначе Hystrix может истечь до того, как файл будет загружен, что приведет к ошибке на стороне клиента.

Исходная ссылка: http://www.itmuch.com/spring-cloud-sum/spring-cloud-feign-upload/

Feign реализует отправку формы Form

Добавьте зависимости:

<dependency>
  <groupId>io.github.openfeign.form</groupId>
  <artifactId>feign-form</artifactId>
  <version>3.2.2</version>
</dependency>
<dependency>
  <groupId>io.github.openfeign.form</groupId>
  <artifactId>feign-form-spring</artifactId>
  <version>3.2.2</version>
</dependency>

Пример ложного клиента:

@FeignClient(name = "xxx", url = "http://www.itmuch.com/", configuration = TestFeignClient.FormSupportConfig.class)
public interface TestFeignClient {
    @PostMapping(value = "/test",
            consumes = {MediaType.APPLICATION_FORM_URLENCODED_VALUE},
            produces = {MediaType.APPLICATION_JSON_UTF8_VALUE}
            )
    void post(Map<String, ?> queryParam);

    class FormSupportConfig {
        @Autowired
        private ObjectFactory<HttpMessageConverters> messageConverters;
        // new一个form编码器，实现支持form表单提交
        @Bean
        public Encoder feignFormEncoder() {
            return new SpringFormEncoder(new SpringEncoder(messageConverters));
        }
        // 开启Feign的日志
        @Bean
        public Logger.Level logger() {
            return Logger.Level.FULL;
        }
    }
}

Пример вызова:

@GetMapping("/user/{id}")
public User findById(@PathVariable Long id) {
  HashMap<String, String> param = Maps.newHashMap();
  param.put("username","zhangsan");
  param.put("password","pwd");
  this.testFeignClient.post(param);
  return new User();
}

бревно:

...[TestFeignClient#post] ---> POST http://www.baidu.com/test HTTP/1.1
...[TestFeignClient#post] Accept: application/json;charset=UTF-8
...[TestFeignClient#post] Content-Type: application/x-www-form-urlencoded; charset=UTF-8
...[TestFeignClient#post] Content-Length: 30
...[TestFeignClient#post] 
...[TestFeignClient#post] password=pwd&username=zhangsan
...[TestFeignClient#post] ---> END HTTP (30-byte body)

Из журнала видно, что в это время Feign смог отправить данные с помощью формы формы.

Исходная ссылка: http://www.itmuch.com/spring-cloud-sum/feign-form-params/

Как создать несколько параметров в запросе Feign GET

Предположим, запрошенный URL-адрес содержит несколько параметров, таких как http://microservice-provider-user/get?id=1&username=Zhang San, как использовать конструкцию Feign? Мы знаем, что Spring Cloud добавляет в Feign поддержку аннотаций Spring MVC, поэтому мы могли бы также попробовать это в соответствии со Spring MVC:

@FeignClient("microservice-provider-user")
public interface UserFeignClient {
  @RequestMapping(value = "/get", method = RequestMethod.GET)
  public User get0(User user);
}

Однако такой способ написания неверен, и консоль выдаст исключение, подобное следующему.

feign.FeignException: status 405 reading UserFeignClient#get0(User); content:
{"timestamp":1482676142940,"status":405,"error":"Method Not Allowed","exception":"org.springframework.web.HttpRequestMethodNotSupportedException","message":"Request method 'POST' not supported","path":"/get"}

Как видно из исключения, хотя мы указали метод GET, Feign все равно будет использовать метод POST для отправки запроса. Отсюда исключение. Правильное написание выглядит следующим образом

Способ 1 [рекомендуется]Примечание. С этим методом нельзя использовать режим наследования Fegin.

@FeignClient("microservice-provider-user")
public interface UserFeignClient {
  @GetMapping("/get")
  public User get0(@SpringQueryMap User user);
}

Способ 2 [рекомендуется]

@FeignClient(name = "microservice-provider-user")
public interface UserFeignClient {
  @RequestMapping(value = "/get", method = RequestMethod.GET)
  public User get1(@RequestParam("id") Long id, @RequestParam("username") String username);
}

Это наиболее интуитивно понятный способ, URL имеет несколько параметров, и метод в интерфейсе Feign также имеет несколько параметров. Используйте аннотацию @RequestParam, чтобы указать параметры запроса.

Способ третий [не рекомендуется]URL-адреса с несколькими параметрами также можно создавать с помощью Карт. Когда у целевого URL много параметров, этот метод можно использовать для упрощения написания интерфейса Feign.

@FeignClient(name = "microservice-provider-user")
public interface UserFeignClient {
  @RequestMapping(value = "/get", method = RequestMethod.GET)
  public User get2(@RequestParam Map<String, Object> map);
}

При вызове может использоваться код, подобный следующему.

public User get(String username, String password) {
  HashMap<String, Object> map = Maps.newHashMap();
  map.put("id", "1");
  map.put("username", "张三");
  return this.userFeignClient.get2(map);
}

Уведомление:Этот метод не рекомендуется. В основном потому, что читаемость не очень хорошая, и есть некоторые проблемы, если параметр пуст, например.map.put("username", null);Заставляет вызывающую службу (потребительскую службу) получать имя пользователя "" вместо null.

Исходная ссылка: http://www.itmuch.com/spring-cloud-sum/feign-multiple-params-2/

Переключитесь на Okhttp3, чтобы улучшить оптимизацию производительности QPS.

Добавьте зависимости и введите okhttp3

<dependency>
    <groupId>io.github.openfeign</groupId>
    <artifactId>feign-okhttp</artifactId>
    <version>${version}</version>
</dependency>

записать конфигурацию

feign:
  # feign启用hystrix，才能熔断、降级
  # hystrix:
  # enabled: true
  # 启用 okhttp 关闭默认 httpclient
  httpclient:
    enabled: false #关闭httpclient
    # 配置连接池
    max-connections: 200 #feign的最大连接数
    max-connections-per-route: 50 #fegin单个路径的最大连接数
  okhttp:
    enabled: true
  # 请求与响应的压缩以提高通信效率
  compression:
    request:
      enabled: true
      min-request-size: 2048
      mime-types: text/xml,application/xml,application/json
    response:
      enabled: true

конфигурация параметров

/**
 * 配置 okhttp 与连接池
 * ConnectionPool 默认创建5个线程，保持5分钟长连接
 */
@Configuration
@ConditionalOnClass(Feign.class)
@AutoConfigureBefore(FeignAutoConfiguration.class) //SpringBoot自动配置
public class OkHttpConfig {

    // 默认老外留给你彩蛋中文乱码，加上它就 OK
    @Bean
    public Encoder encoder() {
        return new FormEncoder();
    }

    @Bean
    public okhttp3.OkHttpClient okHttpClient() {
        return new okhttp3.OkHttpClient.Builder()
                //设置连接超时
                .connectTimeout(10, TimeUnit.SECONDS)
                //设置读超时
                .readTimeout(10, TimeUnit.SECONDS)
                //设置写超时
                .writeTimeout(10, TimeUnit.SECONDS)
                //是否自动重连
                .retryOnConnectionFailure(true)
                .connectionPool(new ConnectionPool(10, 5L, TimeUnit.MINUTES))
                .build();
    }
}

Оригинальная ссылка: https://mp.weixin.qq.com/s/PAjXS9d6Sxa04pw1Lw2HXQ

Личный блог Чжао Сяопана

Категории