spring cloud feign实现远程调用服务传输文件的方法
实践案例包括两个项目,服务提供者项目名:upload-service,调用服务项目名:upload-client,主要给出两个服务之间的调用过程,文件上传功能不提供
项目框架:spring-boot2.0.1.RELEASE、spring-cloudFinchley.RELEASE
依赖:
io.github.openfeign.form feign-form 3.0.3 io.github.openfeign.form feign-form-spring 3.0.3 commons-fileupload commons-fileupload 1.3.3
创建FeignClient接口(用于指定远程调用的服务)
//申明这是一个Feign客户端,并且指明服务id @FeignClient(value="com-spring-caclulate") publicinterfaceCacluFeignClient{ //这里定义了类似于SpringMVC用法的方法,就可以进行RESTful的调用了 @RequestMapping(value="/caclu/{num}",method=RequestMethod.GET) publicItemcaclulate(@PathVariable("num")Integernum); }
一.文件上传服务upload-service
1.控制层
@Slf4j @CrossOrigin @RestController @RequestMapping("/ftp") @Api(description="文件上传控制") publicclassFtpFileController{ @Autowired privateFtpFileServiceftpFileService; /** *FTP文件上传 * *@return */ @PostMapping(value="/uploadFile",consumes=MediaType.MULTIPART_FORM_DATA_VALUE) publicFtpApiResponseuploadFileFTP(@RequestPart(value="file")MultipartFilefile, @RequestParam("logId")StringlogId){ FtpApiResponse result=newFtpApiResponse<>(); LogUtil.updateLogId(logId); try{ log.info("文件上传开始!}"); LongstartTime=System.currentTimeMillis(); FtpUploadResDTOresDTO=ftpFileService.uploadFile(file); result.setData(resDTO); result.setSuccess(true); result.setTimeInMillis(System.currentTimeMillis()-startTime); log.info("文件上传结束resDTO:{},耗时:{}",resDTO,(System.currentTimeMillis()-startTime)); }catch(ServiceExceptione){ result.setSuccess(false); result.setErrorCode(ErrorMsgEnum.FILE_UPLOAD_EXCEPTION.getCode()); result.setErrorMsg(ErrorMsgEnum.FILE_UPLOAD_EXCEPTION.getMsg()); }catch(Exceptione){ result.setSuccess(false); result.setErrorCode(ErrorMsgEnum.SYSTEM_ERROR.getCode()); result.setErrorMsg(ErrorMsgEnum.SYSTEM_ERROR.getMsg()); log.info("文件上传失败Exception:{}",Throwables.getStackTraceAsString(e)); } returnresult; } }
2.业务层
@Service @Slf4j publicclassFtpFileService{ @Autowired privateFtpFileManagerftpFileManager; /** *上传文件 * *@paramfile *@return */ publicFtpUploadResDTOuploadFile(MultipartFilefile){ try{ //判断上传文件是否为空 if(null==file||file.isEmpty()||file.getSize()==0){ log.info("传入的文件为空,file:{}",file); thrownewServiceException(ErrorMsgEnum.EMPTY_FILE); } //文件上传至ftp服务目录 FtpFileRecordDOftpFileRecordDO=ftpFileManager.fileUploadToFtp(file); if(null==ftpFileRecordDO){ log.info("文件上传至ftp服务目录异常"); thrownewServiceException(ErrorMsgEnum.FILE_UPLOAD_TO_FTP_EXCEPTION); } returnftpFileManager.addFileRecord(ftpFileRecordDO); }catch(Exceptione){ log.error("业务异常,case",e); thrownewServiceException(ErrorMsgEnum.SYSTEM_ERROR); } } }
3.服务写好后,需要把远程接口暴露出去
@FeignClient(value="upload-service",configuration=UpDownFtpFacade.MultipartSupportConfig.class) publicinterfaceUpDownFtpFacade{ /** *FTP上传文件 * *@paramfile文件 *@paramlogId日志id *@return */ @PostMapping(value="/ftp/uploadFile",consumes=MediaType.MULTIPART_FORM_DATA_VALUE) FtpApiResponseuploadFileFTP(@RequestPart(value="file")MultipartFilefile, @RequestParam("logId")StringlogId); /** *引用配置类MultipartSupportConfig.并且实例化 */ @Configuration classMultipartSupportConfig{ @Bean publicEncoderfeignFormEncoder(){ returnnewSpringFormEncoder(); } } }
二.文件上传客户端upload-client
@Slf4j @Component publicclassFileManager{ @Autowired privateUpDownFtpFacadeupDownFtpFacade; /** *调用远程上传文件接口 * *@paramfile待上传的文件 *@return下载路径 **/ publicFtpApiResponserequestFtpFacade(MultipartFilefile){ try{ DiskFileItemfileItem=(DiskFileItem)newDiskFileItemFactory().createItem("file", MediaType.ALL_VALUE,true,file.getOriginalFilename()); InputStreaminput=file.getInputStream(); OutputStreamos=fileItem.getOutputStream(); IOUtils.copy(input,os); MultipartFilemulti=newCommonsMultipartFile(fileItem); FtpApiResponse response=upDownFtpFacade.uploadFileFTP(multi,LogUtil.getLogId()); if(null==response||!response.getSuccess()||null==response.getData()){ thrownewManagerException(ErrorMsgEnum.FIlE_UPLOAD_FAILED); } returnresponse; }catch(Exceptione){ thrownewManagerException(ErrorMsgEnum.FIlE_UPLOAD_FAILED); } } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。