集成阿里云OSS编写AliyunOSSUtil

文章目录

集成阿里云OSS编写AliyunOSSUtil
- 1、引入sdk依赖
- 2、添加yml配置文件
- 3、编写 AliyunOSSUtil文件
- - 3.1 多例模式
  - 3.2 单例模式
  - - 3.2.1 静态内部类-延时加载
    - 3.2.2 枚举-延时加载
- 4、单元测试调用

我们通过调用官方SDK方式集成
阿里云SDK：https://help.aliyun.com/document_detail/32008.htm?spm=a2c4g.11186623.2.6.5032f2eekNXgW7#concept-32008-zh

1、引入sdk依赖

pom.xml

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

2、添加yml配置文件

application.yml

oss:bucket: 你的bucketendPoint: https://oss-cn-shenzhen.aliyuncs.comaccessKeyId: 你的 accessKeyIdaccessKeySecret: 你的 accessKeySecret

3、编写 AliyunOSSUtil文件

3.1 多例模式

package com.mtl.aliyunoss.utils;import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;import javax.annotation.PostConstruct;
import java.io.*;
import java.net.URL;
import java.util.Calendar;/*** Aliyun OSS上传工具类*/
@Component
public class AliyunOSSUtil {private static String BUCKET_NAME;private static String KEY_ID;private static String KEY_SECRET;private static String END_POINT;private static final int URL_EXPIRATION = 365 * 10;@Value("${oss.bucket}")private String bucketName;@Value("${oss.endPoint}")private String accessEndPoint;@Value("${oss.accessKeyId}")private String accessKeyId;@Value("${oss.accessKeySecret}")private String accessKeySecret;@PostConstructpublic void init() {BUCKET_NAME = bucketName;END_POINT = accessEndPoint;KEY_ID = accessKeyId;KEY_SECRET = accessKeySecret;}/*** 打开ossClient** @reutrn ossClient ossClient*/private static OSS getOSSClient() {OSS ossClient = new OSSClientBuilder().build(END_POINT, KEY_ID, KEY_SECRET);System.out.println(ossClient);return ossClient;}/*** OSS上传文件-InputStream** @param allPathFile OSS上传的全路径路径+文件名称（/111/1.png)* @param inputStream 上传的文件流*/public static void uploadFile(String allPathFile, InputStream inputStream) {OSS ossClient = getOSSClient();try {ossClient.putObject(BUCKET_NAME, allPathFile, inputStream);} catch (Exception e) {e.printStackTrace();} finally {depoly(ossClient);}}/*** OSS上传文件-File** @param allPathFile OSS上传的全路径路径+文件名称（/111/1.png)* @param file        文件*/public static void uploadFile(String allPathFile, File file) {try {uploadFile(allPathFile, new FileInputStream(file));} catch (FileNotFoundException e) {e.printStackTrace();}}/*** OSS生成文件需要访问的url** @param allPathFile OSS需要生成的文件:路径+文件名称（/111/1.png)* @reutrn visitUrl 可以访问的url链接*/public static String getVisitUrl(String allPathFile) {OSS ossClient = getOSSClient();try {Calendar calendar = Calendar.getInstance();calendar.add(Calendar.DAY_OF_YEAR, URL_EXPIRATION);URL url = ossClient.generatePresignedUrl(BUCKET_NAME, allPathFile, calendar.getTime());if (url != null) {return url.toString();}} catch (Exception e) {e.printStackTrace();} finally {depoly(ossClient);}return null;}/*** 关闭ossClient** @param ossClient ossClient*/private static void depoly(OSS ossClient) {try {if (ossClient != null) {ossClient.shutdown();}} catch (Exception e) {e.printStackTrace();}}}

3.2 单例模式

3.2.1 静态内部类-延时加载

替换多例 getOSSClient 方法；
加上 SingletonOSS 内部类静态方法

/*** 内部类静态方法*/private static class SingletonOSS {private final static OSS ossClient = new OSSClientBuilder().build(END_POINT, KEY_ID, KEY_SECRET);}/*** 获取 ossClient** @reutrn OSS OSS访问Client*/public static OSS getOSSClient() {return SingletonOSS.ossClient;}

3.2.2 枚举-延时加载

替换多例 getOSSClient 方法；
加上 SingletonOSS 内部类静态方法

