• 文件上传很难搞？10分钟带你学会阿里云OSS对象存储

    一. 前言

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

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

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

    二. 浅析OSS对象存储作用

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

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

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

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

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

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

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

    3.1 注册和登录

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

    3.2 开通对象存储OSS服务

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

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

    3.3. 管理控制台

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

    接着进入到控制台界面。

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

     3.4 使用控制台上传图片

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

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

    四. 代码实现

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

    4.1 搭建项目环境

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

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

    2. <parent>
    3.     <groupId>org.springframework.bootgroupId>
    4.     <artifactId>spring-boot-starter-parentartifactId>
    5.     <version>2.1.5.RELEASEversion>
    6. parent>
    7.  
    8. <properties>
    9.     
    10.     <project.build.sourceEncoding>UTF-8project.build.sourceEncoding>
    11.     <project.reporting.outputEncoding>UTF-8project.reporting.outputEncoding>
    12.  
    13.     
    14.     <maven.compiler.source>1.8maven.compiler.source>
    15.     <maven.compiler.target>1.8maven.compiler.target>
    16.  
    17.     
    18.     <spring.boot.version>2.1.5.RELEASEspring.boot.version>
    19.     <aliyun-oss-version>3.10.2aliyun-oss-version>
    20.     <httpcore-verison>4.4.3httpcore-verison>
    21.     <httpclient-version>4.5.1httpclient-version>
    22. properties>
    23.  
    24. <dependencies>
    25.     
    26.     <dependency>
    27.         <groupId>org.springframework.bootgroupId>
    28.         <artifactId>spring-boot-starter-webartifactId>
    29.         <version>${spring.boot.version}version>
    30.     dependency>
    31.     <dependency>
    32.         <groupId>com.aliyun.ossgroupId>
    33.         <artifactId>aliyun-sdk-ossartifactId>
    34.         <version>${aliyun-oss-version}version>
    35.     dependency>
    36.     <dependency>
    37.         <groupId>org.apache.httpcomponentsgroupId>
    38.         <artifactId>httpcoreartifactId>
    39.         <version>${httpcore-verison}version>
    40.     dependency>
    41.     <dependency>
    42.         <groupId>org.apache.httpcomponentsgroupId>
    43.         <artifactId>httpclientartifactId>
    44.         <version>${httpclient-version}version>
    45.     dependency>
    46. dependencies>

    注意，如果你的JDK是1.9或者以上版本，需要加入jaxb相关依赖，其他JDK版本不需要！

    1. <dependency>
    2.     <groupId>javax.xml.bindgroupId>
    3.     <artifactId>jaxb-apiartifactId>
    4.     <version>2.3.1version>
    5. dependency>
    6.  
    7. <dependency>
    8.     <groupId>javax.activationgroupId>
    9.     <artifactId>activationartifactId>
    10.     <version>1.1.1version>
    11. dependency>
    12.  
    14. <dependency>
    15.     <groupId>org.glassfish.jaxbgroupId>
    16.     <artifactId>jaxb-runtimeartifactId>
    17.     <version>2.3.3version>
    18. dependency>

    然后我们在resources目录下创建一个application.yml配置文件。

    1. spring:
    2.   servlet:
    3.     multipart:
    4.       max-file-size: 10MB
    5.       max-request-size: 10MB
    6.   application:
    7.     name: aliyun-oss-demo
    8. server:
    9.   port: 9001
    10. aliyun:
    11.   oss:
    12.     #服务器地址, 我选择的是华北2-北京地址如下
    13.     endpoint: http://oss-cn-beijing.aliyuncs.com
    14.     #子账户名称，在自己控制台账户的Access中查看
    15.     accessKeyId: 填写自己的accessKey
    16.     #子账户密码
    17.     accessKeySecret: 填写自己的accessSecret
    18.     #自己创建的桶的名字
    19.     bucketName: qianfeng-file

    接着我们创建一个启动类AliyunOssApplication。

    1. package com.qianfeng;
    2.  
    3. import org.springframework.boot.SpringApplication;
    4. import org.springframework.boot.autoconfigure.SpringBootApplication;
    5.  
    6. /**
    7.  * 微服务启动类
    8.  * @Author 壹哥
    9.  */
    10. @SpringBootApplication
    11. public class AliyunOssApplication {
    12.  
    13.     public static void main(String[] args) {
    14.         SpringApplication.run(AliyunOssApplication.class, args);
    15.     }
    16. }

    4.2 封装工具类

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

    1. package com.qianfeng.util;
    2.  
    3. import com.aliyun.oss.OSS;
    4. import com.aliyun.oss.OSSClient;
    5. import com.aliyun.oss.OSSClientBuilder;
    6. import com.aliyun.oss.model.*;
    7.  
    8. import java.io.ByteArrayInputStream;
    9. import java.io.File;
    10. import java.io.InputStream;
    11. import java.util.Date;
    12.  
    13. /**
    14.  * 阿里云OSS上传,下载, 删除文件工具类
    15.  * @Author 壹哥
    16.  */
    17. public class AliyunOSSUtil {
    18.  
    19.     /**
    20.      * byte数组格式上传文件
    21.      * @param endpoint          OSS对外服务的访问域名
    22.      * @param accessKeyId       accessKey账号
    23.      * @param accessKeySecret   accessKey密码
    24.      * @param bucketName        桶名字
    25.      * @param objectName        完整文件名, 例如abc/efg/123.jpg
    26.      * @param content           文件内容, byte数组格式
    27.      * @Author 壹哥
    28.      */
    29.     public static void uploadByByteArrayFile(String endpoint,
    30.                                              String accessKeyId,
    31.                                              String accessKeySecret,
    32.                                              String bucketName,
    33.                                              String objectName,
    34.                                              byte[] content) throws Exception {
    35.         // 创建OSSClient实例。
    36.         OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    37.  
    38.         //创建上传请求对象
    39.         PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, new ByteArrayInputStream(content));
    40.  
    41.         // 上传
    42.         PutObjectResult putObjectResult = ossClient.putObject(putObjectRequest);
    43.  
    44.         // 关闭OSSClient。
    45.         ossClient.shutdown();
    46.     }
    47.  
    48.     /**
    49.      * 输入流格式上传文件
    50.      * @param endpoint          OSS对外服务的访问域名
    51.      * @param accessKeyId       accessKey账号
    52.      * @param accessKeySecret   accessKey密码
    53.      * @param bucketName        桶名字
    54.      * @param objectName        完整文件名, 例如abc/efg/123.jpg
    55.      * @param content           文件内容, 输入流格式
    56.      * @Author 壹哥
    57.      */
    58.     public static void uploadByInputStreamFile(String endpoint,
    59.                                                String accessKeyId,
    60.                                                String accessKeySecret,
    61.                                                String bucketName,
    62.                                                String objectName,
    63.                                                InputStream content) {
    64.  
    65.         // 创建OSSClient实例。
    66.         OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    67.         // 上传
    68.         ossClient.putObject(bucketName, objectName, content);
    69.         // 关闭OSSClient
    70.         ossClient.shutdown();
    71.     }
    72.  
    73.     /**
    74.      * byte数组格式上传文件并返回上传后的URL地址
    75.      * @param endpoint          OSS对外服务的访问域名
    76.      * @param accessKeyId       accessKey账号
    77.      * @param accessKeySecret   accessKey密码
    78.      * @param bucketName        桶名字
    79.      * @param objectName        完整文件名, 例如abc/efg/123.jpg
    80.      * @param content           文件内容, byte数组格式
    81.      * @Author 壹哥
    82.      */
    83.     public static String uploadImage(String endpoint,
    84.                               String accessKeyId,
    85.                               String accessKeySecret,
    86.                               String bucketName,
    87.                               String objectName,
    88.                               byte[] content)  throws Exception {
    89.         // 创建OSSClient实例。
    90.         OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    91.         // 创建上传文件的元信息，可以通过文件元信息设置HTTP header(设置了才能通过返回的链接直接访问)。
    92.         ObjectMetadata objectMetadata = new ObjectMetadata();
    93.         objectMetadata.setContentType("image/jpg");
    94.         // 文件上传
    95.         ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(content), objectMetadata);
    96.         // 设置URL过期时间为1小时。
    97.         Date expiration = new Date(System.currentTimeMillis() + 3600 * 1000);
    98.         //返回url地址
    99.         String url = ossClient.generatePresignedUrl(bucketName, objectName, expiration).toString();
    100.         //关闭OSSClient。
    101.         ossClient.shutdown();
    102.         return url;
    103.     }
    104.  
    105.     /**
    106.      * 下载文件到本地
    107.      * @param endpoint          OSS对外服务的访问域名
    108.      * @param accessKeyId       accessKey账号
    109.      * @param accessKeySecret   accessKey密码
    110.      * @param bucketName        桶名字
    111.      * @param objectName        完整文件名, 例如abc/efg/123.jpg
    112.      * @param localFile         下载到本地文件目录
    113.      * @Author 壹哥
    114.      */
    115.     public static void downFile(String endpoint,
    116.                                 String accessKeyId,
    117.                                 String accessKeySecret,
    118.                                 String bucketName,
    119.                                 String objectName,
    120.                                 String localFile) throws Exception {
    121.         // 创建OSSClient实例。
    122.         OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    123.  
    124.         // 下载OSS文件到本地文件。如果指定的本地文件存在会覆盖，不存在则新建。
    125.         ossClient.getObject(new GetObjectRequest(bucketName, objectName), new File(localFile));
    126.  
    127.         // 关闭OSSClient。
    128.         ossClient.shutdown();
    129.     }
    130.  
    131.     /**
    132.      * 删除文件
    133.      * @param endpoint          OSS对外服务的访问域名
    134.      * @param accessKeyId       accessKey账号
    135.      * @param accessKeySecret   accessKey密码
    136.      * @param bucketName        桶名字
    137.      * @param objectName        完整文件名, 例如abc/efg/123.jpg
    138.      * @Author 壹哥
    139.      */
    140.     public static void deleteFile(String endpoint,
    141.                                   String accessKeyId,
    142.                                   String accessKeySecret,
    143.                                   String bucketName,
    144.                                   String objectName) {
    145.         // 创建OSSClient实例。
    146.         OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    147.  
    148.         // 删除文件。如需删除文件夹，请将ObjectName设置为对应的文件夹名称。如果文件夹非空，则需要将文件夹下的所有object删除后才能删除该文件夹。
    149.         ossClient.deleteObject(bucketName, objectName);
    150.  
    151.         // 关闭OSSClient。
    152.         ossClient.shutdown();
    153.     }
    154. }

    4.3 上传文件案例

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

    1. package com.qianfeng.controller;
    2.  
    3. import com.qianfeng.util.AliyunOSSUtil;
    4. import org.springframework.beans.factory.annotation.Value;
    5. import org.springframework.web.bind.annotation.*;
    6. import org.springframework.web.multipart.MultipartFile;
    7.  
    8. /**
    9.  * 文件管理接口
    10.  * 提供文件各种形式上传, 下载, 删除等操作
    11.  * @Author 壹哥
    12.  */
    13. @RestController
    14. @RequestMapping("/file")
    15. public class FileManagerController {
    16.  
    17.     //OSS服务器访问域名
    18.     @Value("${aliyun.oss.endpoint}")
    19.     private String endpoint;
    20.  
    21.     //子账户名
    22.     @Value("${aliyun.oss.accessKeyId}")
    23.     private String accessKeyId;
    24.  
    25.     //子账户密码
    26.     @Value("${aliyun.oss.accessKeySecret}")
    27.     private String accessKeySecret;
    28.  
    29.     //桶名字
    30.     @Value("${aliyun.oss.bucketName}")
    31.     private String bucketName;
    32.  
    33.     /**
    34.      * byte数组形式上传
    35.      * @param file
    36.      * @Author 壹哥
    37.      */
    38.     @PostMapping("/upload1")
    39.     public void upload(@RequestParam("file") MultipartFile file) throws Exception {
    40.         AliyunOSSUtil.uploadByByteArrayFile(endpoint, accessKeyId, accessKeySecret, bucketName, file.getOriginalFilename(), file.getBytes());
    41.     }
    42.     
    43.     /**
    44.      * 输入流形式上传
    45.      * @param file
    46.      * @Author 壹哥
    47.      */
    48.     @PostMapping("/upload2")
    49.     public void upload2(@RequestParam("file") MultipartFile file) throws Exception {
    50.         AliyunOSSUtil.uploadByInputStreamFile(endpoint, accessKeyId, accessKeySecret, bucketName, file.getOriginalFilename(), file.getInputStream());
    51.     }
    52. }

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

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

    1. /**
    2.  * 上传图片并返回上传后的URL地址
    3.  * @param file
    4.  * @Author 壹哥
    5.  */
    6. @PostMapping("/upload3")
    7. public String upload3(@RequestParam("file") MultipartFile file) throws Exception {
    8.     String url = AliyunOSSUtil.uploadImage(endpoint, accessKeyId, accessKeySecret, bucketName, file.getOriginalFilename(), file.getBytes());
    9.     System.out.println("===壹哥===" + url);
    10.     return url;
    11. }

    4.5 删除文件案例

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

    1. /**
    2.  * 删除文件
    3.  * @param objName 需要删除的对象名称
    4.  * @Author 壹哥
    5.  */
    6. @DeleteMapping("/delete")
    7. public void deleteFile(String objName) {
    8.     AliyunOSSUtil.deleteFile(endpoint, accessKeyId, accessKeySecret, bucketName, objName);
    9. }

    五. 小结

    至此，我们的阿里云OSS案例就讲完了，各位小伙伴是否跟壹哥学会了呢？ 如果你还没学会，请关注Java架构栈，在评论区给我们留言或私信，把你的疑问告诉我们。当然也可以加入我们的学习群，免费获取更多学习资料和技术支持哦。

  • 相关阅读:
    【PHPCUSTOM】打包PHP程序为EXE
    应用软件漏洞排名
    san.js源码解读之工具(util)篇——extend函数
    html中image 区域点击的优点
    Grpc快速实践
    python面试题——版本管理工具GIT（二）
    SpringBoot 中整合JMS
    javaee之Elasticsearch相关知识
    FFplay文档解读-38-视频过滤器十三
    HTML5简明教程系列之HTML5 表格与表单（二）
  • 原文地址：https://blog.csdn.net/syc000666/article/details/126116359