OSS的使用

谁践踏了优雅 2023-10-11 13:59 49阅读 0赞
  • 1.引入maven依赖
  • 2.上传文件
  • 3.断点上传

1.引入maven依赖

  1. <!--引入阿里oss-->
  2.         <!-- https://mvnrepository.com/artifact/com.aliyun.oss/aliyun-sdk-oss -->
  3.         <dependency>
  4.             <groupId>com.aliyun.oss</groupId>
  5.             <artifactId>aliyun-sdk-oss</artifactId>
  6.             <version>2.2.1</version>
  7.         </dependency>

2.上传文件

  1. /**
  2.      * 上传文件到oss,返回上传oss之后的地址
  3.      * @param file
  4.      * @return
  5.      */
  6.     public static String upLoadFIle2Oss(MultipartFile file,String fileDir){
  8.         String ossUrl=null;
  9.             try {
  11.                 OSSClientUtil ossClient = new OSSClientUtil();
  12.                 String OssImageName = uploadImg2Oss(file,fileDir);
  13.                 ossUrl = ossClient.getImgUrl(OssImageName,fileDir);
  14.             }catch (Exception e){
  16.                 log.error(e.getMessage());
  18.             }
  22.         return ossUrl;
  23.     }
  24.  public String uploadImg2Oss(MultipartFile file,String fileDir){
  26.         String originalFilename = file.getOriginalFilename();
  27.         String substring = originalFilename.substring(originalFilename.lastIndexOf(".")).toLowerCase();
  28.         Random random = new Random();
  29.         String name = random.nextInt(10000) + System.currentTimeMillis() + substring;
  30.         InputStream inputStream = null;
  31.         try {
  33.             inputStream = file.getInputStream();
  34.             this.uploadFile2OSS(inputStream, name,fileDir);
  35.         } catch (IOException e) {
  37.             e.printStackTrace();
  38.         }
  40.         return name;
  41.     }
  42. /**
  43.      * 获得图片路径
  44.      *
  45.      * @param fileUrl
  46.      * @return
  47.      */
  48.     public String getImgUrl(String fileUrl,String fileDir) {
  50.         System.out.println(fileUrl);
  51.         if (!StringUtils.isEmpty(fileUrl)) {
  53.             String[] split = fileUrl.split("/");
  54.             return this.getUrl(fileDir + split[split.length - 1]);
  55.         }
  56.         return null;
  57.     }
  58.       /**
  59.      * 上传到OSS服务器 如果同名文件会覆盖服务器上的
  60.      *
  61.      * @param instream
  62.      *            文件流
  63.      * @param fileName
  64.      *            文件名称 包括后缀名
  65.      * @return 出错返回"" ,唯一MD5数字签名
  66.      */
  67.     public String uploadFile2OSS(InputStream instream, String fileName,String fileDir) {
  69.         String ret = "";
  70.         try {
  72.             // 创建上传Object的Metadata
  73.             ObjectMetadata objectMetadata = new ObjectMetadata();
  74.             objectMetadata.setContentLength(instream.available());
  75.             objectMetadata.setCacheControl("no-cache");
  76.             objectMetadata.setHeader("Pragma", "no-cache");
  77.             objectMetadata.setContentType(getContentType(fileName.substring(fileName.lastIndexOf("."))));
  78.             objectMetadata.setContentDisposition("inline;filename=" + fileName);
  79.             // 上传文件
  80.             PutObjectResult putResult = ossClient.putObject(bucketName, fileDir + fileName, instream, objectMetadata);
  81.             ret = putResult.getETag();
  82.         } catch (IOException e) {
  84.             logger.error(e.getMessage(), e);
  85.         } finally {
  87.             try {
  89.                 if (instream != null) {
  91.                     instream.close();
  92.                 }
  93.             } catch (IOException e) {
  95.                 e.printStackTrace();
  96.             }
  97.         }
  98.         return ret;
  99.     }

