阿里云oss服务器文件上传java

2022-01-26 00:43:07

阿里云oss服务器文件上传javahttp://www.bieryun.com/1251.html

阿里云oss服务器文件上传java

前天做OSS服务器文件上传，之前没了解过，做的过程中遇到许多问题，最终通过查阅相关资料解决了，特分享一下。

首先准备工作必要的jar

阿里云oss服务器文件上传java

这里注意版本一致，不然就会报很多坑爹的错误..

如果你断点调试在执行putObject方法时报错，99％的是罐子包有问题..

然后是配置文件

阿里云oss服务器文件上传java

现在开通OSS，都是免费开通的，包年9块钱。

这是几个必要的参数，既然做这个肯定要知道的！这里就不多做解释了。

这里，首先需要我们创建一个OSS 信息实体类，OSSCon 图。Java，用来读取配置文件的信息，封装成实体。

[java] 查看纯文本

  1. import  java.io.IOException;
  2. import  java.io.InputStream;
  3. import  java.util.Properties;
  4.   / **
  5.    * oss相关参数实体
  6.    * @author liux
  7.    * 2017年/ 5/5
  8.    * /
  9. 公共类 OSSConfigure {
  11.     私人 字符串端点;
  12.     私人 字符串accessKeyId;
  13.     私人 字符串accessKeySecret;
  14.     私人 字符串bucketName;
  15.     私人 字符串accessUrl;
  17.     public  OSSConfigure（）{
  19.     }
  21.     / ** 
  22.      *通过配置文件.properties文件获取，这几项内容。 
  23.      *  
  24.      * @param storageConfName 
  25.      * @抛出IOException 
  26.      * /
  27.     公共 OSSConfigure（字符串storageConfName）  抛出 IOException {
  29.         属性prop =  new  Properties（）;
  30.         InputStream is =  super .getClass（）。getClassLoader（）。getResourceAsStream（storageConfName）;
  31.         prop.load（是）;
  33.         endpoint = prop.getProperty（“Endpoint” ）.trim（）;
  34.         accessKeyId = prop.getProperty（“AccessKey” ）.trim（）;
  35.         accessKeySecret = prop.getProperty（“AccessKeySecret” ）.trim（）;
  36.         bucketName = prop.getProperty（“BucketName” ）.trim（）;
  37.         accessUrl = prop.getProperty（“accessUrl” ）.trim（）;
  39.     }
  41.     公共 OSSConfigure（字符串端点，字符串accessKeyId，
  42.             字符串accessKeySecret，字符串bucketName，字符串accessUrl）{
  44.         这个.endpoint =端点;
  45.         这个.accessKeyId = accessKeyId;
  46.         这个.accessKeySecret = accessKeySecret;
  47.         这个.bucketName = bucketName;
  48.         这个.accessUrl = accessUrl;
  49.     }
  51.     public  String getEndpoint（）{
  52.         返回 终点;
  53.     }
  55.     public void  setEndpoint（String endpoint）{
  56.         这个.endpoint =端点;
  57.     }
  59.     public  String getAccessKeyId（）{
  60.         返回 accessKeyId;
  61.     }
  63.     public void  setAccessKeyId（String accessKeyId）{
  64.         这个.accessKeyId = accessKeyId;
  65.     }
  67.     public  String getAccessKeySecret（）{
  68.         返回 accessKeySecret;
  69.     }
  71.     public void  setAccessKeySecret（String accessKeySecret）{
  72.         这个.accessKeySecret = accessKeySecret;
  73.     }
  75.     public  String getBucketName（）{
  76.         返回 bucketName;
  77.     }
  79.     public void  setBucketName（String bucketName）{
  80.         这个.bucketName = bucketName;
  81.     }
  83.     public  String getAccessUrl（）{
  84.         返回 accessUrl;
  85.     }
  87.     public void  setAccessUrl（String accessUrl）{
  88.         这个.accessUrl = accessUrl;
  89.     }
  91. }

 

然后就是创建一个OSS文件管理的OSSManageUtil工具类的.oss文件存储实际上就是对对象的操作，只要写好路径，都会自动创建的，OSSClient是OSS的核心，有兴趣的可以多研究下。我做这个是要上传app，以及压缩图片后上传，contentType这个方法注意，我上传的是所以要用这个类型application / octet-stream，之前因为这个找了半天错。

