OSS对象存储的简单实现

火影  金牌会员 | 2024-8-15 22:08:07 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 649|帖子 649|积分 1947

条件准备好阿里云对象存储的账号->创建一个bucket(设置好访问权限)->创建用于上传文件的子账号得到accessKey和secretKey以及endpoint->sdk例子java简单上传的例子测试
  

  • 引入alicloud-oss对象纯存储相关的依赖
  

  • 在application.yml中配置accessKey和secretKey即可
  

  • 利用OssClient对象调用方法上传即可
  1. import com.aliyun.oss.ClientException;
  2. import com.aliyun.oss.OSS;
  3. import com.aliyun.oss.OSSClientBuilder;
  4. import com.aliyun.oss.OSSException;
  5. import com.aliyun.oss.model.PutObjectRequest;
  6. import com.aliyun.oss.model.PutObjectResult;
  7. import java.io.FileInputStream;
  8. import java.io.InputStream;
  10. public class Demo {
  12.     public static void main(String[] args) throws Exception {
  13.         //accessKey和secretKey以及endpoint在配置文件中指定的话这里就不用重复指定
  14.         // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
  15.         String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
  16.         // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。
  17.         String accessKeyId = "yourAccessKeyId";
  18.         String accessKeySecret = "yourAccessKeySecret";
  19.         // 填写Bucket名称，例如examplebucket。
  20.         String bucketName = "examplebucket";
  21.         // 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
  22.         String objectName = "exampledir/exampleobject.txt";
  23.         // 填写本地文件的完整路径，例如D:\\localpath\\examplefile.txt。
  24.         // 如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
  25.         String filePath= "D:\\localpath\\examplefile.txt";
  27.         // 创建OSSClient实例。
  28.         OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
  30.         try {
  31.             InputStream inputStream = new FileInputStream(filePath);
  32.             // 创建PutObjectRequest对象。
  33.             PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream);
  34.             // 设置该属性可以返回response。如果不设置，则返回的response为空。
  35.             putObjectRequest.setProcess("true");
  36.             // 创建PutObject请求。
  37.             PutObjectResult result = ossClient.putObject(putObjectRequest);
  38.             // 如果上传成功，则返回200。
  39.             System.out.println(result.getResponse().getStatusCode());
  40.         } catch (OSSException oe) {
  41.             System.out.println("Caught an OSSException, which means your request made it to OSS, "
  42.                     + "but was rejected with an error response for some reason.");
  43.             System.out.println("Error Message:" + oe.getErrorMessage());
  44.             System.out.println("Error Code:" + oe.getErrorCode());
  45.             System.out.println("Request ID:" + oe.getRequestId());
  46.             System.out.println("Host ID:" + oe.getHostId());
  47.         } catch (ClientException ce) {
  48.             System.out.println("Caught an ClientException, which means the client encountered "
  49.                     + "a serious internal problem while trying to communicate with OSS, "
  50.                     + "such as not being able to access the network.");
  51.             System.out.println("Error Message:" + ce.getMessage());
  52.         } finally {
  53.             if (ossClient != null) {
  54.                 ossClient.shutdown();
  55.             }
  56.         }
  57.     }
  58. }
复制代码
一，项目结合实例
  先发送请求获得policy 在将对象发送阿里云对象存储服务器 减轻后端压力
  建立一个oss服务器
  将oss相关配置写在配置文件中
  1. spring:
  2.   cloud:
  3.     nacos:
  4.       discovery:
  5.         server-addr: 127.0.0.1:8848
  6.     application:
  7.       name: gulimall-third-party
  8.     alicloud:
  9.       access-key: LTAI5t6G5JAZ9RB*********** # 修改为自己的
  10.       secret-key: QhhibxJFoXR9qUs*********** # 修改为自己的
  11.       oss:
  12.         endpoint: oss-cn-************* # 修改为自己的
  13.         bucket: test # 修改为自己的
  14. server:
  15.   port: 30000
复制代码
编写controller前端请求这个controller获得policy
  1. package com.wcw.gulimall.third.party.controller;
  3. import com.aliyun.oss.OSS;
  4. import com.aliyun.oss.common.utils.BinaryUtil;
  5. import com.aliyun.oss.model.MatchMode;
  6. import com.aliyun.oss.model.PolicyConditions;
  8. import com.wcw.gulimall.third.party.utils.R;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.beans.factory.annotation.Value;
  11. import org.springframework.web.bind.annotation.RequestMapping;
  12. import org.springframework.web.bind.annotation.RestController;
  14. import java.text.SimpleDateFormat;
  15. import java.util.Date;
  16. import java.util.LinkedHashMap;
  17. import java.util.Map;
  19. /**
  20. * @ClassName com.wcw.gulimall.third.party.controller.OssController
  21. * @Description:
  22. * @Author wcw
  23. * @Version V1.0 Created on ：2023/3/2 17:25
  24. */
  25. @RestController
  26. public class OssController {
  27.     @Autowired
  28.     private OSS ossClient;
  30.     @Value("${spring.cloud.alicloud.oss.endpoint}")
  31.     private String endPoint;
  33.     @Value("${spring.cloud.alicloud.oss.bucket}")
  34.     private String bucket;
  36.     @Value("${spring.cloud.alicloud.access-key}")
  37.     private String accessId;
  39.     @RequestMapping("/oss/policy")
  40.     public R policy() {
  41.         // 填写Host地址，格式为https://bucketname.endpoint。
  42.         String host = "https://" + bucket + "." + endPoint;
  43.         // 设置上传回调URL，即回调服务器地址，用于处理应用服务器与OSS之间的通信。OSS会在文件上传完成后，把文件上传信息通过此回调URL发送给应用服务器。
  44. //        String callbackUrl = "https://192.168.0.0:8888";
  45.         // 设置上传到OSS文件的前缀，可置空此项。置空后，文件将上传至Bucket的根目录下。
  46.         String format = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
  47.         String dir = format+"/";
  48.         Map<String, String> respMap = new LinkedHashMap<String, String>();
  50.         // 创建ossClient实例。
  51. //        OSS ossClient = new OSSClientBuilder().build(endpoint, accessId, accessKey);
  52.         try {
  53.             long expireTime = 30;
  54.             long expireEndTime = System.currentTimeMillis() + expireTime * 1000;
  55.             Date expiration = new Date(expireEndTime);
  56.             PolicyConditions policyConds = new PolicyConditions();
  57.             policyConds.addConditionItem(PolicyConditions.COND_CONTENT_LENGTH_RANGE, 0, 1048576000);
  58.             policyConds.addConditionItem(MatchMode.StartWith, PolicyConditions.COND_KEY, dir);
  60.             String postPolicy = ossClient.generatePostPolicy(expiration, policyConds);
  61.             byte[] binaryData = postPolicy.getBytes("utf-8");
  62.             String encodedPolicy = BinaryUtil.toBase64String(binaryData);
  63.             String postSignature = ossClient.calculatePostSignature(postPolicy);
  65.             respMap.put("accessId", accessId);
  66.             respMap.put("policy", encodedPolicy);
  67.             respMap.put("signature", postSignature);
  68.             respMap.put("dir", dir);
  69.             respMap.put("host", host);
  70.             respMap.put("expire", String.valueOf(expireEndTime / 1000));
  71.             // respMap.put("expire", formatISO8601Date(expiration));
  74.         } catch (Exception e) {
  75.             // Assert.fail(e.getMessage());
  76.             System.out.println(e.getMessage());
  77.         }
  78.         return R.ok().put("data",respMap);
  79.     }
  80. }
