阿里云对象存储服务OSS前后联调

  • 1、为什么要引入阿里云对象存储服务(OSS)?有什么好处?
    • 1.1、什么是对象存储OSS
    • 1.2、OSS工作原理
  • 2、阿里云对象存储-普通上传方式
    • 2.1、时序图
    • 2.2、登录并注册对象存储OSS
  • 3、 通过API接口上传数据对象
    • 3.1、引入依赖
    • 3.2、开通远程RAM访问权限
    • 3.3、编写测试类
    • 3.4、可以看到文件也上传成功
  • 4、 使用阿里云封装的Ali-Cloud OSS SDK进行上传
    • 4.1、引入依赖
    • 4.2、编写application.yml配置文件
    • 4.3、启动类上调用OSSClient方法
    • 4.3、不足
  • 5、阿里云对象存储-服务端签名后直传
    • 5.1、原理图
    • 5.2、controller
    • 5.3、开启Nacos注册和配置中心
    • 5.3、开启服务的注册与发现`@EnableDiscoveryClient`
    • 5.4、配置网关路由协议
  • 6、前后联调
    • 6.1、开启`允许跨域访问`
    • 【注意】

申明: 未经许可,禁止以任何形式转载,若要引用,请标注链接地址
全文共计11577字,阅读大概需要3分钟

1、为什么要引入阿里云对象存储服务(OSS)?有什么好处?

在分布式集群系统中,前端通过浏览器上传图片给服务器存储时存在分库分表的情况,这就涉及到文件存储的情况,在高并发的情况下,考虑到服务器的性能和利用率,都会采用负载均衡来缓解服务器的压力。比如同时有3个商品服务来响应用户的请求,为了减少查询的耗时,采用统一的文件存储来进行读写,可以选择自己搭建文件存储服务器,比如:Fast DFS 、 vsftpd,但是搭建一个专门的服务器的技术和费用成本很高,后期还需要有专人来维护,不是很方便。
目前火热的阿里云对象存储OSS(Object Storage Service)是一个不错的选择。

1.1、什么是对象存储OSS

阿里云对象存储OSS(Object Storage Service)是一款海量、安全、低成本、高可靠的云存储服务。多种存储类型供选择,全面优化存储成本。

OSS具有与平台无关的RESTful API接口,可以在任何应用、任何时间、任何地点存储和访问任意类型的数据。

可以使用阿里云提供的API、SDK接口或者OSS迁移工具轻松地将海量数据移入或移出阿里云OSS。
数据存储到阿里云OSS以后,可以选择标准存储(Standard)作为移动应用、大型网站、图片分享或热点音视频的主要存储方式,也可以选择成本更低、存储期限更长的低频访问存储(Infrequent Access)、归档存储(Archive)、冷归档存储(Cold Archive)作为不经常访问数据的存储方式。

1.2、OSS工作原理

可以将数据以对象(Object)的形式存储在存储空间(Bucket )中,Object指的是一个文件和描述该文件的任何元数据,Bucket是保存Object的容器。

要将Object存储在OSS中,需要先创建Bucket,然后指定Bucket名称以及所在地域(Region)。每个Object都需要定义ObjectName(也称为ObjectKey或者Key),作为Bucket中数据的唯一标识符。Object操作在OSS上具有原子性以及强一致性。

OSS以HTTP RESTful API的形式对外提供服务,访问不同地域需要不同的访问域名(Endpoint)。当请求访问OSS时,OSS通过使用访问密钥(AccessKey Id和AccessKey Secret)对称加密的方法来验证某个请求的发送者身份。

存储空间
存储空间是用户用于存储对象(Object)的容器,所有的对象都必须隶属于某个存储空间。存储空间具有各种配置属性,包括地域、访问权限、存储类型等。用户可以根据实际需求,创建不同类型的存储空间来存储不同的数据。

对象
对象是OSS存储数据的基本单元,也被称为OSS的文件。和传统的文件系统不同,对象没有文件目录层级结构的关系。对象由元信息(Object Meta),用户数据(Data)和文件名(Key)组成,并且由存储空间内部唯一的Key来标识。对象元信息是一组键值对,表示了对象的一些属性,比如最后修改时间、大小等信息,同时用户也可以在元信息中存储一些自定义的信息。

对象名称
在各语言SDK中,ObjectKey、Key以及ObjectName是同一概念,均表示对Object执行相关操作时需要填写的Object名称。例如向某一存储空间上传Object时,ObjectKey表示上传的Object所在存储空间的完整名称,即包含文件后缀在内的完整路径,如填写为abc/efg/123.jpg。

地域
Region表示OSS的数据中心所在物理位置。用户可以根据费用、请求来源等选择合适的地域创建Bucket。一般来说,距离用户更近的Region访问速度更快。详情请参见OSS已经开通的Region。

