React+node 图片剪裁上传,集成本地存储和阿里云OSS

本文涉及的产品
对象存储 OSS,20GB 3个月
云解析 DNS,旗舰版 1个月
全局流量管理 GTM,标准版 1个月
简介: 最近一直在调研图片上传阿里云oss功能,上篇文章主要讲述了阿里云oss大文件分片、断点续传。这篇文章是在原有基础上,前端加了图片剪裁、后端加了本地存储功能。

前言

最近一直在调研图片上传阿里云oss功能,上篇文章主要讲述了阿里云oss大文件分片、断点续传。这篇文章是在原有基础上,前端加了图片剪裁、后端加了本地存储功能。

先看效果
图片剪裁上传 -original-original.gif
技术栈

  1. 前端:react+Ts+antd
  2. 后端:node+koa+koa-body+ali-oss

功能

  1. 图片剪裁(antd剪裁组件
  2. 本地文件上传(antd上传组件+axios
  3. 文件存储本地(node+koa-body
  4. 文件存储阿里oss(node+ali-oss

    核心代码

    环境配置

    引入依赖环境

    使用koa搭建node服务,搭配koa周边依赖包开发起来更方便,详细依赖环境如下:
    const app = new (require('koa'))(); // koa 
    const router = require('koa-Router')();  // koa 路由
    const cors = require('@koa/cors') // 运行koa中跨域 
    const OSS = require('ali-oss') // 阿里云oss-sdk
    const {
         
         koaBody} = require('koa-body'); // 处理请求体中间件、用于解析json、表单 | 包含file内容请求,会生成临时文件,将文件信息添加到ctx.request对象属性,通过ctx.request.files获取
    const path = require('path'); // 对文件路径的操作
    const staticServe = require('koa-static') // 使上传的文件能在浏览器中访问
    const fs = require('fs') // 文件的读写操作 
    const PORT = '9000' // 端口
    

    配置阿里云oss

    const client = new OSS({
         
         
     // yourregion填写Bucket所在地域。以华东1(杭州)为例,Region填写为oss-cn-hangzhou。
     region: 'oss-cn-beijing',
     // 阿里云账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维,请登录RAM控制台创建RAM用户。
     accessKeyId: 'xxx',
     accessKeySecret: 'xx',
     // 填写Bucket名称。
     bucket: 'xxx'
    });
    

    使用中间件

    实现本地上传、解决跨域等功能,需使用koa中间件完成功能
    ``php // __dirname node中全局变量,当前文件所在目录 // 上传本地目录 const UPLOAD_PATH = path.join(__dirname,'public/') // 上传文件后的地址,用于拼接图片名称,回显前端 const UPLOAD_URL =http://localhost:${PORT}`
    // 使用跨域中间件
    app.use(cors())

//应用koabody中间件,处理文件上传操作,生成临时文件路径
app.use(koaBody({
multipart:true ,// 解析文件格式内容
formidable:{
// 上传文件的存储的位置
uploadDir:UPLOAD_PATH,
keepExtensions:true // 保留文件的扩展名
}
}))
// app.use(bodyParser());
app.use(staticServe(UPLOAD_PATH))
app.use(router);
// 启动服务
app.listen(PORT,()=>{
console.log('启动成功 9000')
});

## 阿里云分片上传
### 接口代码
```javascript
router.post('/upload_oss',async(ctx)=>{
    console.log('请求了',ctx.request.files.file)
    console.log('上传oss upload_oss',ctx.request)
    const file = ctx.request.files.file
    let result  = await multipartUpload(file) 
    ctx.body={
        msg:"请求成功了",
        result
    }
})

分片操作

// 上传进度
const progress = (p, _checkpoint) => {
   
   
    // Object的上传进度。
    console.log('分片进度',p); 
    // 分片上传的断点信息。
    // console.log(_checkpoint); 
  };

async function multipartUpload(file) {
   
   
    try {
   
   
      // 依次填写Object完整路径(例如exampledir/exampleobject.txt)和本地文件的完整路径(例如D:\\localpath\\examplefile.txt)。Object完整路径中不能包含Bucket名称。
      // 如果本地文件的完整路径中未指定本地路径(例如examplefile.txt),则默认从示例程序所属项目对应本地路径中上传文件。
      const result = await client.multipartUpload(file.originalFilename, file.filepath, {
   
   
        progress, // 如无需进度实时回显,可不配置
        // headers,
        // 指定meta参数,自定义Object的元信息。通过head接口可以获取到Object的meta数据。
      });
      console.log(result); 
      return result
    } catch (e) {
   
   
      // 捕获超时异常。

      console.log('捕获超时异常。',e);
    }
  }

本地文件上传

存储本地文件两种方式

一、renameSync(移动临时文件)

fs.renameSync(ctx.request.files.file.filepath, filePath);

优点:直接使用fs.renameSync,一次操作即可重命名或移动文件,非常简洁和高效。
缺点:fs.renameSync 是一个同步方法,会直接阻塞代码执行,直到文件操作完成

二、创建文件流存储

const reader = fs.createReadStream(ctx.request.files.file.filepath);
const writer = fs.createWriteStream(filePath);
reader.pipe(writer);

优点:可以同时处理多个文件的上传,不会阻塞代码执行。
缺点:在处理单个文件时可能略微复杂。

renameSync 存储单文件

// 请求中的第二个参数是请求中间件函数,可用于请求前的业务操作 
router.post('/upload_local',async(ctx,next)=>{
   
   

    const filePath = UPLOAD_PATH+`/${
     
     ctx.request.files.file.originalFilename}`
    fs.renameSync(ctx.request.files.file.filepath, filePath);
    await next()
},async(ctx)=>{
   
   
    ctx.body={
   
   
        msg:"请求成功了", 
        imgUrl:UPLOAD_URL+`/${
     
     ctx.request.files.file.originalFilename}` 
    }
})

常见问题

multer存储文件名乱码怎么办?

在第一版代码中,采用的是multer存储文件,上传文件是中文命名,multer中无法解析格式,导致文件名乱码。
解决方式:将使用 Latin-1 编码的文件名转换为 UTF-8 编码
示例代码:

// 文件名称命名
    filename:function(req,file,cb){
   
   
        console.log('文件名称命名')  
        const decodedName = Buffer.from(file.originalname, "latin1").toString(
            "utf8"
          );
        console.log('decodedName',decodedName)
        cb(null,decodedName)
    }

Buffer.from(file.originalname, "latin1")使用 Buffer.from 方法将以 Latin-1 编码的 file.originalname 字符串转换为一个 Buffer 对象。Latin-1 是一种字符编码,也称为 ISO-8859-1。
toString("utf8")使用 toString 方法将 Buffer 对象转换回字符串,指定目标编码为 UTF-8。这将将 Latin-1 编码的字符串转换为 UTF-8 编码的字符串。

Koa接收不到file对象内容

正常情况下,引入koa-body中间件后,可以获取到前端表单数据,如下:
image.png
如果获取不到,大概率是 routes 代码书写顺序错乱导致
⚠ 中间件的应用需要写在routes前面才可以
正常执行顺序如下:

const koaBody  = require('koa-body')({
   
   multipart: true});
app.use(koaBody); //中间件的应用需要写在routes前面才可以
app.use(router.routes())

koa-body 和 koa-bodypaser不兼容

在第一版代码中,使用 koa-bodypaser + multer来存储本地文件,koa-body+ali-oss上传阿里云存储。

这两个功能单独使用是没有问题,但是服务端同时定义两个接口,则会出现阿里云oss或本地存储失败。百度搜了一圈没找到解决方案,最终果断弃坑multer, 使用koa-body 来解析请求体内容.

koa-body不仅可以解析请求体内容、还可以生产文件临时路径、方便存储操作

  • koa-body 用于解析 请求中的 formData 文件内容格式、 json、buffer
  • koa-bodypaser 用于解析 非文件内容数据,比如json、表单
  • 如果node业务中涉及 以上两种情况下,建议使用koa-body。
相关实践学习
借助OSS搭建在线教育视频课程分享网站
本教程介绍如何基于云服务器ECS和对象存储OSS,搭建一个在线教育视频课程分享网站。
相关文章
|
3月前
|
弹性计算 运维 Serverless
项目管理和持续集成系统搭建问题之云效流水线支持阿里云产品的企业用户如何解决
项目管理和持续集成系统搭建问题之云效流水线支持阿里云产品的企业用户如何解决
80 1
项目管理和持续集成系统搭建问题之云效流水线支持阿里云产品的企业用户如何解决
|
3月前
|
存储 关系型数据库 MySQL
MySQL——数据库备份上传到阿里云OSS存储
MySQL——数据库备份上传到阿里云OSS存储
168 0
|
13天前
|
安全 Java API
【三方服务集成】最新版 | 阿里云短信服务SMS使用教程(包含支持单双参数模板的工具类,拿来即用!)
阿里云短信服务提供API/SDK和控制台调用方式,支持验证码、通知、推广等短信类型。需先注册阿里云账号并实名认证,然后在短信服务控制台申请资质、签名和模板,并创建AccessKey。最后通过Maven引入依赖,使用工具类发送短信验证码。
【三方服务集成】最新版 | 阿里云短信服务SMS使用教程(包含支持单双参数模板的工具类,拿来即用!)
|
1月前
|
IDE API 开发工具
沉浸式集成阿里云 OpenAPI|Alibaba Cloud API Toolkit for VS Code
Alibaba Cloud API Toolkit for VSCode 是集成了 OpenAPI 开发者门户多项功能的 VSCode 插件,开发者可以通过这个插件方便地查找API文档、进行API调试、插入SDK代码,并配置基础环境设置。我们的目标是缩短开发者在门户和IDE之间的频繁切换,实现API信息和开发流程的无缝结合,让开发者的工作变得更加高效和紧密。
沉浸式集成阿里云 OpenAPI|Alibaba Cloud API Toolkit for VS Code
|
4月前
|
机器学习/深度学习 人工智能 专有云
人工智能平台PAI使用问题之怎么将DLC的数据写入到另一个阿里云主账号的OSS中
阿里云人工智能平台PAI是一个功能强大、易于使用的AI开发平台,旨在降低AI开发门槛,加速创新,助力企业和开发者高效构建、部署和管理人工智能应用。其中包含了一系列相互协同的产品与服务,共同构成一个完整的人工智能开发与应用生态系统。以下是对PAI产品使用合集的概述,涵盖数据处理、模型开发、训练加速、模型部署及管理等多个环节。
|
17天前
|
分布式计算 Java 开发工具
阿里云MaxCompute-XGBoost on Spark 极限梯度提升算法的分布式训练与模型持久化oss的实现与代码浅析
本文介绍了XGBoost在MaxCompute+OSS架构下模型持久化遇到的问题及其解决方案。首先简要介绍了XGBoost的特点和应用场景,随后详细描述了客户在将XGBoost on Spark任务从HDFS迁移到OSS时遇到的异常情况。通过分析异常堆栈和源代码,发现使用的`nativeBooster.saveModel`方法不支持OSS路径,而使用`write.overwrite().save`方法则能成功保存模型。最后提供了完整的Scala代码示例、Maven配置和提交命令,帮助用户顺利迁移模型存储路径。
|
1月前
|
存储 Java 开发工具
【三方服务集成】最新版 | 阿里云OSS对象存储服务使用教程(包含OSS工具类优化、自定义阿里云OSS服务starter)
阿里云OSS(Object Storage Service)是一种安全、可靠且成本低廉的云存储服务,支持海量数据存储。用户可通过网络轻松存储和访问各类文件,如文本、图片、音频和视频等。使用OSS后,项目中的文件上传业务无需在服务器本地磁盘存储文件,而是直接上传至OSS,由其管理和保障数据安全。此外,介绍了OSS服务的开通流程、Bucket创建、AccessKey配置及环境变量设置,并提供了Java SDK示例代码,帮助用户快速上手。最后,展示了如何通过自定义starter简化工具类集成,实现便捷的文件上传功能。
【三方服务集成】最新版 | 阿里云OSS对象存储服务使用教程(包含OSS工具类优化、自定义阿里云OSS服务starter)
|
15天前
|
存储 弹性计算 数据管理
阿里云对象存储OSS收费标准,存储、流量和请求等多个计费项
阿里云对象存储OSS提供按量付费与包年包月两种计费方式,涵盖存储、流量、请求等费用。标准存储按量付费0.09元/GB/月,包年包月40GB起售,价格9元/年。公网流量出方向收费,内网及上传免费。具体费用视使用情况而定,详情见官网。
127 0
|
1月前
|
人工智能 自然语言处理 关系型数据库
阿里云云原生数据仓库 AnalyticDB PostgreSQL 版已完成和开源LLMOps平台Dify官方集成
近日,阿里云云原生数据仓库 AnalyticDB PostgreSQL 版已完成和开源LLMOps平台Dify官方集成。
|
2月前
|
机器学习/深度学习 DataWorks 数据挖掘
基于阿里云Hologres和DataWorks数据集成的方案
基于阿里云Hologres和DataWorks数据集成的方案
70 7