第2-3-6章 打包批量下载附件的接口开发-文件存储服务系统-nginx/fastDFS/minio/阿里云oss/七牛云oss

news2025/7/20 23:55:45

文章目录

      • 5.6 接口开发-根据文件id打包下载附件
        • 5.6.1 接口文档
        • 5.6.2 代码实现
        • 5.6.3 接口测试
      • 5.7 接口开发-根据业务类型/业务id打包下载
        • 5.7.1 接口文档
        • 5.7.2 代码实现
        • 5.7.3 接口测试

5.6 接口开发-根据文件id打包下载附件

第2-1-2章 传统方式安装FastDFS-附FastDFS常用命令
第2-1-3章 docker-compose安装FastDFS,实现文件存储服务
第2-1-5章 docker安装MinIO实现文件存储服务-springboot整合minio-minio全网最全的资料

全套代码及资料全部完整提供，点此处下载

5.6.1 接口文档

根据文件id打包下载附件接口分两种情况进行下载：

1、如果客户端提交的文件id只有一个，则下载对应的原始文件

2、如果客户端提交的文件id有多个，则将对应的多个原始文件进行压缩，最终下载的是压缩后的文件

接口文档如下：

在这里插入图片描述

5.6.2 代码实现

第一步：在AttachmentController中提供根据文件id打包下载文件的方法

/**
* 下载一个文件或多个文件打包下载
*
* @param ids      文件id
* @param response
* @throws Exception
*/
@ApiOperation(value = "根据文件id打包下载", notes = "根据附件id下载多个打包的附件")
@GetMapping(value = "/download", produces = "application/octet-stream")
public void download(
    @ApiParam(name = "ids[]", value = "文件id 数组")
    @RequestParam(value = "ids[]") Long[] ids,
    HttpServletRequest request, HttpServletResponse response) throws Exception {
    BizAssert.isTrue(ArrayUtils.isNotEmpty(ids), 
                     BASE_VALID_PARAM.build("附件id不能为空"));
    //根据文件id下载文件
    attachmentService.download(request, response, ids);
}

第二步：在AttachmentService接口中扩展download方法

/**
* 根据文件id下载附件
*
* @param request
* @param response
* @param ids
* @throws Exception
*/
void download(HttpServletRequest request, 
              HttpServletResponse response, 
              Long[] ids) throws Exception;

第三步：在AttachmentServiceImpl实现类中实现download方法

@Autowired
private FileBiz fileBiz;

/**
* 根据文件id下载文件
* @param request
* @param response
* @param ids
* @throws Exception
*/
@Override
public void download(HttpServletRequest request, 
                     HttpServletResponse response, 
                     Long[] ids) throws Exception {
    //根据文件id查询数据库
    List<Attachment> list = 
        (List<Attachment>) super.listByIds(Arrays.asList(ids));
    down(request, response, list);
}

/**
* 文件下载
* @param request
* @param response
* @param list
* @throws Exception
*/
private void down(HttpServletRequest request, HttpServletResponse response, 
                  List<Attachment> list) throws Exception {
    if (list.isEmpty()) {
        throw BizException.wrap("您下载的文件不存在");
    }
    List<FileDO> fileDOList = 
        list.stream().map((file) ->FileDO.builder()
                                 .url(file.getUrl())
                                 .submittedFileName(file.getSubmittedFileName())
                                 .size(file.getSize())
                                 .dataType(file.getDataType())
                                 .build())
        						 .collect(Collectors.toList());
    fileBiz.down(fileDOList, request, response);
}

第四步：创建FileBiz，统一进行文件下载

package com.itheima.pinda.file.biz;

import cn.hutool.core.util.StrUtil;
import com.itheima.pinda.file.domain.FileDO;
import com.itheima.pinda.file.enumeration.DataType;
import com.itheima.pinda.file.utils.ZipUtils;
import com.itheima.pinda.utils.NumberHelper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

/**
 * 文件和附件的一些公共方法
 */
@Component
@Slf4j
public class FileBiz {
    /**
     * 构建新文件名称
     * @param filename
     * @param order
     * @return
     */
    private static String buildNewFileName(String filename, Integer order) {
        return StrUtil.strBuilder(filename).
            insert(filename.lastIndexOf("."), "(" + order + ")").toString();
    }

