10分钟学会阿里OSS对象存储

news2024/10/5 19:20:36

一. 前言

最近有很多小伙伴问，如果我们要进行大规模的文件存储该怎么做?

其实实现文件存储的技术有很多，如果我们在网上搜索一下，你会发现实现的技术简直是五花八门，比如有一种技术叫FastDFS就可以实现文件存储，但该方案需要自己搭建服务器，非常的麻烦。

实际上现在很多公司都在使用腾讯云或者阿里云技术，比如阿里云就提供了OSS对象存储技术，该技术安全可靠且用起来简单的要死，只需10分钟就可以上手搞定存储。什么？你不信？！那就跟着健哥一步步来，如果健哥带你10分钟搞定文件存储，你就给我点个赞呗！

二. 浅析OSS对象存储作用

在学习OSS具体实现之前，我们先来简单了解一下OSS是怎么个东东吧。

阿里云对象存储OSS，简单地说就是我们花钱在阿里购买一块存储空间，然后我们就可以将图片、音频、视频等各种文件资源存储在对象存储OSS服务器上。接着对象存储OSS服务器就可以供有权限的人员上传、下载、删除这些文件。

所以有了OSS，我们就省去了购买硬件存储服务器、搭建存储服务器、运营管理存储服务器等一系列的繁琐操作了。

有了这些基本的了解之后，我们就可以开始使用OSS了。当然，首先我们得购买OSS服务！

三. 对象存储OSS注册和配置

阿里云对象存储OSS官网地址 :

对象存储 OSS_云存储服务_企业数据管理_存储-阿里云

3.1 注册和登录

进入阿里云官网后，首先就是注册和登录，我们可以使用自己的支付宝账号登录，可以在阿里云手机客户端扫码登录，或者用账号密码登录，总之阿里云提供了多种登录形式。基本上阿里旗下的产品，用自己的支付宝账号都可以通用。

3.2 开通对象存储OSS服务

首先我们找到阿里云的对象存储OSS服务，点击进入。

image.png

点击开通按钮，开通对象存储OSS服务。

image.png

3.3 管理控制台

注册、登录、开通OSS服务后，点击管理控制台，进入控制台界面。

image.png

接着进入到控制台界面。

image.png

这里我们要先创建一个Bucket桶，点击Bucket列表菜单，点击创建Bucket按钮，然后按照下面的内容填写即可。大家要注意，Bucket桶的名称要唯一，不能重复。

image.png

image.png

3.4 使用控制台上传图片

创建完Bucket桶后，我们就可以使用控制台上传文件进行测试了，上传操作如下：

image.png

成功上传一张图片的结果如下：

image.png

四. 代码实现

当然，我们在开发的时候，肯定不会这样手动上传文件，主要是利用代码进行实现。

4.1 搭建项目环境

我们先创建一个项目，名称就叫做aliyunossDemo吧。这里我们当然是利用Maven创建项目，大家记得不要选择使用Maven自带的骨架哦。

接下来在pom.xml中导入依赖包。

<!-- 继承Spring boot工程 -->
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.5.RELEASE</version>
</parent>

<properties>
    <!-- 项目源码及编译输出的编码 -->
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

    <!-- 项目编译JDK版本 -->
    <maven.compiler.source>1.8</maven.compiler.source>
    <maven.compiler.target>1.8</maven.compiler.target>

    <!-- 依赖包版本管理 -->
    <spring.boot.version>2.1.5.RELEASE</spring.boot.version>
    <aliyun-oss-version>3.10.2</aliyun-oss-version>
    <httpcore-verison>4.4.3</httpcore-verison>
    <httpclient-version>4.5.1</httpclient-version>
</properties>

<dependencies>
    <!-- Spring boot starter -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>${spring.boot.version}</version>
    </dependency>
    <dependency>
        <groupId>com.aliyun.oss</groupId>
        <artifactId>aliyun-sdk-oss</artifactId>
        <version>${aliyun-oss-version}</version>
    </dependency>
    <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpcore</artifactId>
        <version>${httpcore-verison}</version>
    </dependency>
    <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpclient</artifactId>
        <version>${httpclient-version}</version>
    </dependency>
</dependencies>
注意，如果你的JDK是1.9或者以上版本，需要加入jaxb相关依赖，其他JDK版本不需要！

<dependency>
    <groupId>javax.xml.bind</groupId>
    <artifactId>jaxb-api</artifactId>
    <version>2.3.1</version>
</dependency>

<dependency>
    <groupId>javax.activation</groupId>
    <artifactId>activation</artifactId>
    <version>1.1.1</version>