复制代码
返回下面的对象
  1. { policy: '',
  2. signature: '',
  3. key: '',
  4. ossaccessKeyId: '',
  5. dir: '',
  6. host: '',}
复制代码
携带policy按照aliyun oss官方文档发送即可
  1. <template>
  2.   <div>
  3.     <el-upload
  4.       action="http://gulimall-wcw.oss-cn-chengdu.aliyuncs.com"
  5.       :data="dataObj"
  6.       list-type="picture"
  7.       :multiple="false" :show-file-list="showFileList"
  8.       :file-list="fileList"
  9.       :before-upload="beforeUpload"
  10.       :on-remove="handleRemove"
  11.       :on-success="handleUploadSuccess"
  12.       :on-preview="handlePreview">
  13.       <el-button size="small" type="primary">点击上传</el-button>
  14.       <div slot="tip" class="el-upload__tip">只能上传jpg/png文件，且不超过10MB</div>
  15.     </el-upload>
  16.     <el-dialog :visible.sync="dialogVisible">
  17.       <img width="100%" :src="fileList[0].url" alt="">
  18.     </el-dialog>
  19.   </div>
  20. </template>
  21. <script>
  22.    import {policy} from './policy'
  23.    import { getUUID } from '@/utils'
  25.   export default {
  26.     name: 'singleUpload',
  27.     props: {
  28.       value: String
  29.     },
  30.     computed: {
  31.       imageUrl() {
  32.         return this.value;
  33.       },
  34.       imageName() {
  35.         if (this.value != null && this.value !== '') {
  36.           return this.value.substr(this.value.lastIndexOf("/") + 1);
  37.         } else {
  38.           return null;
  39.         }
  40.       },
  41.       fileList() {
  42.         return [{
  43.           name: this.imageName,
  44.           url: this.imageUrl
  45.         }]
  46.       },
  47.       showFileList: {
  48.         get: function () {
  49.           return this.value !== null && this.value !== ''&& this.value!==undefined;
  50.         },
  51.         set: function (newValue) {
  52.         }
  53.       }
  54.     },
  55.     data() {
  56.       return {
  57.         dataObj: {
  58.           policy: '',
  59.           signature: '',
  60.           key: '',
  61.           ossaccessKeyId: '',
  62.           dir: '',
  63.           host: '',
  64.           // callback:'',
  65.         },
  66.         dialogVisible: false
  67.       };
  68.     },
  69.     methods: {
  70.       emitInput(val) {
  71.         this.$emit('input', val)
  72.       },
  73.       handleRemove(file, fileList) {
  74.         this.emitInput('');
  75.       },
  76.       handlePreview(file) {
  77.         this.dialogVisible = true;
  78.       },
  79.       beforeUpload(file) {
  80.         
  81.         let _self = this;
  82.         return new Promise((resolve, reject) => {
  83.           policy().then(response => {
  84.             console.log("response:",response);
  85.             _self.dataObj.policy = response.data.policy;
  86.             _self.dataObj.signature = response.data.signature;
  87.             _self.dataObj.ossaccessKeyId = response.data.accessId;
  88.             _self.dataObj.key = response.data.dir +getUUID()+'_${filename}';
  89.             _self.dataObj.dir = response.data.dir;
  90.             _self.dataObj.host = response.data.host;
  91.             console.log("_self.dataObj:",_self.dataObj);
  92.             resolve(true)
  93.           }).catch(err => {
  94.             reject(false)
  95.           })
  96.         })
  97.       },
  98.       handleUploadSuccess(res, file) {
  99.         console.log("上传成功...")
  100.         this.showFileList = true;
  101.         this.fileList.pop();
  102.         this.fileList.push({name: file.name, url: this.dataObj.host + '/' + this.dataObj.key.replace("${filename}",file.name) });
  103.         this.emitInput(this.fileList[0].url);
  104.       }
  105.     }
  106.   }
  107. </script>
  108. <style>
  110. </style>
复制代码


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

火影

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表