SpringBoot整合华为云OBS实现文件上传下载

首先我们要添加对应的依赖

        <dependency><groupId>com.huaweicloud</groupId><artifactId>esdk-obs-java</artifactId><version>3.20.6.1</version></dependency>

不要忘记在启动类上添加

    @Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();}

然后在对应的配置文件添加华为云对应的密钥，没有的话可以去华为云获取对应密钥

#obs
huawei:obs:ak: xxxxxxxxxxxxsk: xxxxxxxxxxxxxxupload:endPoint: obs.xxxxxx.xxxxxx.combucketName: xxxxxparentDir:  xxx

然后我们创建对应的config类

package Hwei.OBS.demo.config;import com.obs.services.ObsClient;
import com.obs.services.exception.ObsException;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;/*** 华为obs配置类*/
@Data
@Slf4j
@Configuration
public class HweiOBSConfig {@Value("${huawei.obs.ak:home}")private String accessKey;@Value("${huawei.obs.sk:home}")private String securityKey;@Value("${huawei.obs.upload.endPoint:home}")private String endPoint;@Value("${huawei.obs.bucketName:home}")private String bucketName;/*** 创建实例* @return*/public ObsClient getInstance(){return new ObsClient(accessKey,securityKey,endPoint);}/*** 销毁实列* @param obsClient*/public void destroy(ObsClient obsClient)  {try{obsClient.close();}catch (ObsException e){log.error("obs执行失败",e);}catch (Exception e){log.error("执行失败",e);}}}

这里我把需要的上传下载的方法封装起来了，这里获取到了文件上传的进度，如果前后台分离可以使用webSocket进行实时通讯，在这里就不详细讲了。