</dependency>

<!-- no more than 2.3.3-->
<dependency>
    <groupId>org.glassfish.jaxb</groupId>
    <artifactId>jaxb-runtime</artifactId>
    <version>2.3.3</version>
</dependency>


然后我们在resources目录下创建一个application.yml配置文件。
spring:
  servlet:
    multipart:
      max-file-size: 10MB
      max-request-size: 10MB
  application:
    name: aliyun-oss-demo
server:
  port: 9001
aliyun:
  oss:
    #服务器地址, 我选择的是华北2-北京地址如下
    endpoint: http://oss-cn-beijing.aliyuncs.com
    #子账户名称，在自己控制台账户的Access中查看
    accessKeyId: 填写自己的accessKey
    #子账户密码
    accessKeySecret: 填写自己的accessSecret
    #自己创建的桶的名字
    bucketName: qianfeng-file
   

 接着我们创建一个启动类AliyunOssApplication。
package com.qianfeng;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * 微服务启动类
 * @Author 千锋健哥
 */
@SpringBootApplication
public class AliyunOssApplication {

    public static void main(String[] args) {
        SpringApplication.run(AliyunOssApplication.class, args);
    }
}

4.2 封装工具类

创建com.qianfeng.util包，放入文件操作工具类AliyunOSSUtil。

package com.qianfeng.util;

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClient;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.*;

import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.InputStream;
import java.util.Date;

/**
 * 阿里云OSS上传,下载, 删除文件工具类
 * @Author 千锋健哥
 */
public class AliyunOSSUtil {

    /**
     * byte数组格式上传文件
     * @param endpoint          OSS对外服务的访问域名
     * @param accessKeyId       accessKey账号
     * @param accessKeySecret   accessKey密码
     * @param bucketName        桶名字
     * @param objectName        完整文件名, 例如abc/efg/123.jpg
     * @param content           文件内容, byte数组格式
     * @Author 千锋健哥
     */
    public static void uploadByByteArrayFile(String endpoint,
                                             String accessKeyId,
                                             String accessKeySecret,
                                             String bucketName,
                                             String objectName,
                                             byte[] content) throws Exception {
        // 创建OSSClient实例。
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

        //创建上传请求对象
        PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, new ByteArrayInputStream(content));

        // 上传
        PutObjectResult putObjectResult = ossClient.putObject(putObjectRequest);

        // 关闭OSSClient。
        ossClient.shutdown();
    }

    /**
     * 输入流格式上传文件
     * @param endpoint          OSS对外服务的访问域名
     * @param accessKeyId       accessKey账号
     * @param accessKeySecret   accessKey密码
     * @param bucketName        桶名字
     * @param objectName        完整文件名, 例如abc/efg/123.jpg
     * @param content           文件内容, 输入流格式
     * @Author 千锋健哥
     */
    public static void uploadByInputStreamFile(String endpoint,
                                               String accessKeyId,
                                               String accessKeySecret,
                                               String bucketName,
                                               String objectName,
                                               InputStream content) {

        // 创建OSSClient实例。
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
        // 上传
        ossClient.putObject(bucketName, objectName, content);
        // 关闭OSSClient
        ossClient.shutdown();
    }

    /**
     * byte数组格式上传文件并返回上传后的URL地址
     * @param endpoint          OSS对外服务的访问域名
     * @param accessKeyId       accessKey账号
     * @param accessKeySecret   accessKey密码
     * @param bucketName        桶名字
     * @param objectName        完整文件名, 例如abc/efg/123.jpg
     * @param content           文件内容, byte数组格式
     * @Author 千锋健哥
     */
    public static String uploadImage(String endpoint,
                              String accessKeyId,
                              String accessKeySecret,
                              String bucketName,
                              String objectName,
                              byte[] content)  throws Exception {
        // 创建OSSClient实例。
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
        // 创建上传文件的元信息，可以通过文件元信息设置HTTP header(设置了才能通过返回的链接直接访问)。
        ObjectMetadata objectMetadata = new ObjectMetadata();
        objectMetadata.setContentType("image/jpg");
        // 文件上传
        ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(content), objectMetadata);
        // 设置URL过期时间为1小时。
        Date expiration = new Date(System.currentTimeMillis() + 3600 * 1000);
        //返回url地址
        String url = ossClient.generatePresignedUrl(bucketName, objectName, expiration).toString();
        //关闭OSSClient。
        ossClient.shutdown();
        return url;
    }

    /**
     * 下载文件到本地
     * @param endpoint          OSS对外服务的访问域名
     * @param accessKeyId       accessKey账号
     * @param accessKeySecret   accessKey密码
     * @param bucketName        桶名字
     * @param objectName        完整文件名, 例如abc/efg/123.jpg
     * @param localFile         下载到本地文件目录
     * @Author 千锋健哥
     */
    public static void downFile(String endpoint,
                                String accessKeyId,
                                String accessKeySecret,
                                String bucketName,
                                String objectName,
                                String localFile) throws Exception {
        // 创建OSSClient实例。
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

        // 下载OSS文件到本地文件。如果指定的本地文件存在会覆盖，不存在则新建。
        ossClient.getObject(new GetObjectRequest(bucketName, objectName), new File(localFile));

        // 关闭OSSClient。
        ossClient.shutdown();
    }

    /**
     * 删除文件
     * @param endpoint          OSS对外服务的访问域名
     * @param accessKeyId       accessKey账号
     * @param accessKeySecret   accessKey密码
     * @param bucketName        桶名字
     * @param objectName        完整文件名, 例如abc/efg/123.jpg
     * @Author 千锋健哥
     */
    public static void deleteFile(String endpoint,
                                  String accessKeyId,
                                  String accessKeySecret,
                                  String bucketName,
                                  String objectName) {
        // 创建OSSClient实例。
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

        // 删除文件。如需删除文件夹，请将ObjectName设置为对应的文件夹名称。如果文件夹非空，则需要将文件夹下的所有object删除后才能删除该文件夹。
        ossClient.deleteObject(bucketName, objectName);

        // 关闭OSSClient。
        ossClient.shutdown();
    }
}

