JAVA上传内容到阿里云服务器，获取保存路径和点击路径。

阿里云的一些基本数据常量配置

import java.text.SimpleDateFormat;
import java.util.Date;

/**
*
* @ClassName: OSSClientConstants
* @Description: OSS阿里云常用变量
* @author wy
* @date 2017年5月5日 上午11:56:25
*
*/
public class OSSClientConstants {
//阿里云API的外网域名
public static final String ENDPOINT = "http://oss-cn-hangzhou.aliyuncs.com";
//阿里云API的密钥Access Key ID
public static final String ACCESS_KEY_ID = "XX";
//阿里云API的密钥Access Key Secret
public static final String ACCESS_KEY_SECRET = "XX";
//阿里云API的bucket名称
public static final String BACKET_NAME = "XX";
//阿里云API的文件夹名称
public static final String FOLDER="user/";
public static final String FOLDER_VIDEO="video/";
public static final String FORMAT = new SimpleDateFormat("yyyyMMdd").format(new Date());
public static final String FORMATS = new SimpleDateFormat("yyyyMMddHHmmss").format(new Date());
}

上传内容到阿里云服务器，获取保存路径和点击路径。

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.util.Date;

import javax.imageio.stream.FileImageInputStream;

import org.apache.log4j.Logger;
import org.springframework.stereotype.Component;

import com.aliyun.oss.OSSClient;
import com.aliyun.oss.model.Bucket;
import com.aliyun.oss.model.OSSObject;
import com.aliyun.oss.model.ObjectMetadata;
import com.aliyun.oss.model.PutObjectResult;

import sun.misc.BASE64Decoder;