    /**
     * 下载文件
     * @param list
     * @param request
     * @param response
     * @throws Exception
     */
    public void down(List<FileDO> list, 
                     HttpServletRequest request, 
                     HttpServletResponse response) throws Exception {
        
        int fileSize = list.stream().filter(
            (file) -> file != null &&
            !DataType.DIR.eq(file.getDataType()) && 
            StringUtils.isNotEmpty(file.getUrl()))
                .mapToInt(
            		(file) -> NumberHelper.intValueOf0(file.getSize())).sum();
        
        String extName = list.get(0).getSubmittedFileName();
        if (list.size() > 1) {
            extName = StringUtils.substring(extName, 0, 
                                  StringUtils.lastIndexOf(extName, ".")) + 
                					"等.zip";
        }

        Map<String, String> map = new LinkedHashMap<>(list.size());
        Map<String, Integer> duplicateFile = new HashMap<>(list.size());
        list.stream()
                //过滤不符合要求的文件
                .filter((file) -> file != null && !DataType.DIR.eq(file.getDataType()) && StringUtils.isNotEmpty(file.getUrl()))
                //循环处理相同的文件名
                .forEach((file) -> {
                    String submittedFileName = file.getSubmittedFileName();
                    if (map.containsKey(submittedFileName)) {
                        if (duplicateFile.containsKey(submittedFileName)) {
                            duplicateFile.put(submittedFileName, duplicateFile.get(submittedFileName) + 1);
                        } else {
                            duplicateFile.put(submittedFileName, 1);
                        }
                        submittedFileName = buildNewFileName(submittedFileName, duplicateFile.get(submittedFileName));
                    }
                    map.put(submittedFileName, file.getUrl());
                });


        ZipUtils.zipFilesByInputStream(map, Long.valueOf(fileSize), extName, request, response);
    }
}

5.6.3 接口测试

第一步：启动Nacos配置中心

第二步：启动Nginx服务

第三步：启动文件服务

第四步：访问接口文档，地址为http://localhost:8765/doc.html

在这里插入图片描述

5.7 接口开发-根据业务类型/业务id打包下载

5.7.1 接口文档

根据业务类型/业务id打包下载文件接口分两种情况进行下载：

1、如果根据业务类型和业务id匹配到的文件只有一个，则下载对应的原始文件

2、如果根据业务类型和业务id匹配到的文件有多个，则将对应的多个原始文件进行压缩，最终下载的是压缩后的文件

接口文档如下：

在这里插入图片描述

5.7.2 代码实现

第一步：在AttachmentController中提供根据业务类型和业务id打包下载的方法

/**
* 根据业务类型或者业务id其中之一，或者2个同时打包下载文件
*
* @param bizIds   业务id
* @param bizTypes 业务类型
*
*/
@ApiImplicitParams({
    @ApiImplicitParam(name = "bizIds[]", value = "业务id数组", dataType = "array", paramType = "query"),
    @ApiImplicitParam(name = "bizTypes[]", value = "业务类型数组", dataType = "array", paramType = "query"),
})
@ApiOperation(value = "根据业务类型/业务id打包下载", notes = "根据业务id下载一个文件或多个文件打包下载")
@GetMapping(value = "/download/biz", produces = "application/octet-stream")
public void downloadByBiz(
    @RequestParam(value = "bizIds[]", required = false) String[] bizIds,
    @RequestParam(value = "bizTypes[]", required = false) String[] bizTypes,
    HttpServletRequest request, HttpServletResponse response) throws Exception {
    BizAssert.isTrue(!(ArrayUtils.isEmpty(bizTypes) && ArrayUtils.isEmpty(bizIds)), BASE_VALID_PARAM.build("附件业务id和业务类型不能同时为空"));
    attachmentService.downloadByBiz(request, response, bizTypes, bizIds);
}

第二步：在AttachmentService接口中扩展downloadByBiz方法

/**
* 根据业务id和业务类型下载附件
*
* @param request
* @param response
* @param bizTypes
* @param bizIds
* @throws Exception
*/
void downloadByBiz(HttpServletRequest request, HttpServletResponse response, 
                   String[] bizTypes, String[] bizIds) throws Exception;

第三步：在AttachmentServiceImpl实现类中实现downloadByBiz方法

/**
* 根据业务id和业务类型下载附件
*
* @param request
* @param response
* @param bizTypes
* @param bizIds
* @throws Exception
*/
@Override
public void downloadByBiz(HttpServletRequest request, HttpServletResponse response, String[] bizTypes, String[] bizIds) throws Exception {
    List<Attachment> list = super.list(
        Wraps.<Attachment>lbQ()
        .in(Attachment::getBizType, bizTypes)
        .in(Attachment::getBizId, bizIds));

    down(request, response, list);
}

5.7.3 接口测试

第一步：启动Nacos配置中心

第二步：启动Nginx服务

第三步：启动文件服务

第四步：访问接口文档，地址为http://localhost:8765/doc.html
在这里插入图片描述

第2-1-2章 传统方式安装FastDFS-附FastDFS常用命令
第2-1-3章 docker-compose安装FastDFS,实现文件存储服务
第2-1-5章 docker安装MinIO实现文件存储服务-springboot整合minio-minio全网最全的资料

