【SpringBoot整合系列】SpringBoot整合FastDFS(二)

目录

  • SpringBoot整合FastDFS
    • Java客户端/依赖
    • 常用api接口解释
      • 1.uploadFile
        • 参数
        • 返回值
      • 2.uploadSlaveFile
        • 参数
        • 返回值
      • 3.getMetadata
        • 参数
        • 返回值
      • 4.overwriteMetadata
        • 参数:
        • 返回值:无
      • 5.mergeMetadata
        • 参数:
        • 返回值:无
      • 6.queryFileInfo
        • 参数:
        • 返回值
      • 7.deleteFile
        • 参数:
        • 返回值:无
      • 8.downloadFile
        • 参数
        • 返回值
      • 9.downloadFile
        • 参数
        • 返回值
    • 代码测试
      • yml配置
      • 工具类
      • 上传
        • Controller
        • 测试
      • 下载
        • Controller
        • 测试

SpringBoot整合FastDFS

Java客户端/依赖

        <dependency><groupId>com.github.tobato</groupId><artifactId>fastdfs-client</artifactId><version>1.27.2</version></dependency>

常用api接口解释

1.uploadFile

uploadFile(String groupName, InputStream inputStream, long fileSize, String fileExtName)

参数
  • groupName:上传文件所属的组名。
  • inputStream:输入流对象,指向要上传的文件内容。
  • fileSize:上传文件的大小,单位为字节。
  • fileExtName:上传文件的扩展名。
返回值

返回值:一个 StorePath 对象,其中封装文件的路径和 store 节点的地址。

2.uploadSlaveFile

uploadSlaveFile(String groupName, String masterFilename, InputStream inputStream, long fileSize, String prefixName, String fileExtName)

参数
  • groupName:文件上传到的组名。
  • masterFilename:主文件的名称。
  • inputStream:从文件的输入流对象。
  • fileSize:上传从文件的大小,单位为字节。
  • prefixName: 从文件名前缀
  • fileExtName:从文件的扩展名
返回值

返回值:一个 StorePath 对象,表示成功上传后从文件存储的路径信息。

3.getMetadata

getMetadata(String groupName, String path)

参数
  • groupName:文件所属的分组名。
  • path:文件的在 FastDFS 存储中真实的路径。
返回值

返回值:Set 集合,其中包含多组 metadata 信息。每一条 metadata 是 k-v 形式的键值对。如果没有找到对应的 metadata 信息,则返回一个空的集合。

4.overwriteMetadata

overwriteMetadata(String groupName, String path, Set metaDataSet)

参数:
  • groupName:文件所属的分组名。
  • path:文件在 FastDFS 存储中真实的路径。
  • metaDataSet:要覆盖的新的 metadata 集合。
返回值:无

5.mergeMetadata

mergeMetadata(String groupName, String path, Set metaDataSet)

参数:
  • groupName:文件所属的分组名。
  • path:文件在 FastDFS 存储中真实的路径。
  • metaDataSet:待合并的metadata集合。
返回值:无

6.queryFileInfo

queryFileInfo(String groupName, String path)

参数:
  • groupName:文件所属的组名。
  • path:文件在 FastDFS 存储中真实的路径。
返回值

返回值:一个 FileInfo 对象,包含了文件的元数据信息。

7.deleteFile

deleteFile(String groupName, String path)

参数:
  • groupName:文件所属的组名。
  • path:文件在 FastDFS 存储中真实的路径。
返回值:无

8.downloadFile

downloadFile(String groupName, String path, DownloadCallback callback)

参数
  • groupName:文件所属的组名。
  • path:文件在 FastDFS 存储中真实的路径。
  • callback:下载回调接口对象。
返回值

返回值:一个泛型值对象 T,表示经过回调方法处理后的结果。

9.downloadFile

downloadFile(String groupName, String path, long fileOffset, long fileSize, DownloadCallback callback)

参数
  • groupName:文件所属的组名。
  • path:文件在 FastDFS 存储中真实的路径。
  • fileOffset:文件偏移量,从哪个地方开始下载。
  • fileSize:要下载的文件大小。
  • callback:下载回调接口对象。
