AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

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

2018-02-13 4481
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
对象存储 OSS，20GB 3个月
推荐场景：
基于PAI-EAS挂载OSS部署AIGC服务 ossutil工具管理OSS
对象存储 OSS，内容安全 1000次 1年
对象存储 OSS，恶意文件检测 1000次 1年
简介：

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

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

首先准备工作必要的jar

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

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

然后是配置文件

现在开通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>
文章标签：
对象存储
Java
对象存储
数据格式
XML
关键词：
阿里云云服务器 ECS
云服务器 ECS oss
云服务器 ECS阿里云
云服务器 ECS java
服务器Java
相关实践学习
借助OSS搭建在线教育视频课程分享网站
本教程介绍如何基于云服务器ECS和对象存储OSS，搭建一个在线教育视频课程分享网站。
优惠券活动
目录
相关文章
刘大猫.
|
14天前
|
Java
java小工具util系列5：java文件相关操作工具，包括读取服务器路径下文件，删除文件及子文件，删除文件夹等方法
java小工具util系列5：java文件相关操作工具，包括读取服务器路径下文件，删除文件及子文件，删除文件夹等方法
刘大猫.
51 9
刘大猫.
|
2月前
|
Java Linux
java读取linux服务器下某文档的内容
java读取linux服务器下某文档的内容
刘大猫.
38 3
java读取linux服务器下某文档的内容
Dylaniou
|
2月前
|
运维 Java Linux
【运维基础知识】Linux服务器下手写启停Java程序脚本start.sh stop.sh及详细说明
### 启动Java程序脚本 `start.sh` 此脚本用于启动一个Java程序，设置JVM字符集为GBK，最大堆内存为3000M，并将程序的日志输出到`output.log`文件中，同时在后台运行。 ### 停止Java程序脚本 `stop.sh` 此脚本用于停止指定名称的服务（如`QuoteServer`），通过查找并终止该服务的Java进程，输出操作结果以确认是否成功。
Dylaniou
45 1
java冯坚持
|
2月前
|
算法 Java Linux
java制作海报四：java BufferedImage 转 InputStream 上传至OSS。png 图片合成到模板（另一个图片）上时，透明部分变成了黑色
这篇文章主要介绍了如何将Java中的BufferedImage对象转换为InputStream以上传至OSS，并解决了png图片合成时透明部分变黑的问题。
java冯坚持
69 1
武子康
|
2月前
|
分布式计算 资源调度 Hadoop
大数据-01-基础环境搭建 超详细 Hadoop Java 环境变量 3节点云服务器 2C4G XML 集群配置 HDFS Yarn MapRedece
大数据-01-基础环境搭建 超详细 Hadoop Java 环境变量 3节点云服务器 2C4G XML 集群配置 HDFS Yarn MapRedece
武子康
82 4
武子康
|
2月前
|
Java Shell Maven
Flink-11 Flink Java 3分钟上手 打包Flink 提交任务至服务器执行 JobSubmit Maven打包Ja配置 maven-shade-plugin
Flink-11 Flink Java 3分钟上手 打包Flink 提交任务至服务器执行 JobSubmit Maven打包Ja配置 maven-shade-plugin
武子康
118 4
叫个什么名字
|
12天前
|
Java 开发者
Java多线程编程中的常见误区与最佳实践####
本文深入剖析了Java多线程编程中开发者常遇到的几个典型误区，如对`start()`与`run()`方法的混淆使用、忽视线程安全问题、错误处理未同步的共享变量等，并针对这些问题提出了具体的解决方案和最佳实践。通过实例代码对比，直观展示了正确与错误的实现方式，旨在帮助读者构建更加健壮、高效的多线程应用程序。 ####
叫个什么名字
35 5
游客sjjs6jgz4gp7m1
|
3天前
|
缓存 Java 开发者
Java多线程编程的陷阱与最佳实践####
本文深入探讨了Java多线程编程中常见的陷阱，如竞态条件、死锁和内存一致性错误，并提供了实用的避免策略。通过分析典型错误案例，本文旨在帮助开发者更好地理解和掌握多线程环境下的编程技巧，从而提升并发程序的稳定性和性能。 ####
游客sjjs6jgz4gp7m1
28 11
muxiaoxi
|
3天前
|
安全 Java 开发者
Java中的多线程编程：从基础到实践
本文深入探讨了Java多线程编程的核心概念和实践技巧，旨在帮助读者理解多线程的工作原理，掌握线程的创建、管理和同步机制。通过具体示例和最佳实践，本文展示了如何在Java应用中有效地利用多线程技术，提高程序性能和响应速度。
muxiaoxi
24 1
java的细水长流
|
11天前
|
安全 Java 开发者
Java 多线程并发控制：深入理解与实战应用
《Java多线程并发控制：深入理解与实战应用》一书详细解析了Java多线程编程的核心概念、并发控制技术及其实战技巧，适合Java开发者深入学习和实践参考。
java的细水长流
36 6

热门文章

最新文章

  • 1
    ECS入门训练营——day1
  • 2
    重装linux服务器后开不了机
  • 3
    阿里云服务器申请免费试用图文教程（个人和企业均可申请）
  • 4
    RAKsmart高防服务器的优势是什么？这篇文章给你答案
  • 5
    阿里云第八代云服务器简介及最新价格分享（倚天云服务器）
  • 6
    阿里云ECS云服务器通用型g6和g5的区别以及选择建议(图文教程)
  • 7
    FTP服务器端程序分类
  • 8
    构建企业服务之windows 2008 负载均衡服务器部署
  • 9
    FBI又想查看苹果服务器了: 这一次是iCloud
  • 10
    Next.js 创建项目到服务器部署（目录结构介绍、项目结构Demo、开发细节注意）
  • 1
    oss文件删除，SecurityToken没有呀？
    98
  • 2
    数据备份到阿里云oss上，以防勒索病毒的破坏
    127
  • 3
    OSS重要特性
    68
  • 4
    基于nginx反向代理实现OSS固定域名IP访问
    1721
  • 5
    通过FC运行脚本下载文件到OSS
    121
  • 6
    存储系统、数据库和对象存储 | 青训营
    268
  • 7
    DataWorks产品使用合集之在DataWorks中，查看ODPS表的OSS对象如何解决
    92
  • 8
    DataWorks产品使用合集之在DataWorks中管理MaxCompute模块的步骤如何解决
    96
  • 9
    DataWorks产品使用合集之DataWorks在将数据写入OSS时，会将所有的字符串类型的字段进行trim操作如何解决
    89
  • 10
    DataWorks产品使用合集之在DataWorks中，同步OSS中的数据的步骤如何解决
    102

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 使用ECS和RDS搭建个人博客
  • 利用云备份Cloud Backup实现ECS文件备份
  • 基于ECS搭建FTP服务
  • 基于ECS和NAS搭建个人网盘
  • 使用ECS和OSS搭建个人网盘
  • 基于ECS搭建云上博客
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月