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

阿里云OSS对象存储简单上手(超级详细,针对小白)

首先:文件上传实现理论

因为在新增菜品时,需要上传菜品对应的图片(文件),包括后绪其它功能也会使用到文件上传,故要实现通用的文件上传接口。

文件上传,是指将本地图片、视频、音频等文件上传到服务器上,可以供其他用户浏览或下载的过程。文件上传在项目中应用非常广泛,我们经常发抖音、发朋友圈都用到了文件上传功能。

实现文件上传服务,需要有存储的支持,那么我们的解决方案将以下几种:

  1. 直接将图片保存到服务的硬盘(springmvc中的文件上传)
    1. 优点:开发便捷,成本低
    2. 缺点:扩容困难
  2. 使用分布式文件系统进行存储
    1. 优点:容易实现扩容
    2. 缺点:开发复杂度稍大(有成熟的产品可以使用,比如:FastDFS,MinIO)
  3. 使用第三方的存储服务(例如OSS)
    1. 优点:开发简单,拥有强大功能,免维护
    2. 缺点:付费

在本项目选用阿里云的OSS服务进行文件存储。(前面课程已学习过阿里云OSS,不再赘述)

image-20221121174942235

实现步骤:

1). 定义OSS相关配置

在sky-server模块

application-dev.yml

sky:alioss:endpoint: oss-cn-hangzhou.aliyuncs.comaccess-key-id: LTAI5tPeFLzsPPT8gG3LPW64access-key-secret: U6k1brOZ8gaOIXv3nXbulGTUzy6Pd7bucket-name: sky-take-out

application.yml

spring:profiles:active: dev    #设置环境
sky:alioss:endpoint: ${sky.alioss.endpoint}access-key-id: ${sky.alioss.access-key-id}access-key-secret: ${sky.alioss.access-key-secret}bucket-name: ${sky.alioss.bucket-name}

2). 读取OSS配置

在sky-common模块中,已定义

package com.sky.properties;import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;@Component
@ConfigurationProperties(prefix = "sky.alioss")
@Data
public class AliOssProperties {private String endpoint;private String accessKeyId;private String accessKeySecret;private String bucketName;}

3). 生成OSS工具类对象

在sky-server模块

package com.sky.config;import com.sky.properties.AliOssProperties;
import com.sky.utils.AliOssUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 配置类,用于创建AliOssUtil对象*/
@Configuration
@Slf4j
public class OssConfiguration {@Bean@ConditionalOnMissingBeanpublic AliOssUtil aliOssUtil(AliOssProperties aliOssProperties){log.info("开始创建阿里云文件上传工具类对象:{}",aliOssProperties);return new AliOssUtil(aliOssProperties.getEndpoint(),aliOssProperties.getAccessKeyId(),aliOssProperties.getAccessKeySecret(),aliOssProperties.getBucketName());}
}

其中,AliOssUtil.java已在sky-common模块中定义

package com.sky.utils;import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import java.io.ByteArrayInputStream;@Data
@AllArgsConstructor
@Slf4j
public class AliOssUtil {private String endpoint;private String accessKeyId;private String accessKeySecret;private String bucketName;/*** 文件上传** @param bytes* @param objectName* @return*/public String upload(byte[] bytes, String objectName) {// 创建OSSClient实例。OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);try {// 创建PutObject请求。ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(bytes));} catch (OSSException oe) {System.out.println("Caught an OSSException, which means your request made it to OSS, "+ "but was rejected with an error response for some reason.");System.out.println("Error Message:" + oe.getErrorMessage());System.out.println("Error Code:" + oe.getErrorCode());System.out.println("Request ID:" + oe.getRequestId());System.out.println("Host ID:" + oe.getHostId());} catch (ClientException ce) {System.out.println("Caught an ClientException, which means the client encountered "+ "a serious internal problem while trying to communicate with OSS, "+ "such as not being able to access the network.");System.out.println("Error Message:" + ce.getMessage());} finally {if (ossClient != null) {ossClient.shutdown();}}//文件访问路径规则 https://BucketName.Endpoint/ObjectNameStringBuilder stringBuilder = new StringBuilder("https://");stringBuilder.append(bucketName).append(".").append(endpoint).append("/").append(objectName);log.info("文件上传到:{}", stringBuilder.toString());return stringBuilder.toString();}
}

4). 定义文件上传接口

在sky-server模块中定义接口