package Hwei.OBS.demo.util;import Hwei.OBS.demo.config.HweiOBSConfig;
import Hwei.OBS.demo.dto.FileUploadStatus;
import com.obs.services.ObsClient;
import com.obs.services.exception.ObsException;
import com.obs.services.model.*;import jdk.internal.util.xml.impl.Input;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.IOUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.multipart.MultipartFile;import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedOutputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;@Slf4j
@Configuration
public class HweiOBSUtil {@Autowiredprivate HweiOBSConfig hweiOBSConfig;/*** 文件上传* @param uploadFile 上传的文件* @param FileName 文件名称* @return 返回的路径*/public PutObjectResult fileUpload(MultipartFile uploadFile, String FileName){ObsClient obsClient=null;try {//创建实例obsClient = hweiOBSConfig.getInstance();//获取文件信息InputStream inputStream = uploadFile.getInputStream();UploadFileRequest request1 = new UploadFileRequest(hweiOBSConfig.getBucketName(), FileName);long available = inputStream.available();PutObjectRequest request = new PutObjectRequest(hweiOBSConfig.getBucketName(), java.lang.String.valueOf(FileName), inputStream);ObjectMetadata objectMetadata = new ObjectMetadata();objectMetadata.setContentLength(available);request.setMetadata(objectMetadata);//设置公共读request.setAcl(AccessControlList.REST_CANNED_PUBLIC_READ);PutObjectResult putObjectResult = obsClient.putObject(request);return putObjectResult;} catch (IOException e) {e.printStackTrace();}finally {//销毁实例hweiOBSConfig.destroy(obsClient);}return null;}/*** 获取文件上传进度* @param fileName* @return*/public FileUploadStatus getFileUploadPlan(String objectName){ObsClient obsClient=null;FileUploadStatus fileUploadStatus = new FileUploadStatus();try {obsClient=hweiOBSConfig.getInstance();GetObjectRequest request = new GetObjectRequest(hweiOBSConfig.getBucketName(), objectName);request.setProgressListener(new ProgressListener() {@Overridepublic void progressChanged(ProgressStatus status) {//上传的平均速度fileUploadStatus.setAvgSpeed(status.getAverageSpeed());//上传的百分比fileUploadStatus.setPct(String.valueOf(status.getTransferPercentage()));}});// 每下载1MB数据反馈下载进度request.setProgressInterval(1024*1024L);ObsObject obsObject = obsClient.getObject(request);// 读取对象内容InputStream input= obsObject.getObjectContent();byte[] b = new byte[1024];ByteArrayOutputStream byteArrayOutputStream= new ByteArrayOutputStream();int len;while ((len=input.read(b))!=-1 ){//将每一次的数据写入缓冲区byteArrayOutputStream.write(b,0,len);}byteArrayOutputStream.close();input.close();return fileUploadStatus;}catch (Exception e){e.printStackTrace();}finally {hweiOBSConfig.destroy(obsClient);}return null;}/*** 文件下载* @param request* @param response* @param fileName 文件名称* @return*/public int fileDownload(HttpServletRequest request, HttpServletResponse response, String fileName){try {ObsClient obsClient = hweiOBSConfig.getInstance();ObsObject obsObject = obsClient.getObject(hweiOBSConfig.getBucketName(), fileName);InputStream input = obsObject.getObjectContent();//缓冲文件输出流BufferedOutputStream outputStream = new BufferedOutputStream(response.getOutputStream());//设置让浏览器弹出下载提示框，而不是直接在浏览器中打开response.addHeader("Content-Disposition", "attachment;filename=" + fileName);IOUtils.copy(input,outputStream);outputStream.flush();outputStream.close();input.close();return 0;}catch (Exception e){log.error("文件下载失败：{}",e.getMessage());return 1;}}
}

对应的Controller，这里在上传的时候去校验redis是否有上传成功的，如果有就直接返回对应的值，实现了秒传的效果。

package Hwei.OBS.demo.controller;import Hwei.OBS.demo.config.WebSocketHandler;
import Hwei.OBS.demo.dto.FileUploadStatus;
import Hwei.OBS.demo.dto.R;
import Hwei.OBS.demo.dto.fileChunkDto;
import Hwei.OBS.demo.util.FileUtil;
import Hwei.OBS.demo.util.HweiOBSUtil;
import cn.hutool.crypto.SecureUtil;
import com.obs.services.model.PutObjectResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;@RestController
@RequestMapping("huawei/obs")
public class ObsController {@Autowiredprivate HweiOBSUtil hweiOBSUtil;@Autowiredprivate WebSocketHandler webSocketHandler;@Resourceprivate RedisTemplate redisTemplate;/*** 文件上传* @param uploadFile* @return*/@PostMapping("fileUpload")public R fileUpload(MultipartFile uploadFile){//讲文件转换为md5,实现唯一性String fileString = FileUtil.MultipartFileToString(uploadFile);String fileMd5 = SecureUtil.md5(fileString);//reids是否存在if (redisTemplate.hasKey(fileMd5)){//存在返回名称String  fileUrl = (String) redisTemplate.opsForValue().get(fileMd5);return R.ok().data(fileUrl);}else{//不存在上传并放入redisPutObjectResult putObjectResult = hweiOBSUtil.fileUpload(uploadFile, uploadFile.getOriginalFilename());if (putObjectResult!=null){redisTemplate.opsForValue().set(fileMd5,putObjectResult.getObjectUrl());return R.ok().data(putObjectResult.getObjectKey());}else{return R.error();}}}/*** 查询上传进度* @param fileName*/@GetMapping("realFilePlan")public void redalFilePlan(String fileName) {FileUploadStatus fileUploadPlan = hweiOBSUtil.getFileUploadPlan(fileName);webSocketHandler.sendAllMessage(fileUploadPlan.getPct());}/*** 下载文件* @param request* @param response* @param fileName* @return*/@GetMapping("fileDownload")public R fileDownload(HttpServletRequest request, HttpServletResponse response, String fileName){int i = hweiOBSUtil.fileDownload(request, response, fileName);if(i==0){return null;}return R.error();}}

对应的MultipartFile转成String

package Hwei.OBS.demo.util;import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.multipart.MultipartFile;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.nio.charset.StandardCharsets;@Slf4j
@Configuration
public class FileUtil {/*** MultipartFile转成String* @param file* @return*/public static String MultipartFileToString(MultipartFile file){InputStreamReader isr;BufferedReader br;StringBuilder txtResult = new StringBuilder();try {isr = new InputStreamReader(file.getInputStream(), StandardCharsets.UTF_8);br = new BufferedReader(isr);String lineTxt;while ((lineTxt = br.readLine()) != null) {txtResult.append(lineTxt);}isr.close();br.close();return txtResult.toString();} catch (IOException e) {e.printStackTrace();return "";}}
}

SpringBoot整合华为云OBS实现文件上传下载相关推荐

基于华为云obs实现文件上传下载（技术栈mysql+springboot+Maven+jsp+java）的技术分享
基于华为云obs实现文件上传下载(技术栈mysql+springboot+jsp+java)的技术分享 obs实现文件上传下载前言一.OBS是什么? 二.使用步骤 1.1 前期准备 2 工具的内容 ...
SpringBoot 系列教程(九十九)：SpringBoot整合阿里云OSS实现文件上传，下载，删除功能
一.前言之所以写这篇文章呢? 是因为最近在做文件上传时遇到一个问题,就是我们在以前使用传统Spring+SpringMVC+Mybatis框架开发Web项目的时候,都是将项目打包生成一个War包,然 ...
SpringBoot整合华为云OBS
一.参考项华为云 OBS(官网): 对象存储服务OBS官网_海量安全高可靠_数据云存储解决方案-华为云 OBS SDK for Java(官网): SDK下载_对象存储服务 OBS_Java_华为云 ...
基于Springboot外卖系统13：实现文件上传下载模块
1. 上传功能模块 1.1 上传概述文件上传,也称为upload,是指将本地图片.视频.音频等文件上传到服务器上,可以供其他用户浏览或下载的过程. 文件上传时,对页面的form表单有如下要求: 表单 ...
基于华为云obs的springMVC文件上传下载，简单demo
使用华为云的obs作为文件服务使用springdata jpa框架操作数据库创建springboot项目,添加华为云obs的SDK的maven依赖 <!-- 开启spring配置类 --&g ...
华为云OBS文件上传下载工具类
Java-华为云OBS文件上传下载工具类文章目录 Java-华为云OBS文件上传下载工具类 1.华为云obs文件上传下载 2.文件流转MultipartFile 3.File转换为Multipart ...
Nginx的安装基础配置（windows、linux）以及搭建图片服务器（windows、阿里云），文件上传
Nginx的安装基础配置(windows.linux)以及搭建图片服务器(windows.阿里云),文件上传本文目录文章目录 Nginx的安装基础配置(windows.linux)以及搭建图片服务 ...
使用阿里云OSS实现文件上传
概述场景文件上传,是程序开发中必须会使用到的一个功能,比如: 添加商品,用户头像,文章封面等需求富文本编辑(插件文件上传) 文件上传的原理是什么? 我们为什么要实现文件上传,其实就要共享资源,大家 ...
SpringMVC整合fastdfs-client-java实现web文件上传下载
为什么80%的码农都做不了架构师?>>> 版权声明:本文为博主原创文章,转载请标明出处(http://blog.csdn.net/wlwlwlwl015)Thanks. 目录( ...

SpringBoot整合华为云OBS实现文件上传下载

SpringBoot整合华为云OBS实现文件上传下载相关推荐

最新文章

热门文章