[java] 查看纯文本

  1. 包 com.cdy.utils;
  3. import  java.io.File;
  4. import  java.io.IOException;
  5. import  java.io.InputStream;
  6. import  java.util.Date;
  9. import  com.aliyun.oss.ClientException;
  10. import  com.aliyun.oss.OSSClient;
  11. import  com.aliyun.oss.OSSException;
  12. import  com.aliyun.oss.model.GetObjectRequest;
  13. import  com.aliyun.oss.model.OSSObject;
  14. import  com.aliyun.oss.model.ObjectMetadata;
  16. / **
  17.  *对OSS服务器进行上传删除等的处理
  18.  * 
  19.  * @ClassName：OSSManageUtil
  20.  * @说明：
  21.  * @author liux
  22.  * @date 2017-5-3上午10:47:00
  23.  * 
  24.  * /
  25. 公共类 OSSManageUtil {
  26.     / **
  27.      *上传OSS服务器文件@Title：uploadFile 
  28.      * @param multipartFile spring上传的文件
  29.      * remotePath @param oss服务器二级目录
  30.      * @throws Exception设定文件@return String
  31.      *返回类型@throws
  32.      * /
  33.     public static  String uploadFile（InputStream fileContent，String remotePath，String fileName）  throws  Exception {
  34.         //随机名处理
  35.         fileName =  “lxkc_”  +  new  Date（）。getTime（）+ fileName.substring（fileName.lastIndexOf（“。” ））;
  36.         //加载配置文件，初始化OSSClient
  37.         OSSConfigure ossConfigure =  new  OSSConfigure（“/ system.properties ” ）;
  38.         OSSClient ossClient =  新的 OSSClient（ossConfigure.getEndpoint（），ossConfigure.getAccessKeyId（），
  39.                 ossConfigure.getAccessKeySecret（））;
  40.         //定义二级目录
  41.         String remoteFilePath = remotePath.substring（0 ，remotePath.length（））。replaceAll（“\\\\”，“ / ”）+“ /”;
  42.         //创建上传对象的元数据
  43.         ObjectMetadata objectMetadata =  new  ObjectMetadata（）;
  44.         objectMetadata.setContentLength（fileContent.available（））;
  45.         objectMetadata.setContentEncoding（“utf-8” ）;
  46.         objectMetadata.setCacheControl（“no-cache” ）;
  47.         objectMetadata.setHeader（“Pragma” ，  “no-cache” ）;
  48.         objectMetadata.setContentType（contentType（fileName.substring（fileName.lastIndexOf（“。” ））））;
  49.         objectMetadata.setContentDisposition（“inline; filename =”  + fileName）;
  50.         //上传文件
  51.         ossClient.putObject（ossConfigure.getBucketName（），remoteFilePath + fileName，fileContent，objectMetadata）;
  52.         //关闭OSSClient
  53.         ossClient.shutdown（）;
  54.         //关闭io流
  55.         fileContent.close（）;
  56.         return  ossConfigure.getAccessUrl（）+  “/”  + remoteFilePath + fileName;
  57.     }
  59.     //下载文件
  60.     @SuppressWarnings （“未使用” ）
  61.     public static void  downloadFile（OSSConfigure ossConfigure，String key，String filename）
  62.             抛出 OSSException，ClientException，IOException {
  63.         //初始化OSSClient
  64.         OSSClient ossClient =  新的 OSSClient（ossConfigure.getEndpoint（），ossConfigure.getAccessKeyId（），
  65.                 ossConfigure.getAccessKeySecret（））;
  66.         OSSObject对象= ossClient.getObject（ossConfigure.getBucketName（），key）;
  67.         //获取ObjectMeta
  68.         ObjectMetadata meta = object.getObjectMetadata（）;
  70.         //获取对象的输入流
  71.         InputStream objectContent = object.getObjectContent（）;
  73.         ObjectMetadata objectData = ossClient.getObject（new  GetObjectRequest（ossConfigure.getBucketName（），key），
  74.                 新 文件（文件名））;
  75.         //关闭数据流
  76.         objectContent.close（）;
  78.     }
  80.     / **
  81.      *根据key删除OSS服务器上的文件@Title：deleteFile @Description：@param @param
  82.      * ossConfigure @param @param filePath设定文件@return void返回类型@throws
  83.      * @抛出IOException 
  84.      * /
  85.     public static void  deleteFile（String filePath）  throws  IOException {
  86.         //加载配置文件，初始化OSSClient
  87.         OSSConfigure ossConfigure =  new  OSSConfigure（“/ system.properties ” ）;
  88.         OSSClient ossClient =  新的 OSSClient（ossConfigure.getEndpoint（），ossConfigure.getAccessKeyId（），
  89.                 ossConfigure.getAccessKeySecret（））;
  90.         filePath = filePath.substring（45 ）;
  91.         ossClient.deleteObject（ossConfigure.getBucketName（），filePath）;
  93.     }
  95.     / **
  96.      *描述：判断OSS服务文件上传时文件的contentType @ Version1.0
  97.      * 
  98.      * @param FilenameExtension
  99.      *文件后缀
  100.      * @返回字符串
  101.      * /
  102.     public static  String contentType（String FileNameExtension）{
  103.         if  （FilenameExtension.equals（“.BMP” ）|| FilenameExtension.equals（“.bmp” ））{
  104.             返回“image / bmp” ;
  105.         }
  106.         if  （FilenameExtension.equals（“.GIF” ）|| FilenameExtension.equals（“.gif” ））{
  107.             返回“image / gif” ;
  108.         }
  109.         if  （FilenameExtension.equals（“.JPEG” ）|| FilenameExtension.equals（“.jpeg” ）|| FilenameExtension.equals（“.JPG” ）
  110.                 || FilenameExtension.equals（“.jpg” ）|| FilenameExtension.equals（“.PNG” ）
  111.                 || FilenameExtension.equals（“.png” ））{
  112.             返回“image / jpeg” ;
  113.         }
  114.         if  （FilenameExtension.equals（“. HTML” ）|| FilenameExtension.equals（“.html” ））{
  115.             返回“text / html” ;
  116.         }
  117.         if  （FilenameExtension.equals（“.TXT” ）|| FilenameExtension.equals（“.txt” ））{
  118.             返回“text / plain” ;
  119.         }
  120.         if  （FilenameExtension.equals（“.VSD” ）|| FilenameExtension.equals（“.vsd ” ））{
  121.             返回“application / vnd.visio” ;
  122.         }
  123.         if  （FilenameExtension.equals（“.PPTX” ）|| FilenameExtension.equals（“.pptx” ）|| FilenameExtension.equals（“.PPT” ）
  124.                 || FilenameExtension.equals（“.ppt” ））{
  125.             返回“application / vnd.ms-powerpoint” ;
  126.         }
  127.         if  （FilenameExtension.equals（“.DOCX” ）|| FilenameExtension.equals（“.docx” ）|| FilenameExtension.equals（“.DOC” ）
  128.                 || FilenameExtension.equals（“.doc” ））{
  129.             返回“application / msword” ;
  130.         }
  131.         if  （FilenameExtension.equals（“.XML” ）|| FilenameExtension.equals（“.xml” ））{
  132.             返回“text / xml” ;
  133.         }
  134.         if  （FilenameExtension.equals（“. apk” ）|| FilenameExtension.equals（“.APK” ））{
  135.             返回“application / octet-stream” ;
  136.         }
  137.         返回“text / html” ;
  138.     }
  139. }