package com.sky.controller.admin;import com.sky.constant.MessageConstant;
import com.sky.result.Result;
import com.sky.utils.AliOssUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;import java.io.IOException;
import java.util.UUID;/*** 通用接口*/
@RestController
@RequestMapping("/admin/common")
@Api(tags = "通用接口")
@Slf4j
public class CommonController {@Autowiredprivate AliOssUtil aliOssUtil;/*** 文件上传* @param file* @return*/@PostMapping("/upload")@ApiOperation("文件上传")public Result<String> upload(MultipartFile file){log.info("文件上传:{}",file);try {//原始文件名String originalFilename = file.getOriginalFilename();//截取原始文件名的后缀   dfdfdf.pngString extension = originalFilename.substring(originalFilename.lastIndexOf("."));//构造新文件名称String objectName = UUID.randomUUID().toString() + extension;//文件的请求路径String filePath = aliOssUtil.upload(file.getBytes(), objectName);return Result.success(filePath);} catch (IOException e) {log.error("文件上传失败:{}", e);}return Result.error(MessageConstant.UPLOAD_FAILED);}
}

然后:获取配置值

一、注册阿里云账号(略)

二、进入控制台

image-20250801081801442

三、点击左上角三条杠

image-20250801081813188

四、在搜索框搜索“对象存储”并进入

image-20250801081823078

五、开通OSS

新手这里是没开通的,需要下单进行开通,直接支付0元即可下单,免费使用100年。我之前是开通过了就不再进行开通。

六、开通之后,创建Bucket

image-20250801081835528
image-20250801081854835

七、点击进入Bucket

image-20250801081905509

八、进来后是这样的

image-20250801081917425
✨✨到这里Bucket就创建完毕了,如果是要使用Bucket进行文件上传,那么可以继续看下去✨✨

九、获取密钥

image-20250801081925947

十、点击继续使用就行

image-20250801081934480

十一、点击创建AccessKey

image-20250801081943695

十二、再次点击允许

image-20250801081952579

十三、选择验证方式并验证

image-20250801082000793

十四、验证完成后会自动获取密钥信息(一定保存好!!!)

image-20250801082008631
下面是使用AccessKey的步骤,我的朋友,请耐心点噢,不要觉得我啰嗦呜呜呜~🥰🥰

十五、我们回到这个页面,找到下载SDK选项并进入

image-20250801082017753

十六、由于我是写Java,所以我选择第一个,具体情况看自己,然后点击查看文档

image-20250801082028163

十七、在文档中心打开

image-20250801082039793

十八、自己可以根据具体情况选择一个示例代码进行参考,我自己是要做一个上传图片文件的功能,所以我参考如图所示

image-20250801082053505

十九、将上一步拿到的endpoint和其他信息在application.yml配置文件中进行OSS配置

image-20250801082104193
附上代码:

aliyun:oss:endpoint: 自己选择的创建Bucket时所在区域的结点(我的是北京)accessKeyId: 填自己的accessKeySecret: 填自己的bucketName: 自己的Bucket名字

注意!!
image-20250801082115281

二十、再创建工具类util(按需操作)

附上代码:

package cn.wolfcode.util;import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;import java.io.IOException;
import java.io.InputStream;
import java.util.UUID;@Component//当你不确定使用哪个特定的注解时,可以使用 @Component 注解
public class AliOSSUtils {//获取配置信息@Value("${aliyun.oss.endpoint}")private String endpoint;@Value("${aliyun.oss.accessKeyId}")private String accessKeyId;@Value("${aliyun.oss.accessKeySecret}")private String accessKeySecret;@Value("${aliyun.oss.bucketName}")private String bucketName;//上传图片的方法public String upload(MultipartFile multipartFile) throws IOException {//获取上传文件输入流InputStream inputStream = multipartFile.getInputStream();//避免文件覆盖 更换文件名String originalFilename = multipartFile.getOriginalFilename();String newName = UUID.randomUUID().toString() +originalFilename.substring(originalFilename.lastIndexOf("."));//创建OSSClient实例OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);//推送数据到OSSossClient.putObject(bucketName, newName, inputStream);//还原文件名//https://sjt--java63--oss.oss-cn-beijing.aliyuncs.com/img/%E6%8E%A5%E5%8F%A3.txtStringBuffer stringBuffer = new StringBuffer(endpoint);//将endpoint放入stringBuffer 方便字符串插入 因为String是不可变的String url = stringBuffer.insert(8, bucketName + ".").append("/").append(newName).toString();return url;}}

二十一、实现上传图片功能

image-20250801082130788

附上代码:

package cn.wolfcode.controller;import cn.wolfcode.domain.Result;
import cn.wolfcode.util.AliOSSUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;import java.io.IOException;@RestController
@Slf4j
public class UploadController {@Autowiredprivate AliOSSUtils aliOSSUtils;@PostMapping("/upload")public Result upload(MultipartFile image) throws IOException {log.info("文件上传{}",image.getOriginalFilename());String upload = aliOSSUtils.upload(image);return Result.success(upload);}}

二十二、阿里云OSS也成功上传

image-20250801082152455
完结撒花!!!🎈🎈🎈

http://www.sczhlp.com/news/2993/

相关文章:

  • 一种CAN接口电路的隔离方案
  • 热卷 2510
  • P5405 [CTS2019] 氪金手游 题解
  • 阿里云OSS对象存储简单使用(超级详细,针对小白上手!!)_阿里云oss使用教程-CSDN博客-2025-08-01 08_06_12
  • 浅谈后缀自动机
  • 多Agent协作入门:移交编排模式
  • Oxygen Forensic Detective 17.3.1 新增功能简介 - 一体化数字取证软件
  • ARM物联网漏洞利用实验室在Blackhat USA 2017首次亮相
  • 谁在给字节赚钱:⌈巨量⌋一出,谁与争锋?
  • 大模型时代,这才是AI的“隐形心脏”
  • nodejs第一天
  • 题解 P8883 幻想中成为原神
  • 薄膜铌酸锂量子光子学:回顾与展望
  • 一步一步学习使用LiveBindings(1) 使用向导无代码创建基于绑定的FireMonkey应用程序
  • 近几年常见的一类二分套路题,从上古时代 01 规划的基础原理扩展
  • 记梦
  • SILENTTRINITY最新部署指南:现代C2框架快速搭建
  • 第十天
  • 第九天
  • Codeforces Round 1040 (Div. 2)(A~D,E1赛后写出)
  • Codeforces Round 1040 (Div. 2)
  • 更改_Rootmotion控制角色移动
  • RD6006/6012 如何给电池充电
  • 通过st7789v + cst816t实现nrf52840的zephyr LVGL的显示和触摸
  • 面试
  • 第十五章 设计谷歌云盘
  • 快速数论变换(NTT)
  • window用git将本地文件上传到远程服务器 - IT
  • JOISC2016
  • LeetCode 2614[对角线上的质数]