4.3 上传文件案例

我们在Controller中实现文件上传。

package com.qianfeng.controller;

import com.qianfeng.util.AliyunOSSUtil;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

/**
 * 文件管理接口
 * 提供文件各种形式上传, 下载, 删除等操作
 * @Author 千锋健哥
 */
@RestController
@RequestMapping("/file")
public class FileManagerController {

    //OSS服务器访问域名
    @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;

    /**
     * byte数组形式上传
     * @param file
     * @Author 千锋健哥
     */
    @PostMapping("/upload1")
    public void upload(@RequestParam("file") MultipartFile file) throws Exception {
        AliyunOSSUtil.uploadByByteArrayFile(endpoint, accessKeyId, accessKeySecret, bucketName, file.getOriginalFilename(), file.getBytes());
    }
    
    /**
     * 输入流形式上传
     * @param file
     * @Author 千锋健哥
     */
    @PostMapping("/upload2")
    public void upload2(@RequestParam("file") MultipartFile file) throws Exception {
        AliyunOSSUtil.uploadByInputStreamFile(endpoint, accessKeyId, accessKeySecret, bucketName, file.getOriginalFilename(), file.getInputStream());
    }
}

4.4 上传图片并返回访问路径案例

在这个案例中给大家展示了如何获取返回的访问路径。

/**
 * 上传图片并返回上传后的URL地址
 * @param file
 * @Author 千锋健哥
 */
@PostMapping("/upload3")
public String upload3(@RequestParam("file") MultipartFile file) throws Exception {
    String url = AliyunOSSUtil.uploadImage(endpoint, accessKeyId, accessKeySecret, bucketName, file.getOriginalFilename(), file.getBytes());
    System.out.println("===千锋健哥===" + url);
    return url;
}

4.5 删除文件案例

这是删除上传后的文件案例。

/**
 * 删除文件
 * @param objName 需要删除的对象名称
 * @Author 千锋健哥
 */
@DeleteMapping("/delete")
public void deleteFile(String objName) {
    AliyunOSSUtil.deleteFile(endpoint, accessKeyId, accessKeySecret, bucketName, objName);
}

千锋教育Java入门全套视频教程(java核心技术，适合java零基础，Java自学必备)

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/857734.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Effective Java笔记（31）利用有限制通配符来提升 API 的灵活性

Effective Java笔记（31）利用有限制通配符来提升 API 的灵活性

参数化类型是不变的&#xff08; invariant &#xff09; 。 换句话说&#xff0c;对于任何两个截然不同的类型 Typel 和 Type2 而言&#xff0c; List<Type1 &#xff1e;既不是 List<Type 2 &#xff1e; 的子类型&#xff0c;也不是它的超类型 。虽然 L ist<String…
阅读更多...
问道管理：零基础学炒股？

问道管理：零基础学炒股？

