(二十四)ATP应用测试平台——springboot集成fastdfs上传与下载功能

news2024/11/16 3:21:39

前言

本节内容我们主要介绍一下如何在springboot项目中集成fastdfs组件，实现文件的上传与下载。关于fastdfs服务中间键的安装过程，本节内容不做介绍。fastdfs是一个轻量级的分布式文件系统，也是我们文件存储中常常使用的组件之一，主要包括文件存储、文件同步、文件访问，实现了文件存储和负载均衡的问题。

正文

①引入fastdfs客户端的maven依赖

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

 ②在application.yml配置fastdfs的属性参数值

fdfs:
  so-timeout: 1501 # 超时时间
  connect-timeout: 601 # 连接超时时间
  tracker-list: # tracker地址：你的虚拟机服务器地址+端口（默认是22122）
    - 125.27.107.218:22122

 ③引入fastdfs客户端组件，交由spring管理

package com.ht.atp.plat.config;

import com.github.tobato.fastdfs.FdfsClientConfig;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.EnableMBeanExport;
import org.springframework.context.annotation.Import;
import org.springframework.jmx.support.RegistrationPolicy;


@Configuration
@Import(FdfsClientConfig.class)
@EnableMBeanExport(registration = RegistrationPolicy.IGNORE_EXISTING)
public class FastDfsConfig {

}

 ④创建springboot文件上传与下载的控制层接口FdfsRecordController.class

package com.ht.atp.plat.controller;

import com.ht.atp.plat.common.Result;
import com.ht.atp.plat.service.FdfsRecordService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

@Api(tags = {"文件管理"})
@RestController
@RequestMapping("/v1/fdfs/record")
public class FdfsRecordController {
    @Autowired
    private FdfsRecordService fdfsRecordService;

    @ApiOperation(value = "文件上传")
    @PostMapping(value = "uploadFile")
    public Result<String> uploadFile(
            @ApiParam(name = "file", value = "上传的文件")
            @RequestParam(value = "file") MultipartFile file) {
        String url = fdfsRecordService.uploadFile(file);
        return Result.success(url);
    }


    @ApiOperation(value = "文件下载")
    @GetMapping(value = "downloadFile")
    public Result<String> downloadFile(
            @ApiParam(name = "url", value = "下载地址")
            @RequestParam(value = "url") String url) {
        String data = fdfsRecordService.downloadFile(url);
        return Result.success(data);
    }

}

 ⑤创建springboot文件上传与下载的业务接口层FdfsRecordService.class

package com.ht.atp.plat.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.ht.atp.plat.entity.FdfsRecord;
import org.springframework.web.multipart.MultipartFile;


public interface FdfsRecordService extends IService<FdfsRecord> {
    /**
     * 上传文件
     *
     * @param file
     * @return
     */
    String uploadFile(MultipartFile file);

    /**
     * 文件下载
     * @param url
     * @return
     */
    String downloadFile(String url);
}

  ⑥创建springboot文件上传与下载的业务接口实现层FdfsRecordServiceImpl.class

package com.ht.atp.plat.service.impl;

import cn.hutool.core.codec.Base64;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
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 com.ht.atp.plat.entity.FdfsRecord;
import com.ht.atp.plat.exception.BusinessException;
import com.ht.atp.plat.mapper.FdfsRecordMapper;
import com.ht.atp.plat.service.FdfsRecordService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import javax.imageio.ImageIO;
import java.awt.image.BufferedImage;
import java.time.LocalDateTime;


@Service
public class FdfsRecordServiceImpl extends ServiceImpl<FdfsRecordMapper, FdfsRecord> implements FdfsRecordService {
    @Autowired
    private FastFileStorageClient storageClient;

    @Override
    public String uploadFile(MultipartFile file) {
        try {
            BufferedImage bufferedImage = ImageIO.read(file.getInputStream());
            if (bufferedImage == null) {
                throw new BusinessException("文件内容不合法，无法上传！");
            }
            String fileName = file.getOriginalFilename();
            String suffix = "";
            if (StringUtils.isNotEmpty(fileName)) {
                String[] splitFileName = fileName.split("\\.");
                if (splitFileName != null && splitFileName.length > 1) {
                    suffix = splitFileName[splitFileName.length - 1];
                }
            }
            FdfsRecord fdfsRecord = new FdfsRecord();
            fdfsRecord.setModifyTime(LocalDateTime.now());
            fdfsRecord.setCreateTime(LocalDateTime.now());
            fdfsRecord.setSuffixName(suffix);
            fdfsRecord.setName(fileName);
            StorePath storePath = this.storageClient.uploadFile(file.getInputStream(), file.getSize(), suffix, null);
            fdfsRecord.setUrl(storePath.getFullPath());
            baseMapper.insert(fdfsRecord);
            return storePath.getFullPath();
        } catch (Exception e) {
            throw new BusinessException("文件上传服务异常，请稍后重试！");
        }
    }

