Feign传递文件以及MultipartFile对象

Feign微服务调用传递文件以及MultipartFile多媒体参数对象

上游服务提供者

• 使用spring接收文件可以使用MultipartFile对象，并同时使用RequestPart注解标识这个一个多媒体参数。
• 也就是request的content-Type=multipart/form-data
• 文件上传provider代码：

@PostMapping("/form")publicStringformData(@RequestPart("file")MultipartFile multipartFile){
    multipartFile.getBytes();}

• 同时你可以可以还接收其他参数，例如：
• 或者这种形式

测试服务提供者

• 首先要保证服务提供者能够正常接收多媒体MultipartFile文件参数以及其他的参数。我这里使用postman测试，直接看图：
• 使用multipart/form-data的content-Type,并且传递一个文件参数，一个字符串参数。
• 可以看到文件和字符串参数都是有值了，也就是服务提供者是可以调通的。

下游消费者

• 消费者直接通过Feign去调用文件上传接口。
• 在另外一个项目中定义了一个FeignClient，并在consumer中直接通过Feign去调用
• 结果就是抛出异常

com.fasterxml.jackson.databind.exc.InvalidDefinitionException:No serializer found forclassjava.io.ByteArrayInputStream and no properties discovered tocreateBeanSerializer(toavoid exception, disable SerializationFeature.FAIL_ON_EMPTY_BEANS)(through reference chain:java.util.LinkedHashMap["file"]->org.springframework.mock.web.MockMultipartFile["inputStream"])
    at com.fasterxml.jackson.databind.exc.InvalidDefinitionException.from(InvalidDefinitionException.java:77)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.SerializerProvider.reportBadDefinition(SerializerProvider.java:1276)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.DatabindContext.reportBadDefinition(DatabindContext.java:400)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ser.impl.UnknownSerializer.failForEmpty(UnknownSerializer.java:71)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ser.impl.UnknownSerializer.serialize(UnknownSerializer.java:33)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ser.BeanPropertyWriter.serializeAsField(BeanPropertyWriter.java:728)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ser.std.BeanSerializerBase.serializeFields(BeanSerializerBase.java:770)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ser.BeanSerializer.serialize(BeanSerializer.java:178)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ser.std.MapSerializer.serializeFields(MapSerializer.java:808)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ser.std.MapSerializer.serializeWithoutTypeInfo(MapSerializer.java:764)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ser.std.MapSerializer.serialize(MapSerializer.java:720)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ser.std.MapSerializer.serialize(MapSerializer.java:35)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ser.DefaultSerializerProvider._serialize(DefaultSerializerProvider.java:480)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ser.DefaultSerializerProvider.serializeValue(DefaultSerializerProvider.java:400)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ObjectWriter$Prefetch.serialize(ObjectWriter.java:1510)~[jackson-databind-2.12.5.jar:2.12.5]
    at com.fasterxml.jackson.databind.ObjectWriter.writeValue(ObjectWriter.java:1006)~[jackson-databind-2.12.5.jar:2.12.5]
    at org.springframework.http.converter.json.AbstractJackson2HttpMessageConverter.writeInternal(AbstractJackson2HttpMessageConverter.java:454)~[spring-web-5.3.12.jar:5.3.12]
    at org.springframework.http.converter.AbstractGenericHttpMessageConverter.write(AbstractGenericHttpMessageConverter.java:104)~[spring-web-5.3.12.jar:5.3.12]
    at org.springframework.cloud.openfeign.support.SpringEncoder.checkAndWrite(SpringEncoder.java:195)~[spring-cloud-openfeign-core-3.0.4.jar:3.0.4]
    at org.springframework.cloud.openfeign.support.SpringEncoder.encodeWithMessageConverter(SpringEncoder.java:124)~[spring-cloud-openfeign-core-3.0.4.jar:3.0.4]
    at org.springframework.cloud.openfeign.support.SpringEncoder.encode(SpringEncoder.java:114)~[spring-cloud-openfeign-core-3.0.4.jar:3.0.4]
    at feign.ReflectiveFeign$BuildFormEncodedTemplateFromArgs.resolve(ReflectiveFeign.java:358)~[feign-core-10.12.jar:na]
    at feign.ReflectiveFeign$BuildTemplateByResolvingArgs.create(ReflectiveFeign.java:232)~[feign-core-10.12.jar:na]
    at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:84)~[feign-core-10.12.jar:na]
    at feign.ReflectiveFeign$FeignInvocationHandler.invoke(ReflectiveFeign.java:100)~[feign-core-10.12.jar:na]
    at com.sun.proxy.$Proxy85.formData(UnknownSource)~[na:na]
    at com.maple.cloud10feignconsumer.controller.ConsumerController.form(ConsumerController.java:59)~[classes/:na]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(NativeMethod)~[na:1.8.0_131]
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)~[na:1.8.0_131]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)~[na:1.8.0_131]
    at java.lang.reflect.Method.invoke(Method.java:498)~[na:1.8.0_131]
    at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205)~[spring-web-5.3.12.jar:5.3.12]
    at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150)~[spring-web-5.3.12.jar:5.3.12]
    at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:117)~[spring-webmvc-5.3.12.jar:5.3.12]
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895)~[spring-webmvc-5.3.12.jar:5.3.12]
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808)~[spring-webmvc-5.3.12.jar:5.3.12]
    at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)~[spring-webmvc-5.3.12.jar:5.3.12]
    at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1067)~[spring-webmvc-5.3.12.jar:5.3.12]
    at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:963)~[spring-webmvc-5.3.12.jar:5.3.12]
    at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006)~[spring-webmvc-5.3.12.jar:5.3.12]
    at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898)~[spring-webmvc-5.3.12.jar:5.3.12]
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:655)~[tomcat-embed-core-9.0.54.jar:4.0.FR]
    at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883)~[spring-webmvc-5.3.12.jar:5.3.12]
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:764)~[tomcat-embed-core-9.0.54.jar:4.0.FR]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:227)~[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)~[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)~[tomcat-embed-websocket-9.0.54.jar:9.0.54]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)~[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)~[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)~[spring-web-5.3.12.jar:5.3.12]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)~[spring-web-5.3.12.jar:5.3.12]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)~[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)~[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)~[spring-web-5.3.12.jar:5.3.12]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)~[spring-web-5.3.12.jar:5.3.12]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)~[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)~[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)~[spring-web-5.3.12.jar:5.3.12]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)~[spring-web-5.3.12.jar:5.3.12]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)~[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)~[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:197)~[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.core.StandardContextValve.__invoke(StandardContextValve.java:97)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:41002)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:540)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:135)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:78)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:357)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:382)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:895)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1722)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1191)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)[tomcat-embed-core-9.0.54.jar:9.0.54]
    at java.lang.Thread.run(Thread.java:748)[na:1.8.0_131]