跟着股市的不断升温&#xff0c;越来越多的人参加到了炒股大军中&#xff0c;希望经过股市赚到更多的金钱。但是关于零根底的新手来说&#xff0c;怎么开始学习炒股成为了一个难题。那么&#xff0c;零根底学炒股真的难吗&#xff1f;怎么更好的入门和学习&#xff1f; 首要&am…
阅读更多...
线性代数(三) 线性方程组

线性代数(三) 线性方程组

前言 如何利用行列式&#xff0c;矩阵求解线性方程组。 线性方程组的相关概念 用矩阵方程表示 齐次线性方程组&#xff1a;Ax0&#xff1b;非齐次线性方程组&#xff1a;Axb. 可以理解 齐次线性方程组 是特殊的 非齐次线性方程组 如何判断线性方程组的解 其中R(A)表示矩阵A的…
阅读更多...
模型、策略和算法

模型、策略和算法

模型(model)、策略(strategy)和算法(algorithm)是统计学习的所有内容. 模型是统计学习的最终结果&#xff0c;即决策函数(decision function) 或条件概率函数 &#xff0c;它被⽤来预测特定问题下&#xff0c;将来未知输⼊的输出结果. 策略是统计学习过程中的产⽣最优模型的评…
阅读更多...
如何使用vue创建一个项目

如何使用vue创建一个项目

1、安装node.js 打开cmd 输入node -v 和npm -v查看电脑是否已经安装了node,js 如果出现以下截图&#xff0c;则说明已经有node.js&#xff0c;可忽略此步 如果没有&#xff0c;则打开官网&#xff0c;下载即可 下载地址&#xff1a;Node.js 下载完成后&#xff0c;打开cmd输…
阅读更多...
漏洞挖掘日记1：企业src某系统存在登录绕过漏洞

漏洞挖掘日记1：企业src某系统存在登录绕过漏洞

&#xff08;一&#xff09;漏洞描述 这个漏洞属于逻辑漏洞&#xff0c;逻辑漏洞是指开发者在开发过程中&#xff0c;实现业务上出现了逻辑上的漏洞。之所以出现逻辑漏洞&#xff0c;是因为一些开发者&#xff0c;在开发过程中&#xff0c;第一考虑是怎么实现功能&#xff0c;…
阅读更多...
OPENCV C++(十)gramm矫正+直方图均衡化

OPENCV C++(十)gramm矫正+直方图均衡化

两者都是只对单通道使用&#xff0c;对多通道的话 就需要分离通道处理再合并通道 两种方法&#xff0c;第一个要运算次数太多了&#xff0c;第二个只需要查表 伽马矫正函数&#xff0c;这里用第二种方法&#xff0c;且写法有点高级 int gammaCorrection(cv::Mat srcMat, cv::…
阅读更多...
路由器和交换机的区别

路由器和交换机的区别

交换机和路由器的区别 交换机实现局域网内点对点通信&#xff0c;路由器实现收集发散&#xff0c;相当于一个猎头实现的中介的功能 路由器属于网络层&#xff0c;可以处理TCP/IP协议&#xff0c;通过IP地址寻址&#xff1b;交换机属于中继层&#xff0c;通过MAC地址寻址(列表)…
阅读更多...
聚观早报 | 真我GT5系列工艺细节曝光；小米MIXFold3定妆照抢先看

聚观早报 | 真我GT5系列工艺细节曝光；小米MIXFold3定妆照抢先看

【聚观365】8月10日消息 真我GT5系列工艺细节曝光小米MIX Fold 3定妆照抢先看360智脑整体能力提升15%科大讯飞智能办公本X3正式发布索尼第二季度营收增长33% 真我GT5系列工艺细节曝光 在此前举办的ChinaJoy2023上&#xff0c;作为手机行业新势力的真我realme携手旗下多款爆款…
阅读更多...
JavaWeb 速通Session

JavaWeb 速通Session

目录 一、Session的引入 1.什么是Session&#xff1f; 2.Session的基本原理 : 3.Session长什么样子&#xff1f; 二、Session的底层机制 1. Session接口相关的方法 : 1 req.getSession() : 2 httpSession.setAttribute(String name, Object val); 3 Object obj httpSessi…
阅读更多...
Python（七十五--总结）列表、字典、元组、集合总结

Python（七十五--总结）列表、字典、元组、集合总结

❤️ 专栏简介&#xff1a;本专栏记录了我个人从零开始学习Python编程的过程。在这个专栏中&#xff0c;我将分享我在学习Python的过程中的学习笔记、学习路线以及各个知识点。 ☀️ 专栏适用人群 &#xff1a;本专栏适用于希望学习Python编程的初学者和有一定编程基础的人。无…
阅读更多...
【Python篇】Python基础语法