以上是主要代码，再贴一下我的控制器，我这里是做的应用程序文件上传

[java] 查看纯文本

  1. / **
  2.      * app文件上传
  3.      *
  4.      * @param imageFile
  5.      * @param请求
  6.      * @返回
  7.      * /
  8.     @RequestMapping （value =  “/ uploadApp” ，method = RequestMethod.POST）
  9.     @ResponseBody
  10.     public  ImportResponse uploadApp（@RequestParam （“app” ）MultipartFile appFile，VersionUpgrade versionUpgrade）{
  11.         if  （versionUpgrade ==  null ）{
  12.             返回 ImportResponse.fail（“上传失败！” ）;
  13.         }
  14.         尝试 {
  15.              //流转换将MultipartFile转换为所需的InputStream
  16.             CommonsMultipartFile cf =（CommonsMultipartFile）appFile;
  17.             DiskFileItem fi =（DiskFileItem）cf.getFileItem（）;
  18.             InputStream fileContent = fi.getInputStream（）;
  19.             String fileName = fi.getName（）;
  20.             字符串apkUrl = OSSManageUtil.uploadFile（fileContent，  “xxapp” ，fileName）;
  21.             versionUpgrade.setApkUrl（apkUrl）;
  22.             versionUpgrade.setLoginUserVw（curUser）;
  23.             versionUpgradeManager.save（versionUpgrade）;
  24.         }  捕获 （例外五）{
  25.             log.error（“【app上传失败】：” ，e）;
  26.             返回 ImportResponse.fail（“上传失败！” ）;
  27.         }
  28.         返回 ImportResponse.success（“上传成功！” ）;
  29.     }

以上就是全部内容了，都是API里面有的，因为自己做的过程中出现很多问题，所以分享给大家！

[java] 查看纯文本

  1. <p> <span lang = “zh-CN”  style = “font-size：18.6667px; font-family：新宋体” > </ span> </ p>
上一篇：原生javascript中的的AJAX写法


下一篇：.NET Core 获取操作系统各种信息