全套代码及资料全部完整提供，点此处下载

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

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

相关文章

LeetCode——Weekly Contest 319

LeetCode——Weekly Contest 319

LeetCode周赛第319场记录 这场周赛的质量也很高&#xff0c;有很多值得学习的地方。 2469. 温度转换 这道题很简单&#xff0c;直接根据已有的信息转换即可&#xff0c;一行代码搞定&#xff0c;注意公式不要敲错。 class Solution { public:vector<double> convertTem…
阅读更多...
【案例 5-2】 模拟默认密码自动生成

【案例 5-2】 模拟默认密码自动生成

【案例介绍】 1.任务描述 本例要求编写一个程序&#xff0c;模拟默认密码的自动生成策略&#xff0c;手动输入用户名&#xff0c;根据用户名 自动生成默认密码。在生成密码时&#xff0c;将用户名反转即为默认的密码。 2.运行结果 运行结果如图 5-2 所示。 图 5-2 模拟密码自…
阅读更多...
[附源码]java毕业设计企业公开招聘系统

[附源码]java毕业设计企业公开招聘系统

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…
阅读更多...
Leetode-891-子序列宽度之和

Leetode-891-子序列宽度之和

1、数学 因为我们需要求得是子序列的宽度之和&#xff0c;我们可以先确定不同宽度对应的子序列的个数&#xff0c;而后将其相加即可。我们可以首先在子序列中固定最大值和最小值&#xff0c;此时在剩余的n−2n-2n−2个数中我们可以依次选择0或1或2一直到n−2n-2n−2个&#xf…
阅读更多...
简单工厂、工厂方法 、抽象工厂模式之间的联系

简单工厂、工厂方法 、抽象工厂模式之间的联系

概念 1.简单工厂: 简单工厂模式中工厂为具体工厂&#xff0c;产品为抽象产品&#xff0c;由工厂实例创建产品实例。 2.工厂方法模式&#xff1a; 定义一个用于创建对象的接口&#xff0c;让其子类确定实例化哪一个类。工厂方法使一个类的实例化延迟到其子类。 3.抽象工厂模式&…
阅读更多...
Docker中部署elasticsearch

Docker中部署elasticsearch

Docker中部署elasticsearch1.下载镜像2.查看镜像是否下载成功3.选择挂载硬盘创建三个目录&#xff0c;分别对应es的日志&#xff0c;es的配置&#xff0c;和es的插件。并设置目录权限为可读写。4.进入config目录里创建elasticsearch.yml文件&#xff0c;并使用vi命令插入如下内…
阅读更多...
windows下app爬虫环境搭建：python + fiddler + Appium + 夜神模拟器

windows下app爬虫环境搭建：python + fiddler + Appium + 夜神模拟器

夜神模拟器自行下载安装 1、安装java https://www.oracle.com/java/technologies/downloads/#jdk19-windows 配置环境变量 系统环境下 在Path下添加 验证安装情况 打开 cmd 命令行工具&#xff0c;输入 java -version&#xff0c;返回信息如图所示表示安装配置成功 …
阅读更多...
11.18MyBatis 学习2

11.18MyBatis 学习2

1 #和$的区别 #{}表示一个占位符号 通过#{}可以实现 preparedStatement 向占位符中设置值&#xff0c;自动进行 java 类型和 jdbc 类型转换&#xff0c;#{}可以有效防止 sql 注入。 #{}可以接收简单类型值或 pojo 属性值。可以自动对值添加 ’ ’ 单引号 ${}表示拼接 sql 串…
阅读更多...
【附源码】Python计算机毕业设计天气预报查询管理系统

【附源码】Python计算机毕业设计天气预报查询管理系统

项目运行 环境配置&#xff1a; Pychram社区版 python3.7.7 Mysql5.7 HBuilderXlist pipNavicat11Djangonodejs。 项目技术&#xff1a; django python Vue 等等组成&#xff0c;B/S模式 pychram管理等等。 环境需要 1.运行环境&#xff1a;最好是python3.7.7&#xff0c;…
阅读更多...
linux x64 下的redis安装

linux x64 下的redis安装

1.官网下载linux版本的安装包&#xff0c;官网地址&#xff1a;http://redis.io/download 2.新建目录 mkdir /usr/local/src/redis&#xff0c;并上传到该目录&#xff0c;解压 tar xzvf redis-7.0.5.tar.gz 3…执行make 对Redis解压后文件进行编译 在编译完成之后查看当前文…
阅读更多...
MeterSphereV2.3版本Mac本地启动详细教程（含常见错误）

MeterSphereV2.3版本Mac本地启动详细教程（含常见错误）

