實踐案例包括兩個項目，服務提供者項目名：upload-service，調用服務項目名：upload-client，主要給出兩個服務之間的調用過程，文件上傳功能不提供
項目框架：spring-boot 2.0.1.release、spring-cloud finchley.release
依賴：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
<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><dependency> <groupid>commons-fileupload</groupid> <artifactid>commons-fileupload</artifactid> <version>1.3.3</version></dependency> |
|
1
2
3
4
5
6
7
8
9
|
// 申明這是一個feign客戶端，并且指明服務id@feignclient(value = "com-spring-caclulate") public interface caclufeignclient { // 這里定義了類似于springmvc用法的方法，就可以進行restful的調用了 @requestmapping(value = "/caclu/{num}", method = requestmethod.get) public item caclulate(@pathvariable("num") integer num);} |
一.文件上傳服務upload-service
1.控制層
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
@slf4j@crossorigin@restcontroller@requestmapping("/ftp")@api(description = "文件上傳控制")public class ftpfilecontroller { @autowired private ftpfileservice ftpfileservice; /** * ftp文件上傳 * * @return */ @postmapping(value = "/uploadfile", consumes = mediatype.multipart_form_data_value) public ftpapiresponse<ftpuploadresdto> uploadfileftp(@requestpart(value = "file") multipartfile file, @requestparam("logid") string logid) { ftpapiresponse<ftpuploadresdto> result = new ftpapiresponse<>(); logutil.updatelogid(logid); try { log.info("文件上傳開始!}"); long starttime = system.currenttimemillis(); ftpuploadresdto resdto = ftpfileservice.uploadfile(file); result.setdata(resdto); result.setsuccess(true); result.settimeinmillis(system.currenttimemillis() - starttime); log.info("文件上傳結束 resdto：{}，耗時:{}", resdto, (system.currenttimemillis() - starttime)); } catch (serviceexception e){ result.setsuccess(false); result.seterrorcode(errormsgenum.file_upload_exception.getcode()); result.seterrormsg(errormsgenum.file_upload_exception.getmsg()); } catch (exception e) { result.setsuccess(false); result.seterrorcode(errormsgenum.system_error.getcode()); result.seterrormsg(errormsgenum.system_error.getmsg()); log.info("文件上傳失敗 exception：{}", throwables.getstacktraceasstring(e)); } return result; }} |
2.業務層
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
@service@slf4jpublic class ftpfileservice { @autowired private ftpfilemanager ftpfilemanager; /** * 上傳文件 * * @param file * @return */ public ftpuploadresdto uploadfile(multipartfile file) { try { //判斷上傳文件是否為空 if (null == file || file.isempty() || file.getsize() == 0) { log.info("傳入的文件為空,file:{}", file); throw new serviceexception(errormsgenum.empty_file); } //文件上傳至ftp服務目錄 ftpfilerecorddo ftpfilerecorddo = ftpfilemanager.fileuploadtoftp(file); if (null == ftpfilerecorddo) { log.info("文件上傳至ftp服務目錄異常"); throw new serviceexception(errormsgenum.file_upload_to_ftp_exception); } return ftpfilemanager.addfilerecord(ftpfilerecorddo); } catch (exception e) { log.error("業務異常,case", e); throw new serviceexception(errormsgenum.system_error); } }} |
3.服務寫好后，需要把遠程接口暴露出去
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
@feignclient(value = "upload-service", configuration = updownftpfacade.multipartsupportconfig.class)public interface updownftpfacade { /** * ftp上傳文件 * * @param file 文件 * @param logid 日志id * @return */ @postmapping(value = "/ftp/uploadfile",consumes = mediatype.multipart_form_data_value) ftpapiresponse<ftpuploadresdto> uploadfileftp(@requestpart(value = "file") multipartfile file, @requestparam("logid") string logid); /** * 引用配置類multipartsupportconfig.并且實例化 */ @configuration class multipartsupportconfig { @bean public encoder feignformencoder() { return new springformencoder(); } }} |
二.文件上傳客戶端upload-client
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
@slf4j@componentpublic class filemanager { @autowired private updownftpfacade updownftpfacade; /** * 調用遠程上傳文件接口 * * @param file 待上傳的文件 * @return 下載路徑 **/ public ftpapiresponse<ftpuploadresdto> requestftpfacade(multipartfile file) { try { diskfileitem fileitem = (diskfileitem) new diskfileitemfactory().createitem("file", mediatype.all_value, true, file.getoriginalfilename()); inputstream input = file.getinputstream(); outputstream os = fileitem.getoutputstream(); ioutils.copy(input, os); multipartfile multi = new commonsmultipartfile(fileitem); ftpapiresponse<ftpuploadresdto> response = updownftpfacade.uploadfileftp(multi, logutil.getlogid()); if (null == response || !response.getsuccess() || null == response.getdata()) { throw new managerexception(errormsgenum.file_upload_failed); } return response; } catch (exception e) { throw new managerexception(errormsgenum.file_upload_failed); } }} |
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：https://segmentfault.com/a/1190000016234692