/*** 使用枚举方法实现单例模式*/public enum OSSEnumSignletion { //内部枚举类INSTANCE;private OSS ossClient;/*** JVM保证这个方法绝对只调用一次*/OSSEnumSignletion() {ossClient = new OSSClientBuilder().build(END_POINT, KEY_ID, KEY_SECRET);}public OSS ossClient() {return ossClient;}}/*** 获取 ossClient** @reutrn OSS OSS访问Client*/public static OSS getOSSClient() {return OSSEnumSignletion.INSTANCE.ossClient();}

4、单元测试调用

多线程模型并发上传文件

@SpringBootTest
class AliyunossApplicationTests {@Testvoid contextLoads() throws InterruptedException { long start = System.currentTimeMillis();int threadNum = 10;final CountDownLatch countDownLatch = new CountDownLatch(threadNum);while (threadNum > 0) {new Thread(() -> {System.out.println("---------------线程：" + Thread.currentThread());for (int j = 0; j < 10; j++) {//上传文件AliyunOSSUtil.uploadFile("111/1.png", new File("C:\\Users\\mtl\\Desktop\\1.png"));//获取访问 urlString visitUrl = AliyunOSSUtil.getVisitUrl("111/1.png");System.out.println(visitUrl);}countDownLatch.countDown();}).start();threadNum--;}//main方法阻塞，直到计数器变为0才会继续执行countDownLatch.await();long end = System.currentTimeMillis();System.out.println("总耗时:" + (end - start) + "ms");}
}

集成阿里云OSS编写AliyunOSSUtil相关推荐

Springboot集成阿里云OSS上传及下载
文章目录使用手册 maven依赖及环境配置定义配置bean及OSS工具类定义UploadController和DownloadController 下载接口优化为返回重定向oss路径遇到的问题 ...
SpringBoot集成阿里云OSS上传文件
文章目录前言一.准备环境 1.在搜索框搜索对象存储OSS 2.创建Bucket 3.找到开发相关信息二.具体代码 1.Maven依赖 2.application.yml配置 3.AliOssP ...
SringBoot集成阿里云OSS上传文件
上一篇文章讲了如何将文件从linux同步到阿里云的oss有兴趣的小伙伴可以去看看,这篇文章讲述如何将文件上传到阿里云oss上,本文只详细写出后端java代码示例,前端和无用代码都会省略,可以上传文件, ...
Android 快速集成阿里云OSS服务2020
一.兼单快速集成 1.打开阿里云官网 https://www.aliyun.com并注册账号,然后登陆 2.在阿里云主页选择产品分类,再选择对象存储OSS 3.点击帮助文档开始进行集成 (1).点击帮 ...
十三.SpringCloudAlibaba极简入门-集成阿里云OSS对象存储
前言因为在搞项目,需要对接一下OSS,所以一时兴起就做一下整理,本文章讲述的是如何使用阿里云的对象存储作为文件服务器,您需要登录阿里云,注册一个账号. 1.注册登录阿里云省略- 2.开通OSS对象 ...
在线教育_Day06_项目整合阿里云OSS和Excel导入分类
一.阿里云OSS概述及开通 1.1 对象存储OSS 为了解决海量数据存储与弹性扩容,项目中我们采用云存储的解决方案- 阿里云OSS. 1.2 开通"对象存储OSS"服务 (1)申请 ...
14 医疗挂号系统_【阿里云OSS、用户认证与就诊人】
阿里云oss 用户认证需要上传证件图片.首页轮播也需要上传图片,因此我们要做文件服务,阿里云oss是一个很好的分布式文件服务系统,所以我们只需要集成阿里云oss即可 1.开通"对象存储OSS ...
springboot整合阿里云oss上传的方法示例
这篇文章主要介绍了springboot整合阿里云oss上传的方法示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧 OSS申请和 ...
阿里云OSS的使用(全程请登陆)
文章目录 1.阿里云oss服务开通 2.进入控制台 3.创建Bucket 4.上传一张图片,测试是否成功 5.创建AccessKey 6.Java集成OSS 6.1.依赖POM 6.2.配置类appl ...

集成阿里云OSS编写AliyunOSSUtil

集成阿里云OSS编写AliyunOSSUtil

文章目录

1、引入sdk依赖

2、添加yml配置文件

3、编写 AliyunOSSUtil文件

3.1 多例模式

3.2 单例模式

3.2.1 静态内部类-延时加载

3.2.2 枚举-延时加载

4、单元测试调用

集成阿里云OSS编写AliyunOSSUtil相关推荐

最新文章

热门文章