返回值

返回值:一个泛型值对象 T,表示经过回调方法处理后的结果。

代码测试

yml配置

fdfs:
# 超时时间connect_timeout: 5000# 读取时间so_timeout: 30000# 服务地址列表tracker-list: 192.168.29.31:22122
# 解决限制文件大小
spring:servlet:multipart:max-request-size: 1TBmax-file-size: 1TB

工具类

package com.zjl.util;import com.github.tobato.fastdfs.domain.fdfs.StorePath;
import com.github.tobato.fastdfs.domain.proto.storage.DownloadByteArray;
import com.github.tobato.fastdfs.service.FastFileStorageClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;import javax.annotation.Resource;
import java.io.IOException;
import java.nio.charset.StandardCharsets;/*** @author: zjl* @datetime: 2024/4/7* @desc:*/
@Component
public class FastdfsUtil {@Resourceprivate FastFileStorageClient storageClient;/*** 上传** @param file* @return*/public String upload(MultipartFile file) {// 获取文件名String filename = file.getOriginalFilename();// 得到文件扩展名String extName = filename.substring(filename.lastIndexOf(".") + 1);StorePath storePath = null;try {// 上传storePath = storageClient.uploadFile(file.getInputStream(), file.getSize(), extName, null);// 这个getFullPath是fastdfs返回的id,可通过这个实现图片浏览、视频播放、文件下载等操作return storePath.getFullPath();} catch (IOException e) {throw new RuntimeException(e);}}/*** 下载文件(写二进制流)* @param path* @return*/public ResponseEntity<byte[]> download(String fileName ,String path,HttpServletRequest request) throws Exception {StorePath storePath = StorePath.parseFromUrl(path);String substring = path.substring(path.lastIndexOf("."));byte[] data = storageClient.downloadFile(storePath.getGroup(), storePath.getPath(), new DownloadByteArray());fileName = this.getFilename(request,fileName);HttpHeaders httpHeaders = new HttpHeaders();// 设置下载响应类型以及文件名httpHeaders.setContentType(MediaType.APPLICATION_OCTET_STREAM);httpHeaders.setContentDispositionFormData("attachment",fileName+substring );return new ResponseEntity<>(data,httpHeaders, HttpStatus.OK);}//解决中文下载问题public String getFilename(HttpServletRequest request, String filename) throws Exception {//ie浏览器的编码格式String[] IEBrowserWords = {"MSIE","Trident","Edge"};String userAgent = request.getHeader("User-Agent");for (String ieBrowserWord : IEBrowserWords) {if(userAgent.contains(ieBrowserWord)){return URLEncoder.encode(filename,"UTF-8");}}//其他浏览器就采用这种编码格式return new String(filename.getBytes("UTF-8"),"ISO-8859-1");}
}

上传

Controller
package com.zjl.controller;import com.zjl.util.FastdfsUtil;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;import javax.annotation.Resource;/*** @author: zjl* @datetime: 2024/4/7* @desc:*/
@RestController
public class MyFileController {@Resourceprivate FastdfsUtil fastdfsUtil;@PostMapping("/upload")public String upload(MultipartFile file){return fastdfsUtil.upload(file);}
}
测试

在这里插入图片描述
直接访问这个地址:http://192.168.29.31:8888/group1/M00/00/00/wKgdH2YSNj2ABnBCAAEQeS5bVeM384.jpg
在这里插入图片描述

下载

Controller
@GetMapping("/download")public ResponseEntity<byte[]> download(HttpServletRequest request) throws Exception {//假设这是从其他业务层获取的文件路径String filePath = "group1/M00/00/00/wKgdH2YSNj2ABnBCAAEQeS5bVeM384.jpg";String fileName = "Spring权限管理";return fastdfsUtil.download(fileName,filePath,request);}
测试

在这里插入图片描述
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/799986.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Shoplazza闪耀Shoptalk 2024,新零售创新解决方案引领行业新篇章!

在近期举办的全球零售业瞩目盛事——Shoptalk 2024大会上,全球*的零售技术平台-店匠科技(Shoplazza)以其*的创新实力与前瞻的技术理念,成功吸引了与会者的广泛关注。此次盛会于3月17日至20日在拉斯维加斯曼德勒湾隆重举行,汇聚了逾万名行业精英。在这场零售业的盛大聚会上,Shop…

Unity开发一个FPS游戏之三

在前面的两篇博客中&#xff0c;我已实现了一个FPS游戏的大部分功能&#xff0c;包括了第一人称的主角运动控制&#xff0c;武器射击以及敌人的智能行为。这里我将继续完善这个游戏&#xff0c;包括以下几个方面&#xff1a; 增加一个真实的游戏场景&#xff0c;模拟一个废弃的…

WebAPI(一)之DOM操作元素属性和定时器

webAPI之DOM操作元素属性和定时器 介绍概念DOM 树DOM 节点document获取DOM对象操作元素内容操作元素属性常用属性修改控制样式属性操作表单元素属性自定义属性间歇函数今日单词了解 DOM 的结构并掌握其基本的操作,体验 DOM 的在开发中的作用 知道 EC

谷粒商城实战(011 业务-检索服务)

Java项目《谷粒商城》架构师级Java项目实战&#xff0c;对标阿里P6-P7&#xff0c;全网最强 总时长 104:45:00 共408P 此文章包含第173p-第p194的内容 介绍 这些过滤条件都可以写在must里&#xff0c;但是filter不参与评分&#xff0c;速度会快一些&#xff0c;所以一些分类等…

vue 的状态库管理

Vuex 和 Pinia 均是 Vue.js 的状态管理库&#xff0c;它们为 Vue 应用程序提供了一种集中式的、可预测的状态管理解决方案。 Vuex 是 Vue.js 官方推荐的状态管理库之一。它的核心概念包括 state、mutation、action 和 getter。其中&#xff0c;state 代表应用程序的状态数据&a…

GBase 8s Docker镜像说明

最后更新&#xff1a;2024-04-07 版本号使用&#xff1a; v8.8_3503x1 v8.8_3331x12 文件列表 Dockerfile FROM scratch ADD v8.8_3503x1_x64.tar.gz / EXPOSE 9088 CMD /start.sh注&#xff1a;不同数据库版本的ADD 文件名称不一样。 v8.8_3503x1_x64.tar.gz GBase 8s 数据…

深入探讨WebView的使用与后退键处理:实现无缝网页浏览体验

引言 在移动应用开发中&#xff0c;WebView作为一个强大的组件&#xff0c;为我们提供了将网页内容无缝嵌入原生应用程序的能力。它允许用户在不离开应用环境的情况下访问网页、在线内容或Web应用程序&#xff0c;极大地提升了用户体验的连贯性和便利性。然而&#xff0c;要充分…

docker自动化部署示例

前提 安装docker 、 docker-cpmpose、git、打包环境&#xff08;如meaven、jdk、node等&#xff09; 原理 git Dockerfile docker-compose 获取源码&#xff08;代码仓库&#xff09;获取可运行程序的镜像&#xff08;docker&#xff09;将打包后的程序放入镜像内&#xf…

AssetBundle打包

AssetBundle技术的概念 Unity的AssetBundle是一个资源压缩包&#xff0c;包含模型、贴图、预制体、声音甚至整个场景&#xff0c;可以在游戏运行时被加载。   AssetBundle自身保存着相互的依赖关系&#xff0c;压缩包可以使用LZMA和LZ4压缩算法&#xff0c;减少包大小&#x…

【学习】移动端App性能测试流程有哪些

移动端App性能测试是保证App性能表现的重要环节之一。随着移动设备的普及和移动互联网的发展&#xff0c;移动端App的性能测试变得越来越重要&#xff0c;通过科学合理的性能测试可以发现并解决潜在的性能问题优化App运行效果提高用户体验。性能测试旨在评估App在各种场景下的性…

基于视频监管与AI智能识别技术的水利河道综合治理解决方案

一、方案介绍 TSINGSEE青犀视频水利河道综合治理解决方案是依托视频AI智能分析技术&#xff0c;利用水质/水文等传感器、高清摄像机、水利球、无人机、无人船等感知设备实时采集数据&#xff0c;并与视频能力进行联动&#xff0c;达到智能预警的目的。 TSINGSEE青犀方案以信息…

Spring Cloud微服务入门(三)

服务注册与发现的概念 服务之间相互访问&#xff1a; 例如&#xff1a;用户中心与内容中心之间相互调用。 问题&#xff1a; 服务调用需要知道对方的服务地址&#xff0c;地址写在哪里&#xff1f; 如果服务是多个实例部署&#xff0c;该调用哪一个&#xff1f; 如果服务是多…

Jetpack Compose -> 状态机制的背后秘密

前言 上一章我们讲解了 Jetpack Compose 的无状态、状态提升、单向数据流 本章我们讲解下状态机制的背后秘密 List 前面我们讲过&#xff0c;通过 by mustableStateOf() 就可以被 Compose 自动订阅了&#xff1b;我们前面是通过 String 类型进行的自动订阅&#xff0c;那么换成…

【深度学习】YOLO-World: Real-Time Open-Vocabulary Object Detection,目标检测

介绍一个酷炫的目标检测方式&#xff1a; 论文&#xff1a;https://arxiv.org/abs/2401.17270 代码&#xff1a;https://github.com/AILab-CVC/YOLO-World 文章目录 摘要Introduction第2章 相关工作2.1 传统目标检测2.2 开放词汇目标检测 第3章 方法3.1 预训练公式&#xff1a…

Linux命令-dos2unix命令(将DOS格式文本文件转换成Unix格式)

说明 dos2unix命令 用来将DOS格式的文本文件转换成UNIX格式的&#xff08;DOS/MAC to UNIX text file format converter&#xff09;。DOS下的文本文件是以 \r\n 作为断行标志的&#xff0c;表示成十六进制就是0D0A。而Unix下的文本文件是以\n作为断行标志的&#xff0c;表示成…

vitepress系列-01-搭建笔记骨架

文章目录 搭建笔记骨架 搭建笔记骨架 环境依赖&#xff1a;Node.js 18 及以上版本。 项目创建-以macOS为例 # 1.创建空项目 mkdir vitepress-learn-notes# 2.进入 vitepress-learn-notes cd vitepress-learn-notes# 3. 初始化项目 pnpm init# 4.安装vitepress 根据自己电脑的安…

MongoDB数据更新中的乘法$mul

学习mongodb&#xff0c;体会mongodb的每一个使用细节&#xff0c;欢迎阅读威赞的文章。这是威赞发布的第57篇mongodb技术文章&#xff0c;欢迎浏览本专栏威赞发布的其他文章。 空闲下来&#xff0c;仔细阅读Mongodb的官方文档&#xff0c;发现很多新的功能。mongodb为了给开发…

【C++】STL--list

目录 list的介绍 list的使用 list的构造 list iterator的使用 list capacity list modifiers list的迭代器失效 list模拟实现 list的介绍 1. list是可以在常数范围内在任意位置进行插入和删除的序列式容器&#xff0c;并且该容器可以前后双向迭代。 2. list的底层是双向…

电容隔离型±10V输入隔离放大器特点:ISOC 124P

产品特点: 50KHz(-3dB)高带宽与ISO 124P隔离器Pin-Pin兼容 低成本小体积&#xff0c;标准DIP16Pin阻燃材料封装 精度等级:0.01级&#xff0c;全量程内非线性度0.01% 信号输入与输出之间:3000VDC隔离耐压 电源范围:4.5V~18V 双极运算:Vo10V 方便易用&#xff0c;固定单位增益配置…

ubuntu安装nginx以及开启文件服务器

1. 下载源码 下载页面&#xff1a;https://nginx.org/en/download.html 下载地址&#xff1a;https://nginx.org/download/nginx-1.24.0.tar.gz curl -O https://nginx.org/download/nginx-1.24.0.tar.gz2. 依赖配置 sudo apt install gcc make libpcre3-dev zlib1g-dev ope…