访问域名
Endpoint表示OSS对外服务的访问域名。OSS以HTTP RESTful API的形式对外提供服务,当访问不同的Region的时候,需要不同的域名。通过内网和外网访问同一个Region所需要的Endpoint也是不同的。例如杭州Region的外网Endpoint是oss-cn-hangzhou.aliyuncs.com,内网Endpoint是oss-cn-hangzhou-internal.aliyuncs.com。具体的内容请参见各个Region对应的Endpoint。

访问密钥
AccessKey简称AK,指的是访问身份验证中用到的AccessKeyId和AccessKeySecret。OSS通过使用AccessKeyId和AccessKeySecret对称加密的方法来验证某个请求的发送者身份。AccessKeyId用于标识用户;AccessKeySecret是用户用于加密签名字符串和OSS用来验证签名字符串的密钥,必须保密。

2、阿里云对象存储-普通上传方式

用户通过自己的简单后台应用服务器将数据以对象的形式存储在OSS上

2.1、时序图

2.2、登录并注册对象存储OSS

官网地址:https://www.aliyun.com/product/oss?spm=5176.19720258.J_3207526240.33.e93976f4FQUO0P

创建bucket

https://oss.console.aliyun.com/overview

填写Bucket的名称,地域,存储类型的基本信息

点进实例后,会看到

先简单测试一下本地上传

可以看到上传成功了


通过URL地址可以直接访问的到:https://gulimall-jerry-jy.oss-cn-hangzhou.aliyuncs.com/5b5e74d0978360a1.jpg

3、 通过API接口上传数据对象

3.1、引入依赖

        <dependency><groupId>com.aliyun.oss</groupId><artifactId>aliyun-sdk-oss</artifactId><version>3.5.0</version></dependency>

3.2、开通远程RAM访问权限

RAM(Resource Acess Management)资源访问控制:RAM 用户是一个身份实体,它通常代表您的组织中需要访问云资源的人员或应用程序。
https://ram.console.aliyun.com/users/new
若开通 Open API 调用访问,请及时保存 AccessKey 信息,页面关闭后将无法再次获取信息。

