当前位置: 首页 > news >正文

基于ali-oss实现不同类型文件上传不同的bucket

基于ali-oss实现不同类型文件上传不同的bucket,并根据大小选择直接上传还是分片上传

  • 1 配置OSS
  • 2 引入依赖
  • 3 上传核心代码
  • 4 文件回显

1 配置OSS

可以看阿里云文档
ps:记得配置跨域

2 引入依赖

pnpm install ali-oss -save

3 上传核心代码

import OSS from "ali-oss";
import dayjs from "dayjs"; // 引入时间组件
import { buildUUID } from "@pureadmin/utils";
import { getStsToken } from "@/api/common/oss";
const BUCKET_PREFIX = "XXX";
// 获取不同文件类型bucket
const OSS_BUCKET_OBJECT = {image: BUCKET_PREFIX + "-image",audio: BUCKET_PREFIX + "-audio",video: BUCKET_PREFIX + "-video1",application: BUCKET_PREFIX + "-file",other: BUCKET_PREFIX + "-upload"
};
// 分片的大小
const SHARD_SIZE = 5;
// 文件大小阈值,主要区分直接上传和分片上传
const FILE_SIZE_THRESHOLD = 50;
type configType = {accessKeyId: string;accessKeySecret: string;bucket: string;expiration: string;region: string;token: string;stsToken: string;
};
let config: configType = undefined;
// 对文件进行上传
export async function uploadFile(file, progressCallback = () => {}) {// progressCallback 三个参数 (进度, 断点信息, 返回值)// 校验传入的对象是否正确if (!file || Object.prototype.toString.call(file) !== "[object File]") {throw new Error("参数不正确");}// 根据约定和相关规则进行参数配置const ossConfig: configType = await getOssConfig();ossConfig.bucket = getBucket(file);ossConfig.stsToken = ossConfig.token;const environment = `/${import.meta.env.VITE_LOGOGRAM}`;const pathName = `${environment}/${dayjs().format("YYYY-MM-DD")}/`;const fileName = `${buildUUID()}.${file.name.split(".").at(-1)}`;// 实例化OSS对象const client = new OSS(ossConfig);try {const fileSize = file.size / 1024 / 1024;// 根据文件大小选择上传的方式if (fileSize > FILE_SIZE_THRESHOLD) {const option = {partSize: 1024 * 1024 * SHARD_SIZE,parallel: Math.ceil(fileSize / SHARD_SIZE),progress: progressCallback};const result = await client.multipartUpload(pathName + fileName,file,option);return `/${result.name}`;} else {const result = await client.put(pathName + fileName, file);return `/${result.name}`;}} catch (e) {return Promise.reject(e);}
}// 获取后端返回的临时凭证,并根据时间判断凭证是否过期
export async function getOssConfig() {if (config?.expiration && dayjs().isBefore(dayjs(config.expiration))) {return config;} else {const { data } = await getStsToken();config = data as configType;return data;}
}// 根据文件类型获取不同的bucket
function getBucket(file) {const bucket = OSS_BUCKET_OBJECT[file.type.split("/")[0]];if (bucket) return bucket;else return OSS_BUCKET_OBJECT["other"];
}

4 文件回显

// 访问协议
const AGREEMENT = "https://";
// 获取不同文件类型的访问地址
const SERVER_ADDRESS = {image: "img.xxx.xxx.com",audio: "audio.xxx.xxx.com",video: "video.xxx.xxx.com",application: "file.xxx.xxx.com",other: "upload.xxx.xxx.com"
};
export const imageRegex = RegExp(/(jpg|bmp|gif|ico|pcx|jpeg|tif|png|raw|tga)/);
export const audioRegex = RegExp(/(mp3|wav|flac|ogg|aac|wma)/);
export const videoRegex = RegExp(/(avi|wmv|mpeg|mp4|m4v|mov|asf|flv|f4v|rmvb|rm|3gp|vob)/
);
export const applicationRegex = RegExp(/(doc|docx|xls|xlsx|ppt|pptx|pdf|txt|apk|zip)/
);
export function preview(pathName) {const suffix = pathName.split(".").at(-1);let type = "other";if (imageRegex.test(suffix)) type = "image";if (audioRegex.test(suffix)) type = "audio";if (videoRegex.test(suffix)) type = "video";if (applicationRegex.test(suffix)) type = "application";return `${AGREEMENT}${SERVER_ADDRESS[type]}${pathName}`;
}
deoRegex.test(suffix)) type = "video";if (applicationRegex.test(suffix)) type = "application";return `${AGREEMENT}${SERVER_ADDRESS[type]}${pathName}`;
}
http://www.lryc.cn/news/109628.html

相关文章:

  • 域名校验?反爬界的掩耳盗铃!
  • Cesium 实战教程 - 调整 3dtiles 倾斜摄影大小
  • python机器学习(七)决策树(下) 特征工程、字典特征、文本特征、决策树算法API、可视化、解决回归问题
  • 数据结构与算法中的双向链表
  • 数据安全治理的关键-数据分类分级工具
  • Spring集成Junit
  • Java正则校验密码至少包含:字母数字特殊符号中的2种
  • Stable Diffusion教程(6) - 扩展安装
  • Jenkins通过OpenSSH发布WinServer2016
  • 字母异位词分组 LeetCode热题100
  • 使用angular和electron 构建桌面应用
  • 安达发制造工业迈向智能化:APS高级计划排程助力提升生产效率
  • Flink - sink算子
  • 【项目 线程2】3.5 线程的分离 3.6线程取消 3.7线程属性
  • Filebeat+ELK 部署
  • el-table点击表格某一行添加到URL参数,访问带参URL加载表格内容并滚动到选中行位置 [Vue3] [Element-plus 2.3]
  • 【树】 二叉树 堆与堆排序 平衡(AVL)树 红黑(RB)树
  • 信号平滑或移动平均滤波研究(Matlab代码实现)
  • 黑客技术(网络安全)自学
  • 使用七牛云、阿里云、腾讯云的对象存储上传文件
  • 使用阿里云DataX完成数据同步
  • 《Kali渗透基础》13. 无线渗透(三)
  • python——案例六:判断字符串的长度
  • PC-windows-安卓-Linux音频系统框架概论
  • Web Worker API
  • 1.4 MA多头/空头排列是真的吗?
  • 基于SpringBoot+Vue的CSGO赛事管理系统设计与实现(源码+LW+部署文档等)
  • Android系统APP之SettingsProvider
  • go入门实践二-tcp服务端
  • SprinMVC获取请求参数