3.断点上传

  1. /**
  2.      * 上传视频文件到oss,返回上传oss之后的地址
  3.      * @param file
  4.      * @return
  5.      */
  6.     public static String upLoadVideo2Oss(MultipartFile file,String dir){
  8.         String ossUrl=null;
  9.             try {
  11.                 OSSClientUtil ossClient = new OSSClientUtil();
  12.                 File newFile=MultipartFile2File( file);
  13.                 String OssImageName = ossClient.uploadVideo2OSS(newFile.getPath(),newFile.getName(),dir);
  14.                 ossUrl = ossClient.getUrl(OssImageName);
  15.                 if(ossUrl!=null&&!"".equals(ossUrl)){
  17.                     newFile.delete();
  18.                 }
  19.             }catch (Exception e){
  21.                 log.error(e.getMessage());
  22.             }
  25.         return ossUrl;
  26.     }
  27.     public class OSSClientUtil {
  29. public static final Logger logger = LoggerFactory.getLogger(OSSClientUtil.class);
  30.     // endpoint
  31.     // endpoint以杭州为例，其它region请按实际情况填写
  32.     private static final String endpoint = "http://oss-cn-hangzhou.aliyuncs.com";
  33.     // accessKey
  34.     private static final String accessKeyId = "LTAIBV6mlkfxp7l";
  35.     private static final String accessKeySecret = "TyyLM1HzNdujedZ6dmF9A2xshzScjUS";
  36.     // 空间
  37.     private String bucketName = "bqkj";
  38.     //用户
  39.     //头像
  40.     private static String USER_PROFILE_IMAGE = "bqkj/campusGang/userInfo/profileImage/";
  41.     //内容管理
  42.     //附件
  43.     public static String CONTENT_MANAGE_ACCESSORY = "bqkj/campusGang/ContentManagement/Accessory/";
  44.     //富文本内容
  45.     public static String CONTENT_MANAGE_RICH_TEXT = "bqkj/campusGang/ContentManagement/RichTextContent/";
  46.     //缩略图
  47.     public static String CONTENT_MANAGE_THUMBNAIL = "bqkj/campusGang/ContentManagement/Accessory/";
  48.     //留言
  49.     //缩略图
  50.     public static String LEAVE_MSG_IMAGE = "bqkj/campusGang/leaveMsg/image/";
  51.     public static String INVOICE_OCR = "bqkj/campusGang/invoice/ocr/";
  52.     private OSSClient ossClient;
  54.     public OSSClientUtil() {
  56.         ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
  57.     }
  59.     /**
  60.      * 初始化
  61.      */
  62.     public void init() {
  64.         ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
  65.     }
  67.     /**
  68.      * 销毁
  69.      */
  70.     public void destory() {
  72.         ossClient.shutdown();
  73.     }
  75.     /**
  76.      * 上传图片
  77.      *
  78.      * @param url
  79.      */
  80.     public void uploadImg2Oss(String url,String fileDir){
  82.         File fileOnServer = new File(url);
  83.         FileInputStream fin;
  84.         try {
  86.             fin = new FileInputStream(fileOnServer);
  87.             String[] split = url.split("/");
  88.             this.uploadFile2OSS(fin, split[split.length - 1],fileDir);
  89.         } catch (FileNotFoundException e) {
  91.             e.printStackTrace();
  92.         }
  95.     }
  97.     public String uploadImg2Oss(MultipartFile file,String fileDir){
  99.         String originalFilename = file.getOriginalFilename();
  100.         String substring = originalFilename.substring(originalFilename.lastIndexOf(".")).toLowerCase();
  101.         Random random = new Random();
  102.         String name = random.nextInt(10000) + System.currentTimeMillis() + substring;
  103.         InputStream inputStream = null;
  104.         try {
  106.             inputStream = file.getInputStream();
  107.             this.uploadFile2OSS(inputStream, name,fileDir);
  108.         } catch (IOException e) {
  110.             e.printStackTrace();
  111.         }
  113.         return name;
  114.     }
  116.     /**
  117.      * 获得图片路径
  118.      *
  119.      * @param fileUrl
  120.      * @return
  121.      */
  122.     public String getImgUrl(String fileUrl,String fileDir) {
  124.         System.out.println(fileUrl);
  125.         if (!StringUtils.isEmpty(fileUrl)) {
  127.             String[] split = fileUrl.split("/");
  128.             return this.getUrl(fileDir + split[split.length - 1]);
  129.         }
  130.         return null;
  131.     }
  133.     /**
  134.      * 上传到OSS服务器 如果同名文件会覆盖服务器上的
  135.      *
  136.      * @param instream
  137.      *            文件流
  138.      * @param fileName
  139.      *            文件名称 包括后缀名
  140.      * @return 出错返回"" ,唯一MD5数字签名
  141.      */
  142.     public String uploadFile2OSS(InputStream instream, String fileName,String fileDir) {
  144.         String ret = "";
  145.         try {
  147.             // 创建上传Object的Metadata
  148.             ObjectMetadata objectMetadata = new ObjectMetadata();
  149.             objectMetadata.setContentLength(instream.available());
  150.             objectMetadata.setCacheControl("no-cache");
  151.             objectMetadata.setHeader("Pragma", "no-cache");
  152.             objectMetadata.setContentType(getContentType(fileName.substring(fileName.lastIndexOf("."))));
  153.             objectMetadata.setContentDisposition("inline;filename=" + fileName);
  154.             // 上传文件
  155.             PutObjectResult putResult = ossClient.putObject(bucketName, fileDir + fileName, instream, objectMetadata);
  156.             ret = putResult.getETag();
  157.         } catch (IOException e) {
  159.             logger.error(e.getMessage(), e);
  160.         } finally {
  162.             try {
  164.                 if (instream != null) {
  166.                     instream.close();
  167.                 }
  168.             } catch (IOException e) {
  170.                 e.printStackTrace();
  171.             }
  172.         }
  173.         return ret;
  174.     }
  176.     /**
  177.      * 断点上传视频
  178.      * @param filePath
  179.      * @param fileName
  180.      * @return
  181.      */
  182.     public String uploadVideo2OSS(String filePath, String fileName,String dir) {
  184.         String ret = "";
  185.         try {
  187.             fileName=dir+new Date().getTime()+fileName;
  188.             UploadFileRequest uploadFileRequest = new UploadFileRequest(bucketName, fileName);
  189.             // The local file to upload---it must exist.
  190.             uploadFileRequest.setUploadFile(filePath);
  191.             // Sets the concurrent upload task number to 5.
  192.             uploadFileRequest.setTaskNum(6);
  193.             // Sets the part size to 1MB.
  194.             uploadFileRequest.setPartSize(1024 * 1024 * 1);
  195.             // Enables the checkpoint file. By default it's off.
  196.             uploadFileRequest.setEnableCheckpoint(true);
  198.             UploadFileResult uploadResult = ossClient.uploadFile(uploadFileRequest);
  200.             CompleteMultipartUploadResult multipartUploadResult =
  201.                     uploadResult.getMultipartUploadResult();
  202.             ret=fileName;
  203.             System.out.println(multipartUploadResult.getETag());
  204.         }  catch (OSSException oe) {
  206.             System.out.println("Caught an OSSException, which means your request made it to OSS, "
  207.                     + "but was rejected with an error response for some reason.");
  208.             System.out.println("Error Message: " + oe.getErrorMessage());
  209.             System.out.println("Error Code:       " + oe.getErrorCode());
  210.             System.out.println("Request ID:      " + oe.getRequestId());
  211.             System.out.println("Host ID:           " + oe.getHostId());
  212.         } catch (ClientException ce) {
  214.             System.out.println("Caught an ClientException, which means the client encountered "
  215.                     + "a serious internal problem while trying to communicate with OSS, "
  216.                     + "such as not being able to access the network.");
  217.             System.out.println("Error Message: " + ce.getMessage());
  218.         } catch (Throwable e) {
  220.             e.printStackTrace();
  221.         } finally {
  223.             ossClient.shutdown();
  224.         }
  225.         return ret;
  226.     }
  228.     /**
  229.      * 删除oss的文件，传参是bqkj/campusGang/userInfo/profileImage/1590730407032.jpg
  230.      * @param filePath
  231.      * @return
  232.      */
  233.     public boolean deleteOssFile(String filePath) {
  235.         boolean exist = ossClient.doesObjectExist(bucketName, filePath);
  236.         if (!exist) {
  238.             logger.error("文件不存在,filePath={}", filePath);
  239.             return false;
  240.         }
  241.         logger.info("删除文件,filePath={}", filePath);
  242.         ossClient.deleteObject(bucketName, filePath);
  243.         ossClient.shutdown();
  244.         return true;
  245.     }
  247.     /**
  248.      * Description: 判断OSS服务文件上传时文件的contentType
  249.      * @param filenameExtension 文件后缀
  250.      * @return String
  251.      */
  252.     public static String getContentType(String filenameExtension) {
  254.         if (filenameExtension.equalsIgnoreCase(".bmp")) {
  256.             return "image/bmp";
  257.         }
  258.         if (filenameExtension.equalsIgnoreCase(".gif")) {
  260.             return "image/gif";
  261.         }
  262.         if (filenameExtension.equalsIgnoreCase(".jpeg") || filenameExtension.equalsIgnoreCase(".jpg")
  263.                 || filenameExtension.equalsIgnoreCase(".png")) {
  265.             return "image/jpeg";
  266.         }
  267.         if (filenameExtension.equalsIgnoreCase(".html")) {
  269.             return "text/html";
  270.         }
  271.         if (filenameExtension.equalsIgnoreCase(".txt")) {
  273.             return "text/plain";
  274.         }
  275.         if (filenameExtension.equalsIgnoreCase(".vsd")) {
  277.             return "application/vnd.visio";
  278.         }
  279.         if (filenameExtension.equalsIgnoreCase(".pptx") || filenameExtension.equalsIgnoreCase(".ppt")) {
  281.             return "application/vnd.ms-powerpoint";
  282.         }
  283.         if (filenameExtension.equalsIgnoreCase(".docx") || filenameExtension.equalsIgnoreCase(".doc")) {
  285.             return "application/msword";
  286.         }
  287.         if (filenameExtension.equalsIgnoreCase(".xml")) {
  289.             return "text/xml";
  290.         }
  291.         if (filenameExtension.equalsIgnoreCase(".pdf")) {
  293.             return "application/pdf";
  294.         }
  295.         return "image/jpeg";
  296.     }
  298.     /**
  299.      * 获得url链接
  300.      *
  301.      * @param key
  302.      * @return
  303.      */
  304.     public String getUrl(String key) {
  306.         // 设置URL过期时间为10年 3600l* 1000*24*365*10
  308.         Date expiration = new Date(System.currentTimeMillis() + 3600L * 1000 * 24 * 365 * 10);
  309.         // 生成URL
  310.         URL url = ossClient.generatePresignedUrl(bucketName, key, expiration);
  311.         if (url != null) {
  313.             return url.toString();
  314.         }
  315.         return null;
  316.     }
  318.     }

发表评论

表情：
评论列表 （有 0 条评论，49人围观）

还没有评论，来说两句吧...

相关阅读