【Python篇】Python基础语法

【Python篇】Python基础语法 拖拖拖&#xff0c;能使工作便捷高效的为何要拒绝&#xff0c;作个记录—【蘇小沐】 文章目录 【Python篇】Python基础语法1.实验环境 1、标识符2、Python保留字&#xff08;关键字&#xff1a;不能用作任何标识符名称&#xff09;3、注释1&#x…
阅读更多...
定制全彩LED电子屏的模组类型

定制全彩LED电子屏的模组类型

定制全彩LED电子屏的成功与否很大程度上取决于选择合适的LED模组。LED模组是LED电子屏的基本组成部分&#xff0c;直接影响显示效果、可靠性和性能。什么是LED模组&#xff1f;根据LED屏表面处理的工艺不同&#xff0c;我们可以把其分为插件模组、表贴模组、亚表贴模组、三合一…
阅读更多...
Redis 搭建哨兵集群

Redis 搭建哨兵集群

文章目录 0. 哨兵原理1. 哨兵集群架构2. 准备实例和配置3. 启动4. 测试5. RedisTemplate 的哨兵模式配置地址配置读写分离 在 主从架构 Redis 搭建主从集群 中&#xff0c;一个 slave 节点挂了无影响&#xff0c;但是 master 节点挂了&#xff0c;就无法进行写操作了&#xff0…
阅读更多...
代码随想录算法训练营之JAVA｜第二十五天| 491. 递增子序列

代码随想录算法训练营之JAVA｜第二十五天| 491. 递增子序列

今天是第25天刷leetcode&#xff0c;立个flag&#xff0c;打卡60天。 算法挑战链接 491. 递增子序列https://leetcode.cn/problems/non-decreasing-subsequences/ 第一想法 题目理解&#xff1a;在给定的一个数组中&#xff0c;找出全部的递增列表。要求不能有重复。 这是一…
阅读更多...
Talk | 清华大学交叉信息研究院助理教授许华哲：具身控制中的泛化能力

Talk | 清华大学交叉信息研究院助理教授许华哲：具身控制中的泛化能力

本期为TechBeat人工智能社区第520期线上Talk&#xff01; 北京时间8月9日(周三)20:00&#xff0c;清华大学交叉信息研究院助理教授—许华哲的Talk已准时在TechBeat人工智能社区开播&#xff01; 他与大家分享的主题是: “具身控制中的泛化能力”&#xff0c;从具身控制中视觉外…
阅读更多...
python采集淘宝整店商品 json格式

python采集淘宝整店商品 json格式

竞争优势&#xff1a;通过采集淘宝整店商品&#xff0c;可以获取到同一行业或同一类别的竞争对手的商品信息。这使得你可以更好地了解市场上的产品&#xff0c;了解竞争对手的定价、销售策略和产品特点&#xff0c;从而更好地制定自己的营销策略和定价策略。在竞争激烈的市场中…
阅读更多...
支持对接鸿蒙系统的无线模块及其常见应用介绍

支持对接鸿蒙系统的无线模块及其常见应用介绍

近距离的无线通信得益于万物互联网的快速发展&#xff0c;基于集成部近距离无线连接&#xff0c;为固定和移动设备建立通信的蓝牙技术也已经广泛应用于汽车领域、工业生产及医疗领域。为协助物联网企业终端产品能快速接入鸿蒙生态系统&#xff0c;SKYLAB联手国产芯片厂家研发推…
阅读更多...
爬虫与搜索引擎优化：通过Python爬虫提升网站搜索排名

爬虫与搜索引擎优化：通过Python爬虫提升网站搜索排名

作为一名专业的爬虫程序员&#xff0c;我深知网站的搜索排名对于业务的重要性。在如今竞争激烈的网络世界中&#xff0c;如何让自己的网站在搜索引擎结果中脱颖而出&#xff0c;成为关键。今天&#xff0c;和大家分享一些关于如何通过Python爬虫来提升网站的搜索排名的技巧和实…
阅读更多...
android APP内存优化

android APP内存优化

Android为每个应用分配多少内存 Android出厂后&#xff0c;java虚拟机对单个应用的最大内存分配就确定下来了&#xff0c;超出这个值就会OOM。这个属性值是定义在/system/build.prop文件中. 例如&#xff0c;如下参数 dalvik.vm.heapstartsize8m #起始分配内存 dalvik.vm.…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023