    @Override
    public String downloadFile(String url) {
        String group = url.substring(0, url.indexOf("/"));
        String path = url.substring(url.indexOf("/") + 1);
        DownloadByteArray byteArray = new DownloadByteArray();
        byte[] data = this.storageClient.downloadFile(group, path, byteArray);
        String encodeData = Base64.encode(data);
        return encodeData;
    }
}

⑦创建springboot文件资源信息存储的持久化层FdfsRecordMapper.class，实现文件资源信息的持久化存储

package com.ht.atp.plat.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ht.atp.plat.entity.FdfsRecord;


public interface FdfsRecordMapper extends BaseMapper<FdfsRecord> {

}

⑧创建springboot文件资源信息存储的持久化层FdfsRecordMapper.xml，实现文件资源信息的持久化存储

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ht.atp.plat.mapper.FdfsRecordMapper">

</mapper>

 ⑨创建springboot文件资源信息存储的实体类FdfsRecord.class

package com.ht.atp.plat.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Getter;
import lombok.Setter;

import java.io.Serializable;
import java.time.LocalDateTime;


@Getter
@Setter
@TableName("fdfs_record")
@ApiModel(value = "FdfsRecord对象", description = "")
public class FdfsRecord implements Serializable {

    private static final long serialVersionUID = 1L;

    @ApiModelProperty("主键ID")
    @TableId(value = "id", type = IdType.ASSIGN_ID)
    private String id;

    @ApiModelProperty("业务ID")
    @TableField("business_id")
    private String businessId;

    @ApiModelProperty("服务名称")
    @TableField("service_name")
    private String serviceName;

    @ApiModelProperty("文件名称")
    @TableField("name")
    private String name;

    @ApiModelProperty("文件地址")
    @TableField("url")
    private String url;

    @ApiModelProperty("后缀名称")
    @TableField("suffix_name")
    private String suffixName;

    @ApiModelProperty("创建时间")
    @TableField("create_time")
    private LocalDateTime createTime;

    @ApiModelProperty("创建人")
    @TableField("create_user")
    private String createUser;

    @ApiModelProperty("修改时间")
    @TableField("modify_time")
    private LocalDateTime modifyTime;

    @ApiModelProperty("修改人")
    @TableField("modify_user")
    private String modifyUser;


}

⑩ 使用swagger测试文件上传功能

 ⑪使用swagger测试文件下载功能

结语

通过至此，关于springboot集成fastdfs上传与下载功能到这里就结束了，下期见。。。

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

酷开系统壁纸模式，将氛围感死死拿捏！

酷开系统壁纸模式，将氛围感死死拿捏！

古希腊哲学家柏拉图曾经说过&#xff1a;“美感是起于视觉、听觉产生的快感&#xff0c;以人的感官所能达到的范围为极限。”而电视则恰恰就是视觉听觉的完美融合体&#xff0c;当一台开启的电视可以给我们带来视听享受的时候&#xff0c;一台待机状态下的电视又如何取悦于我们…
阅读更多...
Kotlin新手教程三（类与继承）

Kotlin新手教程三（类与继承）

一、类 1.类的声明 与Java中类似&#xff0c;Kotlin中的类声明使用关键字class&#xff1a; class Person {var height: Int185 //规范写法&#xff1a;冒号后需要紧跟一个空格 }当你定义的类没有类体时&#xff0c;可以省略花括号&#xff1a; class Person2.构造函数…
阅读更多...
多云和混合云场景下的 API 管理：挑战与选择

多云和混合云场景下的 API 管理：挑战与选择