/**
*
* @ClassName: AliyunOSSClientUtil
* @Description: 阿里云OSS上传文件模块
* @author wy
* @date 2017年5月6日 下午6:01:46
*
*/
@Component
public class AliyunOSSClientUtil {
// log日志
private static Logger logger = Logger.getLogger(AliyunOSSClientUtil.class);
// 阿里云API的内或外网域名
private static String ENDPOINT;
// 阿里云API的密钥Access Key ID
private static String ACCESS_KEY_ID;
// 阿里云API的密钥Access Key Secret
private static String ACCESS_KEY_SECRET;
// 阿里云API的bucket名称
public static String BACKET_NAME;
// 阿里云API的文件夹名称
private static String FOLDER;
private static String FORMAT;
private static String FORMATS;
private static String FOLDER_VIDEO;

// 初始化属性
static {
ENDPOINT = OSSClientConstants.ENDPOINT;
ACCESS_KEY_ID = OSSClientConstants.ACCESS_KEY_ID;
ACCESS_KEY_SECRET = OSSClientConstants.ACCESS_KEY_SECRET;
BACKET_NAME = OSSClientConstants.BACKET_NAME;
FOLDER = OSSClientConstants.FOLDER;
FORMAT = OSSClientConstants.FORMAT;
FORMATS = OSSClientConstants.FORMATS;
FOLDER_VIDEO = OSSClientConstants.FOLDER_VIDEO;
}

/**
* 获取阿里云OSS客户端对象
*
* @return ossClient
*/
public static OSSClient getOSSClient() {
return new OSSClient(ENDPOINT, ACCESS_KEY_ID, ACCESS_KEY_SECRET);
}

/**
* 创建存储空间
*
* @param ossClient
* OSS连接
* @param bucketName
* 存储空间
* @return
*/
public static String createBucketName(OSSClient ossClient, String bucketName) {
// 存储空间
final String bucketNames = bucketName;
if (!ossClient.doesBucketExist(bucketName)) {
// 创建存储空间
Bucket bucket = ossClient.createBucket(bucketName);
logger.info("创建存储空间成功");
return bucket.getName();
}
return bucketNames;
}

/**
* 删除存储空间buckName
*
* @param ossClient
* oss对象
* @param bucketName
* 存储空间
*/
public static void deleteBucket(OSSClient ossClient, String bucketName) {
ossClient.deleteBucket(bucketName);
logger.info("删除" + bucketName + "Bucket成功");
}

/**
* 创建模拟文件夹
*
* @param ossClient
* oss连接
* @param bucketName
* 存储空间
* @param folder
* 模拟文件夹名如"qj_nanjing/"
* @return 文件夹名
*/
public static String createFolder(OSSClient ossClient, String bucketName, String folder) {
// 文件夹名
final String keySuffixWithSlash = folder;
// 判断文件夹是否存在，不存在则创建
if (!ossClient.doesObjectExist(bucketName, keySuffixWithSlash)) {
// 创建文件夹
ossClient.putObject(bucketName, keySuffixWithSlash, new ByteArrayInputStream(new byte[0]));
logger.info("创建文件夹成功");
// 得到文件夹名
OSSObject object = ossClient.getObject(bucketName, keySuffixWithSlash);
String fileDir = object.getKey();
return fileDir;
}
return keySuffixWithSlash;
}

/**
* 根据key删除OSS服务器上的文件
*
* @param ossClient
* oss连接
* @param bucketName
* 存储空间
* @param folder
* 模拟文件夹名 如"qj_nanjing/"
* @param key
* Bucket下的文件的路径名+文件名 如："upload/cake.jpg"
*/
public static void deleteFile(OSSClient ossClient, String bucketName, String folder, String key) {
ossClient.deleteObject(bucketName, folder + key);
logger.info("删除" + bucketName + "下的文件" + folder + key + "成功");
}

/**
* 上传图片至OSS 文件流
*
* @param ossClient
* oss连接
* @param file
* 上传文件（文件全路径如：D:\\image\\cake.jpg）
* @param bucketName
* 存储空间
* @param folder
* 模拟文件夹名 如"qj_nanjing/"
* @return String 返回的唯一MD5数字签名
*/
public static String[] uploadObject2OSS(OSSClient ossClient, File file, String bucketName, String user_id) {
String resultStr = null;
String[] fo = new String[] { "", "" };
try {
// 以输入流的形式上传文件
String folder = "";
folder = FOLDER + user_id + "/" + FORMAT + "/";
InputStream is = new FileInputStream(file);
// 文件名
String timefile = FORMATS;
String fileName = file.getName();
fileName = timefile + fileName.substring(fileName.lastIndexOf("."));
logger.info("上传到路径" + folder + fileName);
// 文件大小
Long fileSize = file.length();
// 创建上传Object的Metadata
ObjectMetadata metadata = new ObjectMetadata();
// 上传的文件的长度
metadata.setContentLength(is.available());
// 指定该Object被下载时的网页的缓存行为
metadata.setCacheControl("no-cache");
// 指定该Object下设置Header
metadata.setHeader("Pragma", "no-cache");
// 指定该Object被下载时的内容编码格式
metadata.setContentEncoding("utf-8");
// 文件的MIME，定义文件的类型及网页编码，决定浏览器将以什么形式、什么编码读取文件。如果用户没有指定则根据Key或文件名的扩展名生成，
// 如果没有扩展名则填默认值application/octet-stream
metadata.setContentType(getContentType(fileName));
// 指定该Object被下载时的名称（指示MINME用户代理如何显示附加的文件，打开或下载，及文件名称）
metadata.setContentDisposition("filename/filesize=" + fileName + "/" + fileSize + "Byte.");
// 上传文件 (上传文件流的形式)
PutObjectResult putResult = ossClient.putObject(bucketName, folder + fileName, is, metadata);
// 解析结果
resultStr = putResult.getETag();
fo[1] = folder + fileName;
fo[0] = resultStr;

ossClient.shutdown();
} catch (Exception e) {
e.printStackTrace();
logger.error("上传阿里云OSS服务器异常." + e.getMessage(), e);
}
return fo;
}
//上传路径返回地址，图片视频都可以
//需要改变上传那文件位置FOLDER
public static String[] uploadObjectOSS(OSSClient ossClient, String file, String bucketName, String user_id) {
String resultStr = null;
String[] fo = new String[] { "", "" };
try {
// 以输入流的形式上传文件
String folder = "";
folder = FOLDER + user_id + "/" + FORMAT + "/";
// InputStream is = new FileInputStream(file);
// 文件名
String timefile = FORMATS;
// String fileName = file.getName();
file = timefile + file.substring(file.lastIndexOf("."));
logger.info("上传到路径" + folder + file);
// 文件大小
Integer fileSize = file.length();
// 创建上传Object的Metadata
ObjectMetadata metadata = new ObjectMetadata();
// // 上传的文件的长度
// metadata.setContentLength(is.available());
// 指定该Object被下载时的网页的缓存行为
metadata.setCacheControl("no-cache");
// 指定该Object下设置Header
metadata.setHeader("Pragma", "no-cache");
// 指定该Object被下载时的内容编码格式
metadata.setContentEncoding("utf-8");
// 文件的MIME，定义文件的类型及网页编码，决定浏览器将以什么形式、什么编码读取文件。如果用户没有指定则根据Key或文件名的扩展名生成，
// 如果没有扩展名则填默认值application/octet-stream
metadata.setContentType(getContentType(file));
// 指定该Object被下载时的名称（指示MINME用户代理如何显示附加的文件，打开或下载，及文件名称）
metadata.setContentDisposition("filename/filesize=" + file + "/" + fileSize + "Byte.");
// 上传文件 (上传文件流的形式)
PutObjectResult putResult = ossClient.putObject(bucketName, folder + file, new ByteArrayInputStream(file.getBytes("UTF-8")), metadata);
// 解析结果
resultStr = putResult.getETag();
fo[1] = folder + file;
fo[0] = resultStr;

ossClient.shutdown();
} catch (Exception e) {
e.printStackTrace();
logger.error("上传阿里云OSS服务器异常." + e.getMessage(), e);
}
return fo;
}
//上传视频
public static String uploadByteVideoOSS(OSSClient ossClient, byte[] b, String bucketName, String user_id) {

// byte[] content = "Hello OSS".getBytes();

// 以输入流的形式上传文件
String folder = "";
folder = FOLDER_VIDEO + user_id + "/" + FORMAT + "/";
// 文件名
String timefile = FORMATS;// 文件名
String fileName = ".MP4";// 后缀扩展名
fileName = timefile + fileName;
logger.info("上传到路径" + folder + fileName);

Long fileSize = (long) b.length;

// 创建上传Object的Metadata
ObjectMetadata metadata = new ObjectMetadata();
metadata.setContentLength(fileSize);
// 指定该Object被下载时的网页的缓存行为
metadata.setCacheControl("no-cache");
// 指定该Object下设置Header
metadata.setHeader("Pragma", "no-cache");
// 指定该Object被下载时的内容编码格式
metadata.setContentEncoding("utf-8");
// 文件的MIME，定义文件的类型及网页编码，决定浏览器将以什么形式、什么编码读取文件。如果用户没有指定则根据Key或文件名的扩展名生成，
// 如果没有扩展名则填默认值application/octet-stream
metadata.setContentType(getContentType(fileName));
// 指定该Object被下载时的名称（指示MINME用户代理如何显示附加的文件，打开或下载，及文件名称）
metadata.setContentDisposition("filename/filesize=" + fileName + "/" + fileSize + "Byte.");

PutObjectResult putResult = ossClient.putObject(bucketName, folder + fileName, new ByteArrayInputStream(b),
metadata);
ossClient.shutdown();
String filepath = folder + fileName;
return filepath;
}
//上传图片
public static String uploadByteOSS(OSSClient ossClient, byte[] b, String bucketName, String user_id) {

// byte[] content = "Hello OSS".getBytes();

// 以输入流的形式上传文件
String folder = "";
folder = FOLDER + user_id + "/" + FORMAT + "/";
// 文件名
String timefile = FORMATS;// 文件名
String fileName = ".jpg";// 后缀扩展名
fileName = timefile + fileName;
logger.info("上传到路径" + folder + fileName);

Long fileSize = (long) b.length;
// String timefile = FORMATS;
//// String fileName = file.getName();
// file = timefile + file.substring(file.lastIndexOf("."));
// 创建上传Object的Metadata
ObjectMetadata metadata = new ObjectMetadata();
metadata.setContentLength(fileSize);
// 指定该Object被下载时的网页的缓存行为
metadata.setCacheControl("no-cache");
// 指定该Object下设置Header
metadata.setHeader("Pragma", "no-cache");
// 指定该Object被下载时的内容编码格式
metadata.setContentEncoding("utf-8");
// 文件的MIME，定义文件的类型及网页编码，决定浏览器将以什么形式、什么编码读取文件。如果用户没有指定则根据Key或文件名的扩展名生成，
// 如果没有扩展名则填默认值application/octet-stream
metadata.setContentType(getContentType(fileName));
// 指定该Object被下载时的名称（指示MINME用户代理如何显示附加的文件，打开或下载，及文件名称）
metadata.setContentDisposition("filename/filesize=" + fileName + "/" + fileSize + "Byte.");

PutObjectResult putResult = ossClient.putObject(bucketName, folder + fileName, new ByteArrayInputStream(b),
metadata);
ossClient.shutdown();
String filepath = folder + fileName;
return filepath;
}

public static byte[] image2Bytes(String imgSrc) throws Exception {
FileInputStream fin = new FileInputStream(new File(imgSrc));
// 可能溢出,简单起见就不考虑太多,如果太大就要另外想办法，比如一次传入固定长度byte[]
byte[] bytes = new byte[fin.available()];
// 将文件内容写入字节数组，提供测试的case
fin.read(bytes);

fin.close();
return bytes;
}
//图片转化为byte数组
public static byte[] image2byte(String path) {
byte[] data = null;
FileImageInputStream input = null;
try {
input = new FileImageInputStream(new File(path));
ByteArrayOutputStream output = new ByteArrayOutputStream();
byte[] buf = new byte[1024];
int numBytesRead = 0;
while ((numBytesRead = input.read(buf)) != -1) {
output.write(buf, 0, numBytesRead);
}
data = output.toByteArray();
output.close();
input.close();
} catch (FileNotFoundException ex1) {
ex1.printStackTrace();
} catch (IOException ex1) {
ex1.printStackTrace();
}
return data;
}

/**
* 通过文件名判断并获取OSS服务文件上传时文件的contentType
*
* @param fileName
* 文件名
* @return 文件的contentType
*/
public static String getContentType(String fileName) {
// 文件的后缀名
String fileExtension = fileName.substring(fileName.lastIndexOf("."));
if (".bmp".equalsIgnoreCase(fileExtension)) {
return "image/bmp";
}
if (".gif".equalsIgnoreCase(fileExtension)) {
return "image/gif";
}
if (".jpeg".equalsIgnoreCase(fileExtension) || ".jpg".equalsIgnoreCase(fileExtension)
|| ".png".equalsIgnoreCase(fileExtension)) {
return "image/jpeg";
}
if (".html".equalsIgnoreCase(fileExtension)) {
return "text/html";
}
if (".txt".equalsIgnoreCase(fileExtension)) {
return "text/plain";
}
if (".vsd".equalsIgnoreCase(fileExtension)) {
return "application/vnd.visio";
}
if (".ppt".equalsIgnoreCase(fileExtension) || "pptx".equalsIgnoreCase(fileExtension)) {
return "application/vnd.ms-powerpoint";
}
if (".doc".equalsIgnoreCase(fileExtension) || "docx".equalsIgnoreCase(fileExtension)) {
return "application/msword";
}
if (".xml".equalsIgnoreCase(fileExtension)) {
return "text/xml";
}
if (".mp4".equalsIgnoreCase(fileExtension)) {
return "video/mp4";
}
// 默认返回类型
return "image/jpeg";
}

/**
* 获得url链接
*
* @param key
* @return
*/
public static String getUrl(OSSClient ossClient, String bucketName, String fileName) {
// 设置URL过期时间为10年 3600l* 1000*24*365*10
Date expiration = new Date(new Date().getTime() + 3600l * 1000 * 24 * 365 * 10);
// 生成URL
URL url = ossClient.generatePresignedUrl(bucketName, fileName, expiration);
if (url != null) {
return url.toString();
}
return "获网址路径出错";
}

public String urlpath(String user_id, String files) {
OSSClient ossClient = AliyunOSSClientUtil.getOSSClient();
String[] file = files.split(",");
String url = "";
for (String filename : file) {
// System.out.println("filename:"+filename);
File filess = new File(filename);
String[] s = AliyunOSSClientUtil.uploadObject2OSS(ossClient, filess, BACKET_NAME, user_id);
logger.info("上传后的文件MD5数字唯一签名:" + s[0]);
logger.info("文件路径:" + s[1]);
url = AliyunOSSClientUtil.getUrl(ossClient, BACKET_NAME, s[1]);
logger.info("访问网址路径:" + url);
}
// 上传后的文件MD5数字唯一签名:40F4131427068E08451D37F02021473A
return url;
}
public String uploadvideo(String url){
String user_id="localism";
String[] urllist=AliyunOSSClientUtil.uploadObject2OSS(AliyunOSSClientUtil.getOSSClient(), new File(url), BACKET_NAME, user_id);
String c=urllist[1];
return c;
}
// 测试
public static void main(String[] args) throws Exception {
// AliyunOSSClientUtil t = new AliyunOSSClientUtil();
// String url = t.uploadvideo("g:\\余杰的avi小视频.mp4");
// System.out.println(url);


// 初始化OSSClient
OSSClient ossClient = AliyunOSSClientUtil.getOSSClient();
// 上传文件
String files = "C:\\Users\\user\\Pictures\\微信图片_20220817171144.png";
String[] file = files.split(",");
String user_id = "3";

for (String filename : file) { //
System.out.println("filename:" + filename);
File filess = new File(filename);
String[] s = AliyunOSSClientUtil.uploadObject2OSS(ossClient, filess, BACKET_NAME, user_id);
System.out.println("上传后的文件MD5数字唯一签名:" + s[0]);
System.out.println("文件路径:" + s[1]);
String url = AliyunOSSClientUtil.getUrl(ossClient, BACKET_NAME, s[1]);
System.out.println("访问网址路径:" + url);
// 上传后的文件MD5数字唯一签名:40F4131427068E08451D37F02021473A
}
byte[] b1 = AliyunOSSClientUtil.image2byte("g:\\余杰AVI.png");
String str = "";
BASE64Decoder decoder = new BASE64Decoder();
byte[] b = decoder.decodeBuffer(str);
System.out.println(b.length);
// String path = AliyunOSSClientUtil.uploadByteVideoOSS(ossClient, b1, BACKET_NAME, user_id);
String path = AliyunOSSClientUtil.uploadByteOSS(ossClient, b1, BACKET_NAME, user_id);
// String path = AliyunOSSClientUtil.uploadObjectOSS(ossClient, b1, BACKET_NAME, user_id);
System.out.println(b1.length + "," + b1.toString());
System.out.println("文件路径:" + path);
String urls = AliyunOSSClientUtil.getUrl(ossClient, BACKET_NAME, path);
System.out.println("访问网址路径:" + urls);
}

}

MultipartFile 转 File

有很多小伙伴是使用 MultipartFile 接收的文件 这里 小宋提供一个转换的方法

public static File multipartFileToFile(MultipartFile multiFile) {
// 获取文件名
String fileName = multiFile.getOriginalFilename();
//文件为空返回null
if (!StringUtils.isNotEmpty(fileName)) {
return null;
}
// 获取文件后缀
String prefix = fileName.substring(fileName.lastIndexOf("."));
try {
File file = File.createTempFile(fileName, prefix);
multiFile.transferTo(file);
return file;
} catch (Exception e) {
log.error("MultipartFile转换为File转换异常：" + e.getMessage());
}
return null;
}