• 看这个异常信息可能看不出什么，其实就是因为Feign在构建请求报文的时候，content-type不对导致的。图片说的很清楚了，建议认真看。

异常原因

• 也就是是说，Feign在调用时，没有给content-type导致报错，而且这个报错是在下游服务构建报文时，是没有请求到上游服务的。
• 那么解决方案也就是往RequestTemplate的header中设置content-type=multipart/form-data就好了。

错误解决方案

1. header中既然没有content-type，那就设置一个进去不就好了，但是很遗憾，RequestTemplate是一个具体的类，而不是一个接口，没有提供很好的扩展进制。
2. 你可能想到了RequestInterceptor,请求拦截器，feign在调用其他服务之前会先走拦截器。在拦截器中添加content-type不就好了。
3. 但是很遗憾，RequestTemplate的body报文组装编码是在拦截器之前，话不说说，看代码。

通过Feign调用接口，来到jdk动态代理的invoke方法，拿到分发器，执行invoke逻辑。

invoke方法：构建ReuqestTemplate以及请求报文，执行并解密，执行请求拦截器。

• 可以很清晰的看到，是先构建了ReuqestTemplate的请求报文，然后在执行的拦截器；正常流程在构建请求报文编码就报错了。

可行的解决方案

• 需要重新思考一个添加content-type的可行时机。
• 可以看到，Feign在执行解析编码的时候，是通过SpringEncoder去编码，获取content-type的。那我们就可以自己去创建一个Encoder去替换容器中的SpringEncoder,然后在编码之前，往RequestTemplate的header中添加content-type，或者重写encode的逻辑。
• 接下来就是要看这个SpringEncoder是从哪里来的。

寻找SpringEncoder来源

• SpringEncoder的获取是在容器启动时创建的，核心代码如下
• 也就是在Ioc容器中获取，那么现在要做的，就是找到他是何时加入到容器的。
• 通过调用栈可以发现SpringEncoder是通过配置类的@Bean，调用其他方法创建的。那我们就可以覆盖这个SpringEncoder，注册自己的Encoder对象。