一、准备工作 因为代码是java语言写的&#xff0c;所以提前准备好java的环境JDK11 &#xff1a;https://www.oracle.com/java/technologies/javase/jdk11-archive-downloads.htmlmaven&#xff08;3.6.2以上都行&#xff09;&#xff1a;https://archive.apache.org/dist/mave…
阅读更多...
进程的虚拟地址空间

进程的虚拟地址空间

每个程序运行起来后&#xff0c;都拥有一个自己的虚拟地址空间&#xff08;注意是虚拟的&#xff0c;不是实际存在的&#xff09;&#xff0c;这个虚拟地址空间的大小由计算机的硬件平台 关于虚拟的概念&#xff0c;当时IBM给出了一种说法很形象生动&#xff1a; 它存在&#x…
阅读更多...
XSS-labs靶场实战（三）——第7-8关

XSS-labs靶场实战（三）——第7-8关

今天继续给大家介绍渗透测试相关知识&#xff0c;本文主要内容是XSS-labs靶场实战第7-8关。 免责声明&#xff1a; 本文所介绍的内容仅做学习交流使用&#xff0c;严禁利用文中技术进行非法行为&#xff0c;否则造成一切严重后果自负&#xff01; 再次强调&#xff1a;严禁对未…
阅读更多...
PyQt5_股票策略校验工具_升级版

PyQt5_股票策略校验工具_升级版

相对 PyQt5_股票策略校验工具 博文&#xff0c;图形展示方面增加多行图展示&#xff0c;原本只有K线图&#xff0c;升级版工具可以动态添加多行指标图 股票策略有效与否的确认&#xff0c;需要在不同股票&#xff0c;不同时间段&#xff0c;运行对比&#xff0c;确认在哪些条件…
阅读更多...
图文轻松说透 K8S Pod 各种驱逐场景

图文轻松说透 K8S Pod 各种驱逐场景

图文轻松说透 K8S Pod 各种驱逐场景 Kubernetes Pod 被驱逐是什么意思&#xff1f; 它们被终止&#xff0c;通常是没有足够资源的结果。但是为什么会这样呢&#xff1f; 驱逐是指派给节点的Pod 被终止的过程。Kubernetes 中最常见的情况之一是Preemption&#xff0c;为了在资…
阅读更多...
基于PHP+MySQL健身俱乐部系统的设计与实现

基于PHP+MySQL健身俱乐部系统的设计与实现

随着时代的发展和人们对生活的热爱,健身已经成为人们工作之余的一种热爱,相对应的各种健身俱乐部也如雨后春笋般出现,处于宣传的目的各类健身俱乐部网站也不断的出现,处于对健身俱乐部的宣传作用,我们通过PHP语言和MYSQL数据库开发了健身俱乐部系统 PHP&#xff1a;MySQL健身俱…
阅读更多...
笔试强训第29天（有假币+求正数数组的最小不可组成和）

笔试强训第29天（有假币+求正数数组的最小不可组成和）

单选 A选项&#xff1a;当内存访问越界的时候&#xff0c;线程会收到信号&#xff0c;进而进行信号处理。调用信号处理函数。 B选项&#xff1a;ACM时间。 A&#xff1a;最后访问时间&#xff0c;文件被读取而更新的时间 C&#xff1a;状态修改时间&#xff0c;文件的属性或者权…
阅读更多...
pymsql模块+事务+mysql 注入+数据库备份和恢复

pymsql模块+事务+mysql 注入+数据库备份和恢复

import pymysqlconn pymysql.connect(host127.0.0.1, userroot, password123456, databasehomework) # cur conn.cursor(cursorpymysql.cursors.DictCursor)#查询返回字典 cur conn.cursor() # cursor游标&#xff0c;默认返回元组 try:cur.execute(select * from students…
阅读更多...
前端加密与解密

前端加密与解密

插件加密 MD5加密&#xff08;不可逆&#xff09; MD5加密是不可逆的&#xff0c;相当于是插件加密&#xff0c;当然你也可以把他的方法抄过来自己实现。 MD5.js是通过前台js加密的方式对用户信息&#xff0c;密码等私密信息进行加密处理的工具&#xff0c;前端用的比较多。…
阅读更多...
【毕业设计】深度学习手势识别检测系统 - python

【毕业设计】深度学习手势识别检测系统 - python

文章目录1 前言2 项目背景3 任务描述4 环境搭配5 项目实现5.1 准备数据5.2 构建网络5.3 开始训练5.4 模型评估6 识别效果7 最后1 前言 &#x1f525; Hi&#xff0c;大家好&#xff0c;这里是丹成学长的毕设系列文章&#xff01; &#x1f525; 对毕设有任何疑问都可以问学长…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023