作者张超&#xff0c;API7 Cloud 产品负责人&#xff0c;Apache APISIX PMC 成员。 原文链接 一、多云和混合云 如今微服务已经成为最流行的一种软件架构&#xff0c;人们通过自己对业务的理解&#xff0c;和科学方法&#xff08;比如领域驱动设计的理论&#xff09;的加持将…
阅读更多...
算法刷题打卡第93天： 最大的以 1 为边界的正方形

算法刷题打卡第93天： 最大的以 1 为边界的正方形

最大的以 1 为边界的正方形 难度&#xff1a;中等 给你一个由若干 0 和 1 组成的二维网格 grid&#xff0c;请你找出边界全部由 1 组成的最大 正方形 子网格&#xff0c;并返回该子网格中的元素数量。如果不存在&#xff0c;则返回 0。 示例 1&#xff1a; 输入&#xff1a…
阅读更多...
c++11 标准模板（STL）（std::multimap）（九）

c++11 标准模板（STL）（std::multimap）（九）

定义于头文件 <map> template< class Key, class T, class Compare std::less<Key>, class Allocator std::allocator<std::pair<const Key, T> > > class multimap;(1)namespace pmr { template <class Key, class T…
阅读更多...
【论文速递】ACL 2021-CasEE: 一种用于重叠事件抽取的级联解码联合学习框架

【论文速递】ACL 2021-CasEE: 一种用于重叠事件抽取的级联解码联合学习框架

【论文速递】ACL 2021-CasEE: 一种用于重叠事件抽取的级联解码联合学习框架 【论文原文】&#xff1a;A Joint Learning Framework with Cascade Decoding for Overlapping Event Extraction 【作者信息】&#xff1a;Sheng, Jiawei and Guo, Shu and Yu, Bowen and Li, Qian…
阅读更多...
Python登陆系统

Python登陆系统

前言 #源码见文末公众号哈# 登录系统 一个简单的登录系统包含了登录账户、注册账户、修改密码以及注销账户的操作。 1. 登录账户 登录系统主要需要判断账户是否存在&#xff0c;不存在就注册一个账户&#xff0c;如果第一次登录系统&#xff0c;我们需要先新建一个文件&…
阅读更多...
解密Teradata与中国市场“分手”背后的原因！国产数据库能填补空白吗？

解密Teradata与中国市场“分手”背后的原因！国产数据库能填补空白吗？

2月15日&#xff0c;西方的情人节刚刚过去一天&#xff0c;国内IT行业就爆出一个大瓜。 继Adobe、甲骨文、Tableau、Salesforce之后&#xff0c;又一个IT巨头要撤离中国市场。 Teradata天睿公司官宣与中国市场“分手”&#xff0c;结束在中国的直接运营。目前&#xff0c;多家…
阅读更多...
MySQL Study Notes Design in 2023

MySQL Study Notes Design in 2023

文章目录1 概述1.1 MySQL相关概述1.2 数据模型1.3 SQL分类2 数据库设计-DDL2.1 约束2.2 字段3 数据库操作-DML3.1 增加(insert)1 概述 1.1 MySQL相关概述 数据库&#xff1a;英文为 DataBase&#xff0c;简称DB&#xff0c;它是存储和管理数据的仓库。 数据库管理系统&#xf…
阅读更多...
为什么重写equals必须重写hashCode

为什么重写equals必须重写hashCode

关于这个问题&#xff0c;看了网上很多答案&#xff0c;感觉都参差不齐&#xff0c;没有答到要点&#xff0c;这次就记录一下&#xff01; 首先我们为什么要重写equals&#xff1f;这个方法是用来干嘛的&#xff1f; public boolean equals &#xff08;Object object&#x…
阅读更多...
Wallys|5 GHz 802.11ax|Does wallys QCN9074-5G module support W56?

Wallys|5 GHz 802.11ax|Does wallys QCN9074-5G module support W56?

Wallys|5 GHz 802.11ax|Does wallys QCN9074-5G module support W56?-Does wallys QCN9074-5G module support W56?-The answer is---sure!In this article,we’ll introduce about the W56 at 11ax 5GHz.If you realized this article is helpful, kindly help re-post / co…
阅读更多...
《C陷阱与缺陷》----词法“陷阱”

《C陷阱与缺陷》----词法“陷阱”

导言&#xff1a; 由于一个程序错误可以从不同层面采用不同方式进行考察&#xff0c;而根据程序错误与考察程序的方式之间的相关性&#xff0c;可以将程序错误进行划分为各种陷阱与缺陷&#xff1a; ①.词法“陷阱” ②.语法“陷阱” ③.语义“陷阱” ④.连接问题 ⑤.库函数问…
阅读更多...
Microsoft Office 2021 / 2019 Direct Download Links

Microsoft Office 2021 / 2019 Direct Download Links

前言 微软Office在很长一段时间内都是最常用和最受欢迎的软件。从小型创业公司到大公司，它的使用比例相当。它可以很容易地从微软的官方网站下载。但是，微软只提供安装程序，而不提供完整的软件供下载。这些安装文件通常比较小。下载并运行后，安装的文件将从后端服务器安装M…
阅读更多...
2023美赛B题思路数据代码分享

2023美赛B题思路数据代码分享

文章目录赛题思路2023年美国大学生数学建模竞赛选题&论文一、关于选题二、关于论文格式三、关于论文提交四、论文提交流程注意不要手滑美赛B题思路数据代码【最新】赛题思路 (赛题出来以后第一时间在CSDN分享) 最新进度在文章最下方卡片&#xff0c;加入获取一手资源 202…
阅读更多...
【软件架构设计】SOA/软件架构设计---面向服务的架构（SOA详细解释）

【软件架构设计】SOA/软件架构设计---面向服务的架构（SOA详细解释）

文章目录面向服务的架构SOA 概述1. 服务的基本结构2.SOA 设计原则3. 服务构件与传统构件SOA 的关键技术1. UDDI2.WSDL3.SOAP4.RESTSOA 的实现方法1.Web Service2. 服务注册表3. 企业服务总线微服务1.微服务的优势2. 微服务面临的挑战3.微服务与 SOA面向服务的架构 迄今为止&am…
阅读更多...
使用html-to-image代替html2canvas，结合jspdf实现下载pdf（下载截图下载前端dom元素）

使用html-to-image代替html2canvas，结合jspdf实现下载pdf（下载截图下载前端dom元素）

一、问题 一开始的时候&#xff0c;准备使用html2canvasjspdf来实现的&#xff0c;但是遇到了一个麻烦的问题&#xff0c;在其他项目中使用html2canvas没有任何问题&#xff0c;但是在要开发的项目中使用&#xff0c;就给我报错&#xff0c;是真滴烦。 html2canvas报错 Uncau…
阅读更多...
map和set介绍及其底层模拟实现

map和set介绍及其底层模拟实现

致努力前行的人&#xff1a; 要努力&#xff0c;但不要着急&#xff0c;繁花锦簇&#xff0c;硕果累累都需要过程&#xff01; 目录 1.关联式容器 2.键值对 3.树形结构的关联式容器 3.1set的介绍 3.2set的使用 3.3multiset的使用 3.4map的使用 3.5multimap的使用 4.常见的面试题…
阅读更多...
【Ctfshow_Web】信息收集和爆破

【Ctfshow_Web】信息收集和爆破

0x00 信息收集 web1 直接查看源码 web2 查看不了源码&#xff0c;抓包即可看到&#xff08;JS拦截了F12&#xff09; web3 抓包&#xff0c;发送repeater&#xff0c;在响应包中有Flag字段 web4 题目提示后台地址在robots&#xff0c;访问/robots.txt看到Disallow: /fl…
阅读更多...
vite结合ts使用mock模拟数据，实现前后端异步开发

vite结合ts使用mock模拟数据，实现前后端异步开发

vite结合ts&#xff0c;vue3 使用mock模拟数据&#xff0c;实现前后端异步开发 第一步&#xff1a;安装依赖 安装mock&#xff1a;npm install mockjs --save-dev安装vite-mock插件&#xff1a;npm install vite-plugin-mock --save 注解1&#xff1a; npm 安装依赖包的时候…
阅读更多...
消息中间件----内存数据库 Redis7(第3章 Redis 命令)

消息中间件----内存数据库 Redis7(第3章 Redis 命令)

Redis 根据命令所操作对象的不同&#xff0c;可以分为三大类&#xff1a;对 Redis 进行基础性操作的命令&#xff0c;对 Key 的操作命令&#xff0c;对 Value 的操作命令。3.1 Redis 基本命令首先通过 redis-cli 命令进入到 Redis 命令行客户端&#xff0c;然后再运行下面的命令…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023