快捷導(dǎo)航

Feign實(shí)現(xiàn)多文件上傳,Open?Feign多文件上傳問(wèn)題及解決

更新時(shí)間：2022年11月23日 10:16:07 作者：By子諾

這篇文章主要介紹了Feign實(shí)現(xiàn)多文件上傳，Open?Feign多文件上傳問(wèn)題及解決，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

Feign實(shí)現(xiàn)多文件上傳，Open Feign多文件上傳解決

廢話不多說(shuō)，直接上代碼

用feign多文件上傳的Controller代碼如下

@Slf4j
@RestController
@RequestMapping("/store")
@Api(description = "店鋪管理接口", tags = "店鋪管理接口")
public class StoreController {
    @Autowired
    private StoreService storeService;
    
    @ApiOperation(value = "新增店鋪信息")
    @PostMapping(value = "/addStoreInfo")
    public Result<Store> addStoreInfo(@Valid @ApiParam(value = "添加店鋪時(shí)的店鋪") StoreDto storeDto, MultipartFile[] multipartFiles) {
        return storeService.addStoreInfo(storeDto,multipartFiles);
    }
}

FeignClient代碼如下

/**
 * FileName: FileService
 * Author:   SixJR.
 * Date:     2022/3/2 18:38:56
 * Description: 文件RPC服務(wù)接口
 * History:
 * <author>          <time>          <version>          <desc>
 */
@FeignClient(name = FeignServiceNameConstants.FILE_SERVICE, fallbackFactory = FileServiceFallbackFactory.class, decode404 = true)
public interface FileService {

    @PostMapping(value = "/enclosure/upload/{objectName}/{objectId}", produces = {MediaType.APPLICATION_JSON_UTF8_VALUE}, consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
    Result upload(@PathVariable("objectName")String objectName, @PathVariable("objectId")String objectId,@RequestPart("multipartFiles") MultipartFile[] multipartFiles);

}

Feign調(diào)用服務(wù)，傳送類似MultipartFile[] multipartFiles多文件的時(shí)候

會(huì)出現(xiàn)如下錯(cuò)誤

Could not write request: no suitable HttpMessageConverter found for request type [[Lorg.springframework.web.multipart.MultipartFile;] and content type [multipart/form-data]"

錯(cuò)誤是因?yàn)镕eign在組裝MultipartFile[] multipartFiles多文件的時(shí)候出現(xiàn)了問(wèn)題

解決這個(gè)問(wèn)題可以重寫(xiě)SpringFormEncoder這個(gè)類

重寫(xiě)后的代碼如下：

import feign.form.ContentType;
import feign.form.MultipartFormContentProcessor;
import feign.form.spring.SpringFormEncoder;
import feign.RequestTemplate;
import feign.codec.EncodeException;
import feign.codec.Encoder;
import feign.form.spring.SpringManyMultipartFilesWriter;
import feign.form.spring.SpringSingleMultipartFileWriter;
import org.springframework.web.multipart.MultipartFile;

import java.lang.reflect.Type;
import java.util.Collections;
import java.util.Map;

/**
 * FileName: SpringMultipartEncoder
 * Author:   SixJR.
 * Date:     2022/3/2 19:54:12
 * Description: Feign實(shí)現(xiàn)多文件上傳，重寫(xiě)SpringFormEncoder
 * History:
 * <author>          <time>          <version>          <desc>
 */
public class SpringMultipartEncoder extends SpringFormEncoder {
    public SpringMultipartEncoder(Encoder delegate) {
        super(delegate);
        MultipartFormContentProcessor processor = (MultipartFormContentProcessor) getContentProcessor(ContentType.MULTIPART);
        processor.addWriter(new SpringSingleMultipartFileWriter());
        processor.addWriter(new SpringManyMultipartFilesWriter());
    }

    @Override
    public void encode(Object object, Type bodyType, RequestTemplate template) throws EncodeException {
        if (bodyType != null && bodyType.equals(MultipartFile[].class)) {
            MultipartFile[] file = (MultipartFile[]) object;
            if(file != null) {
                Map data = Collections.singletonMap(file.length == 0 ? "" : file[0].getName(), object);
                super.encode(data, MAP_STRING_WILDCARD, template);
                return;
            }
        }
        super.encode(object, bodyType, template);
    }
}

配置類如下

package com.chinared.common.config;

import com.chinared.common.utils.SpringMultipartEncoder;
import org.springframework.beans.factory.ObjectFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
import org.springframework.cloud.openfeign.support.SpringEncoder;
import org.springframework.context.annotation.Bean;
import feign.codec.Encoder;
import org.springframework.context.annotation.Configuration;

/**
 * FileName: MultipartSupportConfig
 * Author:   SixJR.
 * Date:     2022/3/2 19:56:43
 * Description: 解決Feign在組裝MultipartFile[]的時(shí)候出現(xiàn)的問(wèn)題
 * History:
 * <author>          <time>          <version>          <desc>
 */

@Configuration
public class MultipartSupportConfig {
    @Autowired
    private ObjectFactory<HttpMessageConverters> messageConverters;

    @Bean
    public Encoder feignFormEncoder() {
        return new SpringMultipartEncoder(new SpringEncoder(messageConverters));
    }
}

最后在FeignClient指定一下調(diào)用類就好啦~

package com.chinared.common.feign;

import com.chinared.common.config.MultipartSupportConfig;
import com.chinared.common.constant.FeignServiceNameConstants;
import com.chinared.common.feign.fallback.FileServiceFallbackFactory;
import com.chinared.common.model.Result;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

/**
 * FileName: FileService
 * Author:   SixJR.
 * Date:     2022/3/2 18:38:56
 * Description: 文件RPC服務(wù)接口
 * History:
 * <author>          <time>          <version>          <desc>
 */
@FeignClient(name = FeignServiceNameConstants.FILE_SERVICE, fallbackFactory = FileServiceFallbackFactory.class, decode404 = true,configuration = MultipartSupportConfig.class)
public interface FileService {

    @PostMapping(value = "/enclosure/upload/{objectName}/{objectId}", produces = {MediaType.APPLICATION_JSON_UTF8_VALUE}, consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
    Result upload(@PathVariable("objectName")String objectName, @PathVariable("objectId")String objectId,@RequestPart("multipartFiles") MultipartFile[] multipartFiles);

}