SeaweedFS 分布式上传、下载、删除附件公共接口

这里就直接贴代码吧。

引用jar包：net.anumbrella.seaweedfs.core.FileTemplate;

一、SeaweedFS 上传附件接口

    @Autowiredprivate FileTemplate template;/*** @Description: 上传附件接口* @Date: 2019/12/19*/@PostMapping("/upload")@ApiOperation(value = "上传附件接口", notes = "上传附件，上传成功返回附件id")public RestResponse<FileHandleStatus> uploadFile(@RequestParam(name = "fileId",required = false) String fileId, @RequestParam("excelFile") MultipartFile file) throws IOException {try {if (file.isEmpty()) {return RestResponse.fail().setMsg("上传文件不能为空！");}if (!StringUtils.isEmpty(fileId)){return RestResponse.ok(template.updateFileByStream(fileId,file.getOriginalFilename(),file.getInputStream()));}ContentType contentType = ContentType.create("application/x-www-form-urlencoded", Consts.ISO_8859_1);return RestResponse.ok(template.saveFileByStream(file.getOriginalFilename(), file.getInputStream(),contentType));} catch (Exception e) {logger.error("上传附件失败", e);return RestResponse.fail().setMsg("上传附件服务连接关闭");}}

二、SeaweedFS 下载附件接口

    @Autowiredprivate FileTemplate template;    /*** @Description: 上传附件接口* @Date: 2019/12/19*/@GetMapping("/getFileInfo/{fileId}")@ApiOperation(value="公共下载附件接口",notes = "公共下载附件接口")@ApiImplicitParams(value = {@ApiImplicitParam(name = "fileId", value = "附件id", dataType = "String", required = true)})public RestResponse<SeaweedResponse> getFileInfo(@PathVariable String fileId) throws IOException {FileHandleStatus status = template.getFileStatus(fileId);String name = new String(status.getFileName().substring(8,status.getFileName().length()-1).getBytes("iso-8859-1"),"utf-8");SeaweedResponse response = new SeaweedResponse();if (status != null){response.setFileId(status.getFileId());response.setFileName(name);response.setFilePath(template.getFileUrl(fileId));}return RestResponse.ok(response);}

ps：

解决升级seaweed服务器，导致的获取附件名称时get （“Content-Disposition”）报 NullPointerException 的问题（完善）

/*** 获取附件的详情* @return*/@GetMapping("/getFileInfo/{fileId}")@ApiOperation(value="公共下载附件接口",notes = "下载附件接口")@ApiImplicitParams(value = {@ApiImplicitParam(name = "fileId", value = "附件id", dataType = "String", required = true)})public RestResponse<SeaweedResponse> getFileInfo(@PathVariable String fileId) throws IOException {CloseableHttpClient client = null;String name = "未命名";try {String url = getTemplate().getFileUrl(fileId);client = HttpClientBuilder.create().build();HttpGet get = new HttpGet(url);get.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.81 Safari/537.36");HttpResponse response = client.execute(get);String s = response.getFirstHeader("Content-Disposition").getValue();name = new String(s.substring(18,s.length()-1).getBytes("iso-8859-1"), "utf-8");}catch (Exception e){reConnect();logger.error("公共下载附件出错",e);}finally {if(client != null){client.close();}}SeaweedResponse response = new SeaweedResponse();response.setFileId(fileId);response.setFileName(name);response.setFilePath(getTemplate().getFileUrl(fileId));return RestResponse.ok(response);}

三、SeaweedFS 删除附件接口

    @Autowiredprivate FileTemplate template;/*** @Description: 上传附件接口* @Date: 2019/12/19*/@PostMapping("/delete")@ApiOperation(value="公共删除附件接口",notes = "删除附件接口")public RestResponse deleteFile(@RequestParam(name = "fileId") String fileId) throws IOException {if (StringUtils.isEmpty(fileId)) {return RestResponse.fail().setMsg("fileId 参数不能为空");}template.deleteFile(fileId);return RestResponse.ok("删除成功");}

我是进阶的球儿，大家一起2019年的爬坑历程。感觉分享很给力的话给个赞，谢谢！！！有问题也可以下方留言或者加本人QQ：313989006 进行沟通。

SeaweedFS 分布式上传、下载、删除附件公共接口相关推荐

vue 上传下载删除附件用到blob
接口 export function uploadFileEvaluation(data) { return request({ url: `${prefix}/tqmevaluation/uploa ...
springboot---fastDFS 简单文件上传/下载/删除
本来想简单的记录一下上传/下载,后来看着看着,发现这块的知识点太多.就记录下简单的操作,后面在补充这里采用fastdfs分布式文件系统的形式来进行操作的(关于fastdfs的知识点有很多,这里就不赘 ...
微信小程序文件云存储-上传下载删除功能
文件云存储云存储提供高可用.高稳定.强安全的云端存储服务,支持任意数量和形式的非结构化数据存储,如视频和图片,并在控制台进行可视化管理.云存储包含以下功能: 存储管理:支持文件夹,方便文件归类.支持 ...
基于Django的文件上传下载删除管理器
这是一个基于Django的文件下载,上传,删除的任务管理器先看看效果展示 1.运行完Django后,直接输入网址http://127.0.0.1:8000 就可以直接进去该网站 2.这是一个主图上 ...
阿里云oss简单的上传下载删除（java）
阿里云oss上传和下载. 配置maven  ...
阿里云oss 使用, 基于Nginx 配置云服务器+oss的内网访问 , 及使用Java SDK 完成上传,下载,删除,查询文件列表操作
一.同阿里产品,云服务器和存储对象oss-配置内网访问阿里存储对象oss 地址: https://oss.console.aliyun.com/overview 配置须知通过Nginx 进行网络转 ...
Day228229.上传查询医院接口、上传查询删除科室接口、上传查询删除排班接口 -尚医通
尚医通一.上传医院接口参考<尚医通API接口文档.docx>业务接口4.1上传医院参考<医院接口模拟系统.docx>进行接口测试与数据上传这里要整合hospital-m ...
Struts2　文件上传,下载,删除
本文介绍了: 1.基于表单的文件上传 2.Struts 2 的文件下载 3.Struts2.文件上传 4.使用FileInputStream FileOutputStream文件流来上传 5.使用Fi ...
java操作文件_java操作FTP，实现文件上传下载删除操作
上传文件到FTP服务器: /** * Description: 向FTP服务器上传文件 * @param url FTP服务器hostname * @param port FTP服务器端口,如果默认端 ...
minio对象存储单机部署并设置开机自启动及集成spring boot进行（创建删除桶）（上传下载删除文件）
目录 1.minio简介 2.minio特性 3.下载及部署 4.配置开机自启动 5.集成Springboot 1.minio简介 MinIO 是在GNU Affero 通用公共许可证 v3.0下发布 ...

SeaweedFS 分布式上传、下载、删除附件公共接口

SeaweedFS 分布式上传、下载、删除附件公共接口相关推荐

最新文章

热门文章

SeaweedFS 分布式 上传、下载、删除附件公共接口

SeaweedFS 分布式 上传、下载、删除附件公共接口相关推荐

最新文章

热门文章

SeaweedFS 分布式上传、下载、删除附件公共接口

SeaweedFS 分布式上传、下载、删除附件公共接口相关推荐