一、配置文件解析器
服務提供者和消費者都需要配置文件解析器，這里使用 commons-fileupload 替換原有的解析器：
依賴：
|
1
2
3
4
5
|
<dependency> <groupid>commons-fileupload</groupid> <artifactid>commons-fileupload</artifactid> <version>1.3.1</version></dependency> |
注入 bean ：
|
1
2
3
4
5
6
|
@bean(name = "multipartresolver")public multipartresolver mutipartresolver(){ commonsmultipartresolver com = new commonsmultipartresolver(); com.setdefaultencoding("utf-8"); return com;} |
程序入口中剔除原有的解析器：
|
1
|
@springbootapplication(exclude = {multipartautoconfiguration.class}) |
二、服務提供者，即接收文件一方的配置
controller 的寫法：
|
1
2
3
4
5
6
7
8
9
10
11
|
@responsebody@requestmapping(value = "/upload", method = {requestmethod.post}, produces = {mediatype.application_json_utf8_value}, consumes = mediatype.multipart_form_data_value)public result<string> uploadfile(@requestpart("file")multipartfile file,@requestparam("id")long id){ string filename = file.getoriginalfilename(); string extend = fileoperateutil.suffix(filename); fileoperateutil.copy("e:\\" + filename, file); return resultbuilder.success("ok");} |
@requestpart 指定文件，后面的 @requestparam 是額外參數，注意額外參數不能超過url長度限制。
三、服務消費者配置
依賴：
|
1
2
3
4
5
6
7
8
9
10
|
<dependency> <groupid>io.github.openfeign.form</groupid> <artifactid>feign-form-spring</artifactid> <version>3.2.2</version></dependency><dependency> <groupid>io.github.openfeign.form</groupid> <artifactid>feign-form</artifactid> <version>3.2.2</version></dependency> |
文件編碼配置：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
import feign.codec.encoder;import feign.form.spring.springformencoder;import org.springframework.beans.factory.objectfactory;import org.springframework.beans.factory.annotation.autowired;import org.springframework.boot.autoconfigure.web.httpmessageconverters;import org.springframework.cloud.netflix.feign.support.springencoder;import org.springframework.context.annotation.bean;import org.springframework.context.annotation.configuration;@configurationpublic class multipartsupportconfig{ @autowired private objectfactory<httpmessageconverters> messageconverters; @bean public encoder feignformencoder(){ return new springformencoder(new springencoder(messageconverters)); }} |
feign 接口定義：
|
1
2
3
4
5
6
7
8
9
10
11
|
@feignclient(name = "test-upload")public interface uploadservice{ @responsebody @requestmapping(value = "/upload", method = {requestmethod.post}, produces = {mediatype.application_json_utf8_value}, consumes = mediatype.multipart_form_data_value) result<string>uploadfile(@requestpart("file")multipartfile file,@requestparam("id")long id);} |
與普通 feign 接口寫法差不多，注意方法注解和參數與服務提供者的 controller 一樣。
controller 的寫法， controller 中接收前端傳過來的文件信息和額外參數，然后通過 feign 接口傳輸到遠端：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
// 注入 feign 接口@autowiredprivate uploadservice uploadservice;@requestmapping(value = "/upload", method = requestmethod.post, produces = "application/json; charset=utf-8")@responsebodypublic result<string> testupload(httpservletrequest request, long id){ result<string> result = null; multiparthttpservletrequest mrequest = (multiparthttpservletrequest) request; map<string, multipartfile> filemap = mrequest.getfilemap(); for (multipartfile mfile : filemap.values()) { string filename = mfile.getoriginalfilename(); result = uploadservice.uploadfile(mfile, id); } return result;} |
四、總結
最后梳理一下流程，服務消費者接收前端（如瀏覽器）傳過來的文件，但是并不進行業務處理，然后通過 feign 調用接口，把文件傳給服務提供者，服務提供者拿到文件后，進行相應的業務處理。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：http://www.ciphermagic.cn/spring-cloud-feign-upload.html