3.3、编写测试类

 @Testpublic void testUpload() {// Endpoint以华东1(杭州)为例,其它Region请按实际情况填写。String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";// 阿里云账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维,请登录RAM控制台创建RAM用户。String accessKeyId = "LTAI5tQRCX6FBx77qqhepLo9";String accessKeySecret = "UGvWNebBJusYPTIv9kRfBsEckthRqF";// 填写Bucket名称,例如examplebucket。String bucketName = "gulimall-jerry-jy";// 填写Object完整路径,完整路径中不能包含Bucket名称,例如exampledir/exampleobject.txt。String objectName = "9.png";// 填写本地文件的完整路径,例如D:\\localpath\\examplefile.txt。// 如果未指定本地路径,则默认从示例程序所属项目对应本地路径中上传文件流。String filePath = "C:\\Users\\15718\\Desktop\\png\\9.png";// 创建OSSClient实例。OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);try {InputStream inputStream = new FileInputStream(filePath);// 创建PutObject请求。ossClient.putObject(bucketName, objectName, inputStream);} 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());} catch (FileNotFoundException e) {e.printStackTrace();} finally {if (ossClient != null) {System.out.println("上传完成!");ossClient.shutdown();}}}

3.4、可以看到文件也上传成功

可以通过URL访问图片:https://gulimall-jerry-jy.oss-cn-hangzhou.aliyuncs.com/9.png

4、 使用阿里云封装的Ali-Cloud OSS SDK进行上传

4.1、引入依赖

        <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alicloud-oss</artifactId></dependency>

4.2、编写application.yml配置文件

spring:cloud: alicloud:access-key: LTAI5tQRCX6FBx77qqhepLo9secret-key: UGvWNebBJusYPTIv9kRfBsEckthRqFoss:endpoint: oss-cn-hangzhou.aliyuncs.com

4.3、启动类上调用OSSClient方法

可以看到控制台打印了【上传成功】

去阿里云控制台检查下是否成功

通过【URL】https://gulimall-jerry-jy.oss-cn-hangzhou.aliyuncs.com/8.png
也能正常访问,证明上传成功

4.3、不足

通过我们自己的应用服务器上传数据到OSS,如果前端访问的数据量过大,过造成应用服务器的性能瓶颈,最好的办法是采用服务端签名后直传

5、阿里云对象存储-服务端签名后直传

5.1、原理图

5.2、controller

package com.jerry.gulimall.thirdparty.controller;import com.aliyun.oss.OSS;
import com.aliyun.oss.common.utils.BinaryUtil;
import com.aliyun.oss.model.MatchMode;
import com.aliyun.oss.model.PolicyConditions;
import com.jerry.common.utils.R;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.beans.factory.annotation.Value;
import java.util.Date;
import java.util.Map;
import java.text.SimpleDateFormat;
import java.util.LinkedHashMap;/*** @author 金阳* @description* @create 2022-07-22 1:24*/@RestController
public class OssController {@AutowiredOSS ossClient;@Value("${spring.cloud.alicloud.oss.endpoint}")private String endpoint;@Value("${spring.cloud.alicloud.oss.bucket}")private String bucket;@Value("${spring.cloud.alicloud.access-key}")private String accessId;@RequestMapping("/oss/policy")public R policy() {//https://gulimall-hello.oss-cn-beijing.aliyuncs.com/hahaha.jpgString host = "https://" + bucket + "." + endpoint; // host的格式为 bucketname.endpoint// callbackUrl为 上传回调服务器的URL,请将下面的IP和Port配置为您自己的真实信息。
//        String callbackUrl = "http://88.88.88.88:8888";String format = new SimpleDateFormat("yyyy-MM-dd").format(new Date());String dir = format + "/"; // 用户上传文件时指定的前缀。Map<String, String> respMap = null;try {long expireTime = 30;long expireEndTime = System.currentTimeMillis() + expireTime * 1000;Date expiration = new Date(expireEndTime);PolicyConditions policyConds = new PolicyConditions();policyConds.addConditionItem(PolicyConditions.COND_CONTENT_LENGTH_RANGE, 0, 1048576000);policyConds.addConditionItem(MatchMode.StartWith, PolicyConditions.COND_KEY, dir);String postPolicy = ossClient.generatePostPolicy(expiration, policyConds);byte[] binaryData = postPolicy.getBytes("utf-8");String encodedPolicy = BinaryUtil.toBase64String(binaryData);String postSignature = ossClient.calculatePostSignature(postPolicy);respMap = new LinkedHashMap<String, String>();respMap.put("accessid", accessId);respMap.put("policy", encodedPolicy);respMap.put("signature", postSignature);respMap.put("dir", dir);respMap.put("host", host);respMap.put("expire", String.valueOf(expireEndTime / 1000));// respMap.put("expire", formatISO8601Date(expiration));} catch (Exception e) {// Assert.fail(e.getMessage());System.out.println(e.getMessage());}return R.ok().put("data",respMap);}
}

5.3、开启Nacos注册和配置中心

编写application.yml

spring:cloud:nacos:discovery:server-addr: 127.0.0.1:8848alicloud:access-key: LTAI5tQRCX6FBx77qqhepLo9secret-key: UGvWNebBJusYPTIv9kRfBsEckthRqFoss:endpoint: oss-cn-hangzhou.aliyuncs.combucket: gulimall-jerry-jyapplication:name: gulimall-third-partyserver:port: 30000

配置bootstrap.properties

spring.application.name=gulimall-third-party
spring.cloud.nacos.config.server-addr=127.0.0.1:8848
spring.cloud.nacos.config.namespace=0b0b4ca3-539e-44ed-ab10-1f9ac6af6458spring.cloud.nacos.config.ext-config[0].data-id=oss.yml
spring.cloud.nacos.config.ext-config[0].group=DEFAULT_GROUP
spring.cloud.nacos.config.ext-config[0].refresh=true

完成Nacos Server配置

配置详情

5.3、开启服务的注册与发现@EnableDiscoveryClient

5.4、配置网关路由协议

        - id: third_party_routeuri: lb://gulimall-third-partypredicates:- Path=/api/thirdparty/**filters:- RewritePath=/api/thirdparty/(?<segment>.*),/$\{segment}

访问http://localhost:88/api/thirdparty/oss/policy可以看到能响应json数据,说明服务的注册与发现功能正常

6、前后联调

6.1、开启允许跨域访问

要允许浏览器提交的所有的请求和允许所有的请求头访问OSS

先启动后端项目,再启动前端项目,上传我们的本地图片,可以看到是,图片回显是成功的

去阿里云控制台检查,可以看到能正常接受用户上传的图片

【注意】


图片预览没用回显,发现是
请求网址: https://gulimall-jerry-jy.https//oss-cn-hangzhou.aliyuncs.com/2022-07-22/41168c92-c4b5-4be0-8f5d-8bcade308477_1.png
这里多了一个https

经检查:原因是在application.yml中的endpoint配置多了一个https://应该去掉

Nacos Server中的oss.yml记得也要修改

再次上传图片,发送请求,能正常回显了,响应头也是正常

阿里云对象存储服务OSS前后联调相关推荐

  1. SpringBoot整合——阿里云对象存储(OSS)

    SpringBoot整合--阿里云对象存储 1 OSS介绍 在开发应用的过程中,我们经常会有用户需要实名认证之后才能访问的需求. 用户认证需要上传证件图片.首页轮播也需要上传图片,因此我们要做文件服务 ...

  2. 阿里云对象存储OSS之通过URL形式进行图片处理

    什么是OSS 阿里云对象存储服务(Object Storage Service,简称 OSS),是阿里云提供的海量.安全.低成本.高可靠的云存储服务.它具有与平台无关的RESTful API接口,能够 ...

  3. C# 阿里云对象存储OSS创建、删除、上传代码实现

    一.开始接入 1.Nuget安装Aliyun.OSS.SDK: 2.代码实现: /// <summary> /// 阿里云对象存储服务 /// </summary> publi ...

  4. 阿里云对象存储OSS竟如此简单

    1.1:什么是阿里云的OSS 阿里云对象存储服务(Object Storage Service,简称OSS),是阿里云对外提供的海量.安全.低成本.高可靠的云存储服务.您可以通过本文档提供的简单的RE ...

  5. 五个问答,告诉你阿里云对象存储如何助力钉钉战胜业务洪峰

    "基于OSS在弹性扩容.跨省容灾.多租户管理以及传输加速方面的基础能力,钉钉在此次战役过程中,实现了一键切换写入区域,拆分业务到多个区域的功能,同时钉钉在跨区域的图片处理.文档预览的并发处理 ...

  6. 阿里云对象存储OSS服务开通

    一.阿里云对象存储OSS服务开通 1.开通"对象存储OSS"服务 2.进入管理控制台 二.控制台使用 1.创建Bucket 命名:srb-file 读写权限:公共读 2.上传默认头 ...

  7. 阿里云对象存储OSS与文件存储NAS的区别

    一.简介 应用场景:选择一款存储产品,面向文档数据的存取,不会涉及到数据处理. 产品选型主要从OSS和NAS中选择一款,满足文档存储的需求. 二.NAS优缺点 NAS 是一种采用直接与网络介质相连的特 ...

  8. 阿里云对象存储OSS(Object Storage Service)

    文章目录 简介 endpoint:阿里云服务部署的地区位置 见解 开发步骤 配置文件 utils层(读取全局配置文件并赋值给类变量) service层 impl(基于oss驱动sdk实现类) cont ...

  9. 坑!阿里云对象存储OSS收费细则不只是存储还有其他扣费项

    阿里云对象存储OSS怎么收费?以为只收取存储费用,不只是存储费还有流量.跨区域复制.流量费.请求费.数据处理费用.对象标签费用.传输加速费用等,快看看别让钱花得不清不楚,云吞铺子来详细说下阿里云对象存 ...

最新文章

  1. Oracle10g 管理系统全局区(SGA)
  2. 第四课:算法效率的度量和存储空间需求
  3. 使用Image类提示内存不足问题
  4. 【前端分享】jQuery.lazyload详解(转)
  5. 如何告别“芯繁魂乱”难题?这个 OS 来支招!
  6. 【信息系统项目管理师】案例分析高频记忆考点汇总
  7. 在电脑端微信或低版本ios,使用微信自带浏览器打开网页不显示
  8. 电脑显示计算机资源不足 新用户无法登录,三招解决win10电脑提示资源不足的问题...
  9. 浙江大学python程序设计(陈春晖、翁恺、季江民)习题答案
  10. 腾讯云轻量与CVM内网互通骚操作
  11. UVC webcam驱动添加分辨率
  12. 中国天眼发现地外文明可疑信号,马斯克称星舰7月开始轨道试飞,网信办:APP不得强制要求用户同意处理个人信息,今日更多大新闻在此...
  13. 客户服务管理:客户服务管理技巧
  14. 考试安全平台_ER图_功能图_数据字典_数据库脚本
  15. 线性代数复习CH1:行列式
  16. ES2对数据的基本操作
  17. 零基础学习CANoe Panel(14)——二极管( LED Control )和液晶屏(LCD Control)
  18. 元宇宙给商业世界带来哪些机会?
  19. 雷达干扰模拟器3-信号侦察
  20. HC32f460驱动ht1621

热门文章

  1. 68dva的相关知识
  2. AiDD AI+软件研发数字峰会开启编程新纪元
  3. 安装ENVI5.3:the installation of MSVC_2010_SP1_x64_32bit has failed
  4. 微信小程序云开发日记类日记记录分享动态
  5. 优盘启动盘恢复为普通优盘
  6. Android apps 拍立知-功能实现2(相机/选择相册及图像识别调用)
  7. http协议1.x/2.x区别
  8. 【AI框架】MMDetection3D 使用指南
  9. win7matlab2016启动闪退,大白菜修复win7系统启动matlab出现闪退的图文方案
  10. nvme装系统不能自引导_怎么让老电脑实现UEFI启动NVME SSD固态硬盘进系统方法