正文

(二十四)atp应用测试平台——springboot集成fastdfs上传与下载功能(代码片段)

北溟溟  北溟溟  2023-03-04  803

关键词：

前言

本节内容我们主要介绍一下如何在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上传与下载功能到这里就结束了，下期见。。。

(二十)atp应用测试平台——websocket实现微服务版在线客服聊天室实战案例(代码片段)

前言在前面的博客内容中我们介绍了如何使用websocket实现一个网页版的在线客服聊天室，众所周知，由于websocket是一个长连接，要和服务端保持会话连接，所以其本身并不适用于微服务环境，在微服务环境中&#... 查看详情

(二十一)atp应用测试平台——vue实战之大红灯笼高高挂(代码片段)

前言2022年的最后一天班，好的开始，好的结束。把大红灯笼高高挂起来，欢度元旦的到来，兔年的到来。明年再战。明年再见。。。正文正菜奉上lantern.vue灯笼源码<template><divclass="app"><divclass... 查看详情

(二十一)atp应用测试平台——vue实战之大红灯笼高高挂(代码片段)

(二十二)atp应用测试平台——swagger2集成swagger-bootstrap-ui实现api文档访问(代码片段)

前言原生的swagger文档虽然也可以作为API文档输出，但是不够简洁优美，本节内容我们介绍一下swagger-bootstrap-ui组件，实现对swaggerAPI文档的二次封装，使用API文档更加简洁明了，无论是入参还是结果响应，... 查看详情

跨平台应用开发进阶(二十四)：uni-app实现文件下载并保存(代码片段)

文章目录一、资源下载二、资源保存三、资源打开四、图片保存到本机相册五、拓展阅读一、资源下载APP应用开发过程中，资源下载是一种常见应用场景。uni-app中应用uni.downloadFile实现文件下载功能。示例代码如下：downLo... 查看详情

(十八)atp应用测试平台——关于springboot应用监控的那些事(代码片段)

...快告诉我你的绝招。本节内容我们主要介绍一下springboot应用的常见应用参数监控指标，从而更好的关注springboot应用的运行状况并实现应用的监控。除此之外，我们通过集成一查看详情

(十八)atp应用测试平台——关于springboot应用监控的那些事(代码片段)

atp应用测试平台——关于axios的配置使用(代码片段)

前言该篇是应某个粉丝的要求讲解一下关于axios请求组件的使用，其实axios组件类似我们以前使用过的jQuery中的ajax组件，都是用于进行http网络请求的组件。axios组件在前后端分离项目中使用的更加广泛，也更易集成... 查看详情

(十三)atp应用测试平台——springboot集成kafka案例实战(代码片段)

前言kafka消息中间键也是我们经常要用到的功能，尤其是在大数据、高并发的项目中，如日志收集、业务数据分发等等。其最核心的俩大功能作用是:①削峰填谷②异步解耦。本节我们主要介绍一下如何在springboot项目中集... 查看详情

atp应用测试平台——关于网页表格的打印及pdf下载的实战案例(代码片段)

前言在网站应用中，我们可能会有这样一个需求，将网页的部分内容，例如表格，网页片段下载打印或者导出PDF，本小节内容正是关于这样一个内容的实战，基于vue2环境开发，希望能够帮助到你。源码... 查看详情

atp应用测试平台——关于vue-router前端路由的配置使用案例(代码片段)

前言VueRouter是Vue.js(opensnewwindow)官方的路由管理器。它和Vue.js的核心功能深度集成，功能丰富，是我们构建vue前端项目中必不可少的的组件之一，本节我们简单介绍一下在vue项目中如何使用vue-router组件实现页面的路由... 查看详情

atp应用测试平台——关于vue中vue-quill-editormavon-editortinymce等多种富文本编辑器的集成使用(代码片段)

...or以及tinymce等的集成及使用。源代码依然托管在我们的ATP应用测试平台中，源码地址：https://gitee.com/northcangap/atp，仅供参考使用。富文本编辑器实现效果如下：查看详情

atp应用测试平台——使用bat批处理实现springboot项目的启动与关闭(代码片段)

...停，并且自行配置java环境，这对于windows环境的单应用而言，批处理文件更加简洁，同时也可以实现开机查看详情

atp应用测试平台——使用easyexcel实现excel导入导出多sheet填充模板下载等功能案例实战(代码片段)

前言Java开发中实现Excel的导入、导出、填充、多sheet页操作等常用功能也是我们经常要面对的开发需求，本文以easyexcel为例，将excel中的常用功能整理成一个个小案例，参考使用。案例源码地址：https://gitee.com/northc... 查看详情

(十七)atp应用测试平台——自定义实现一个springboot2的线程池启动器starter

前言启动器是springboot的一大特点，我们可以根据项目自身需求按需装配我们的组件。例如我们需要操作redis，项目中可以添加一个redis的启动器spring-boot-starter-data-redis，这样redis的一些客户端操作功能我们就集成好了&#... 查看详情

(十七)atp应用测试平台——自定义实现一个springboot2的线程池启动器starter(代码片段)

(十九)atp应用测试平台——springboot集成rocketmq案例实战(代码片段)

前言本节内容是关于RocketMQ消息中间键的实战内容，主要介绍在springboot项目中如何集成使用RocketMQ消息中间键，包括消息的发送、消息的接收以及RocketMQ的一些配置说明，以及效果说明。话不多说，开始实战内容。... 查看详情

(十七)atp应用测试平台——redis实现api接口访问限流(固定窗口限流算法)(代码片段)

前言开始正文之前，大多数情况下应该有这样一段场景。面试官：说说平常在项目中，你是如何使用redis的？我：我们就很简单啦，比如前后端分离token的存储、短信验证码的存储，权限列表的存储࿰... 查看详情