Spring|Spring Cloud中使用Feign,@RequestBody无法继承的解决方案 SpringCloud中使用Feign|@RequestBod

Spring Cloud中使用Feign,@RequestBody无法继承的问题

原因分析
解决方案

spring cloud 使用feign遇到的问题

1、示例
2、首次访问超时问题
3、FeignClient接口中,如果使用到@PathVariable,必须指定其value

Spring Cloud中使用Feign,@RequestBody无法继承的问题根据官网FeignClient的例子，编写一个简单的updateUser接口，定义如下

@RequestMapping("/user")public interface UserService {@RequestMapping(value = "https://www.it610.com/{userId}", method = RequestMethod.GET)UserDTO findUserById(@PathVariable("userId") Integer userId); @RequestMapping(value = "https://www.it610.com/update", method = RequestMethod.POST)boolean updateUser(@RequestBody UserDTO user); }

实现类

@Overridepublic boolean updateUser(UserDTO user){LOGGER.info("===updateUser, id = " + user.getId() + " ,name= " + user.getUsername()); return false; }

执行单元测试，发现没有获取到预期的输入参数

2018-09-07 15:35:38,558 [http-nio-8091-exec-5] INFO [com.springboot.user.controller.UserController] {} - ===updateUser, id = null ,name= null

原因分析
SpringMVC中使用RequestResponseBodyMethodProcessor类进行入参、出参的解析。以下方法根据参数是否有@RequestBody注解判断是否进行消息体的转换。

@Overridepublic boolean supportsParameter(MethodParameter parameter) {return parameter.hasParameterAnnotation(RequestBody.class); }

解决方案
既然MVC使用RequestResponseBodyMethodProcessor进行参数解析，可以实现一个定制化的Processor，修改supportParameter的判断方法。

@Overridepublic boolean supportsParameter(MethodParameter parameter){//springcloud的接口入参没有写@RequestBody，并且是自定义类型对象也按JSON解析if (AnnotatedElementUtils.hasAnnotation(parameter.getContainingClass(), FeignClient.class) && isCustomizedType(parameter.getParameterType())) {return true; }return super.supportsParameter(parameter); }

此处的判断逻辑可以根据实际框架进行定义，目的是判断到为Spring Cloud定义的接口，并且是自定义对象时，使用@RequestBody相同的内容转换器。
实现定制化的Processor后，还需要让自定义的配置生效，有两种方案可选：

直接替换RequestResponseBodyMethodProcessor，在SpringBoot下需要自定义RequestMappingHandlerAdapter。
实现WebMvcConfigurer中的addArgumentResolvers接口

这里采用较为简单的第二种方式，初始化时的消息转换器根据需要进行加载：

public class XXXWebMvcConfig implements WebMvcConfigurer{@Overridepublic void addArgumentResolvers(List resolvers){StringHttpMessageConverter stringHttpMessageConverter = new StringHttpMessageConverter(); stringHttpMessageConverter.setWriteAcceptCharset(false); List> messageConverters = new ArrayList<>(5); messageConverters.add(new ByteArrayHttpMessageConverter()); messageConverters.add(stringHttpMessageConverter); messageConverters.add(new SourceHttpMessageConverter<>()); messageConverters.add(new AllEncompassingFormHttpMessageConverter()); CustomizedMappingJackson2HttpMessageConverter jackson2HttpMessageConverter = new CustomizedMappingJackson2HttpMessageConverter(); jackson2HttpMessageConverter.setObjectMapper(defaultObjectMapper()); messageConverters.add(jackson2HttpMessageConverter); ViomiMvcRequestResponseBodyMethodProcessor resolver = new ViomiMvcRequestResponseBodyMethodProcessor(messageConverters); resolvers.add(resolver); }

修改完成后，微服务的实现类即可去掉@RequestBody注解。

spring cloud 使用feign遇到的问题 spring cloud 使用feign 项目的搭建在这里就不写了，本文主要讲解在使用过程中遇到的问题以及解决办法

1、示例

@RequestMapping(value = "https://www.it610.com/generate/password", method = RequestMethod.POST)KeyResponse generatePassword(@RequestBody String passwordSeed);

在这里只能使用 @RequestMapping(value = "https://www.it610.com/generate/password", method = RequestMethod.POST) 注解不能使用
@PostMapping 否则项目启动会报

Caused by: java.lang.IllegalStateException: Method generatePassword not annotated with HTTP method type (ex. GET, POST) 异常

2、首次访问超时问题
原因：Hystrix默认的超时时间是1秒，如果超过这个时间尚未响应，将会进入fallback代码。
而首次请求往往会比较慢（因为Spring的懒加载机制，要实例化一些类），这个响应时间可能就大于1秒了。
解决方法：
<1：配置Hystrix的超时时间改为5秒

hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 5000

<2：禁用Hystrix的超时时间

hystrix.command.default.execution.timeout.enabled: false

<3：禁用feign的hystrix 功能

feign.hystrix.enabled: false

注：个人推荐第一或者第二种方法

3、FeignClient接口中,如果使用到@PathVariable,必须指定其value
【Spring|Spring Cloud中使用Feign,@RequestBody无法继承的解决方案】spring cloud feign 使用 Apache HttpClient
问题：1 没有指定 Content-Type 是情况下会出现如下异常？这里很纳闷？

Caused by: java.lang.IllegalArgumentException: MIME type may not contain reserved characters

在这里有兴趣的朋友可以去研究下源码

ApacheHttpClient.class private ContentType getContentType(Request request) {ContentType contentType = ContentType.DEFAULT_TEXT; for (Map.Entry> entry : request.headers().entrySet())// 这里会判断如果没有指定 Content-Type 属性就使用上面默认的 text/plain; charset=ISO-8859-1// 问题出在默认的 contentType ：格式 text/plain; charset=ISO-8859-1 // 转到 ContentType.create(entry.getValue().iterator().next(), request.charset()); 方法中看if (entry.getKey().equalsIgnoreCase("Content-Type")) {Collection values = entry.getValue(); if (values != null && !values.isEmpty()) {contentType = ContentType.create(entry.getValue().iterator().next(), request.charset()); break; }}return contentType; }

ContentType.classpublic static ContentType create(final String mimeType, final Charset charset) {final String normalizedMimeType = Args.notBlank(mimeType, "MIME type").toLowerCase(Locale.ROOT); // 问题在这 check中 valid f方法中Args.check(valid(normalizedMimeType), "MIME type may not contain reserved characters"); return new ContentType(normalizedMimeType, charset); }private static boolean valid(final String s) {for (int i = 0; i < s.length(); i++) {final char ch = s.charAt(i); // 这里在上面 text/plain; charset=UTF-8 中出现了分号导致检验没有通过 if (ch == '"' || ch == ',' || ch == '; ') {return false; }}return true; }

解决办法：