注册自定义Encoder

• 直接模拟spring的创建方式即可。

packagecom.maple.cloud10feignconsumer.config;importfeign.codec.Encoder;importfeign.form.spring.SpringFormEncoder;importorg.springframework.beans.factory.ObjectFactory;importorg.springframework.beans.factory.ObjectProvider;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;importorg.springframework.boot.autoconfigure.condition.ConditionalOnMissingClass;importorg.springframework.boot.autoconfigure.http.HttpMessageConverters;importorg.springframework.cloud.openfeign.support.AbstractFormWriter;importorg.springframework.cloud.openfeign.support.FeignEncoderProperties;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;/**
 * @author maple
 * @date 2022/12/29 16:08
 * desc:
 */@ConfigurationpublicclassEncoderConfiguration{@Autowired(required =false)privateFeignEncoderProperties encoderProperties;@AutowiredprivateObjectFactory<HttpMessageConverters> messageConverters;@Bean@ConditionalOnMissingBean@ConditionalOnMissingClass("org.springframework.data.domain.Pageable")publicEncoderfeignEncoder(ObjectProvider<AbstractFormWriter> formWriterProvider){returnmapleEncoder(formWriterProvider, encoderProperties);}privateEncodermapleEncoder(ObjectProvider<AbstractFormWriter> formWriterProvider,FeignEncoderProperties encoderProperties){returnnewMapleEncoder(newSpringFormEncoder(),this.messageConverters, encoderProperties);}}

编写自定义Encoder

• encode的逻辑也就是在调用SpringEncoder之前，往RequestTemplate中添加content-type。那么什么时候能够添加content-type，就是我们需要思考的问题，因为我们不能影响其他的FeignClient使用。
• 我的方案是使用自定义注解，标识这是一个多媒体文件上传接口，需要添加content-type，然后在下游FeignClient中标记，并在自定义的Encoder中扫描。

自定义文件上传接口标识注解

packagecom.maple.cloud10feignconsumer.config;importjava.lang.annotation.*;/**
 * @author maple
 * @date 2022/12/29 16:37
 * desc:
 */@Target(ElementType.METHOD)@Retention(RetentionPolicy.RUNTIME)@Documentedpublic@interfaceFormData{}

• 并在FeignClient中标记

编写encode逻辑

• 并在encode中扫描

packagecom.maple.cloud10feignconsumer.config;importfeign.RequestTemplate;importfeign.codec.EncodeException;importfeign.form.spring.SpringFormEncoder;importorg.springframework.beans.factory.ObjectFactory;importorg.springframework.boot.autoconfigure.http.HttpMessageConverters;importorg.springframework.cloud.openfeign.support.FeignEncoderProperties;importorg.springframework.cloud.openfeign.support.SpringEncoder;importjava.lang.reflect.Type;/**
 * @author maple
 * @date 2022/12/29 15:56
 * desc:
 */publicclassMapleEncoderextendsSpringEncoder{publicMapleEncoder(ObjectFactory<HttpMessageConverters> messageConverters){super(messageConverters);}publicMapleEncoder(SpringFormEncoder springFormEncoder,ObjectFactory<HttpMessageConverters> messageConverters){super(springFormEncoder, messageConverters);}publicMapleEncoder(SpringFormEncoder springFormEncoder,ObjectFactory<HttpMessageConverters> messageConverters,FeignEncoderProperties encoderProperties){super(springFormEncoder, messageConverters, encoderProperties);}@Overridepublicvoidencode(Object requestBody,Type bodyType,RequestTemplate request)throwsEncodeException{// 是表单请求,则添加header【content-type=multipart/form-data】if(request.methodMetadata().method().isAnnotationPresent(FormData.class)){
            request.header("content-type","multipart/form-data");}// 执行SpringEncoder的逻辑super.encode(requestBody, bodyType, request);}}

测试

• 可以看到，现在解析编码就是我自定义的Encoder。
• 然后如果是文件上传请求，就会在header中添加content-type。
• 然后也就能够成功的调用到上游服务了，并且获取数据。

总结

1. 通过Feign直接去调用上游的文件上传服务，会报错，原因是因为RequestTemplate的header中没有content-type，会导致错误的编码请求报文。
2. 通过自定义Encoder继承SpringEncoder并重写encode方法，在编码之前添加content-type。
3. 并不是所有的Feign调用都需要自己添加conent-type,所有需要标记一下接口，例如自定义注解。