阿里云-OSS对象存储系统-代码整合

灰太狼 2023-02-20 02:54 194阅读 0赞

> ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIyMDQ5Nzcz_size_16_color_FFFFFF_t_70][]
> 
> aliyun-sdk-oss-3.8.0.jar  
> commons-codec-1.9.jar  
> commons-logging-1.2.jar  
> hamcrest-core-1.1.jar  
> httpclient-4.4.1.jar  
> httpcore-4.4.1.jar  
> jdom-1.1.jar
> 
> ### OssClientFactory.java ###
> 
>     package com.app.util;
>     
>     import java.util.Map;
>     import java.util.Set;
>     
>     import javax.annotation.PostConstruct;
>     
>     import org.apache.commons.lang.StringUtils;
>     import org.springframework.beans.factory.annotation.Autowired;
>     import org.springframework.stereotype.Component;
>     
>     import com.aliyun.oss.OSS;
>     import com.aliyun.oss.OSSClientBuilder;
>     import com.sunflower.sysset.dubbo.DubboParameterDao;
>     import com.sunflower.sysset.pojo.Parameter;
>     import com.sunflower.sysset.pojo.SuperParameter;
>     
>     /**
>      * 双端检索单例模式--》适用于并发场景
>      * OSSClient单例化工厂 使用ossClient单例化后,不可以再进行shutdown操作
>      */
>     @Component
>     public class OssClientFactory {
>     	
>     	@Autowired
>     	private DubboParameterDao dubboParameterDao;
>     	private static DubboParameterDao staticDubboParameterDao;
>     	
>     	//解决带static关键字的bean无法注入的问题
>     	@PostConstruct
>         public void init(){
>     		staticDubboParameterDao=this.dubboParameterDao;
>         }
>     
>     	// volatile是Java提供的一种轻量级的同步机制,在并发编程中,也扮演着比较重要的角色.
>     	// 同synchronized相比(synchronized通常称为重量级锁),volatile更轻量级,相比使用
>     	// synchronized所带来的庞大开销,倘若能恰当的合理的使用volatile,则wonderful
>     	private volatile static OSS client;
>     	
>     	private volatile static OSSClientBuilder ossClientBuilder;
>     	
>     	//后台参数管理模块中获取设置的参数值
>     	//终端地址：http://oss-cn-beijing.aliyuncs.com
>     	private static String endpoint;
>     	
>     	//访问key：LTAI4GH********EaxehDS1119999999
>     	private static String accessKeyId;
>     	
>     	//访问密钥：loVhvU9********jOa3TCKZHn999991111111
>     	private static String accessKeySecret;
>     	
>     	//存储空间集合字符串：bucketName1:path1,bucketName2:path2,bucketName3:path3
>     	private static String bucketNames;
>     	
>     	//存储空间集合：将bucketNames串，splic并put到map中，供调用者使用
>     	private static Map<String,String> bucketNameMap;
>     	
>     	private OssClientFactory() {
>     		
>     	}
>         
>     	public static OSS getOSSClient() {
>     		if (client == null) {
>     			synchronized (OssClientFactory.class) {
>     				if (client == null) {
>     					//OSS相关参数从mysql数据库中获取
>     					SuperParameter sp=staticDubboParameterDao.querySuperParametersByParameterCode(180000);
>     					if (sp != null) {
>     						Set<Parameter> sps=sp.getParameters();
>     						for (Parameter p : sps) {
>     							if (StringUtils.equals(p.getDescription(), "endpoint")) {
>     								endpoint = p.getParameterName();
>     							}
>     							if (StringUtils.equals(p.getDescription(), "accessKeyId")) {
>     								accessKeyId = p.getParameterName();
>     							}
>     							if (StringUtils.equals(p.getDescription(), "accessKeySecret")) {
>     								accessKeySecret = p.getParameterName();
>     							}
>     							if (StringUtils.equals(p.getDescription(), "bucketNames")) {
>     								bucketNames = p.getParameterName();
>     								if(StringUtils.isNotBlank(bucketNames)) {
>     									String[] KVs = bucketNames.split(",");
>     									for (String kv : KVs) {
>     										String[] k_v = kv.split(",");
>     										bucketNameMap.put(k_v[0], k_v[1]);
>     									}
>     								}
>     							}
>     						}
>     					}
>     					client = getOSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
>     				}
>     			}
>     		}
>     		return client;
>     	}
>     
>     	public static OSSClientBuilder getOSSClientBuilder() {
>     		System.out.println("获取OSSClientBuilder");
>     		if (ossClientBuilder == null) {
>     			System.out.println("OSSClientBuilder为空,创建中");
>     			synchronized (OssClientFactory.class) {
>     				if (ossClientBuilder == null) {
>     					System.out.println("进入同步实例化OSSClientBuilder");
>     					ossClientBuilder = new OSSClientBuilder();
>     				}
>     			}
>     		}
>     		return ossClientBuilder;
>     	}
>     
>     	public static String getEndpoint() {
>     		return endpoint;
>     	}
>     
>     	public static void setEndpoint(String endpoint) {
>     		OssClientFactory.endpoint = endpoint;
>     	}
>     
>     	public static String getAccessKeyId() {
>     		return accessKeyId;
>     	}
>     
>     	public static void setAccessKeyId(String accessKeyId) {
>     		OssClientFactory.accessKeyId = accessKeyId;
>     	}
>     
>     	public static String getAccessKeySecret() {
>     		return accessKeySecret;
>     	}
>     
>     	public static void setAccessKeySecret(String accessKeySecret) {
>     		OssClientFactory.accessKeySecret = accessKeySecret;
>     	}
>     
>     	public static Map<String, String> getBucketNameMap() {
>     		return bucketNameMap;
>     	}
>     
>     	public static void setBucketNameMap(Map<String, String> bucketNameMap) {
>     		OssClientFactory.bucketNameMap = bucketNameMap;
>     	}
>     	
>     }
> 
> ### OSSFileUpload.java ###
> 
>     package com.app.util;
>     
>     import java.io.BufferedInputStream;
>     import java.io.BufferedOutputStream;
>     import java.io.File;
>     import java.io.FileInputStream;
>     import java.io.IOException;
>     import java.io.InputStream;
>     import java.io.UnsupportedEncodingException;
>     import java.net.MalformedURLException;
>     import java.net.URL;
>     import java.net.URLConnection;
>     import java.net.URLEncoder;
>     import java.util.Date;
>     import java.util.HashMap;
>     import java.util.LinkedHashMap;
>     import java.util.Map;
>     import java.util.UUID;
>     
>     import javax.servlet.http.HttpServletRequest;
>     import javax.servlet.http.HttpServletResponse;
>     
>     import org.apache.commons.lang.StringUtils;
>     
>     import com.aliyun.oss.OSS;
>     import com.aliyun.oss.common.utils.BinaryUtil;
>     import com.aliyun.oss.model.MatchMode;
>     import com.aliyun.oss.model.ObjectMetadata;
>     import com.aliyun.oss.model.PolicyConditions;
>     import com.aliyun.oss.model.PutObjectRequest;
>     import com.aliyun.oss.model.PutObjectResult;
>     
>     import net.sf.json.JSONObject;
>     
>     public class OSSFileUpload {
>     	// 创建OSSClient实例。
>     	OSS ossClient = null;
>     
>     	/**
>     	 * @Description: TODO()
>     	 * @param bucketName
>     	 *            存储空间
>     	 * @date 2020年6月1日 下午3:17:27
>     	 */
>     	public OSSFileUpload() {
>     		super();
>     		this.ossClient = OssClientFactory.getOSSClient();
>     	}
>     
>     	/**
>     	 * 当前路径权限：公共读，私有写
>     	 * 
>     	 * @Title: fileUpload
>     	 * @Description: TODO(上传单个文件)
>     	 * @param fileName
>     	 *            本地文件名称
>     	 * @param filePath
>     	 *            本地文件路径
>     	 * @param ossFilePath
>     	 *            OSS上的文件存储路径
>     	 * @return String 上传资源的外网访问路径
>     	 * @date 2020年6月1日 下午2:53:49
>     	 */
>     	public String fileUpload(String bucketName,String fileName, String filePath, String ossFilePath) {
>     		String url="";
>     		try {
>     			File file = new File(filePath);
>     			url=fileUpload(bucketName,fileName, file, ossFilePath);
>     		} catch (Exception e) {
>     			e.printStackTrace();
>     			throw e;
>     		} finally {
>     			return url;
>     		}
>     	}
>     	
>     	
>     	/**
>     	  * @Title: fileUpload
>     	  * @Description: TODO(上传单个文件)
>     	  * @param fileName 文件名称
>     	  * @param file File
>     	  * @param ossFilePath  OSS上的文件存储路径
>     	  * @return String  上传资源的外网访问路径
>     	  * @date 2020年6月1日 下午10:56:45
>     	 */
>     	public String fileUpload(String bucketName,String fileName,File file,String ossFilePath) {
>     		String accessUrl = "";
>     		try {
>     			String ossfileName=System.currentTimeMillis()+fileName.substring(fileName.lastIndexOf("."));
>     			// 创建上传Object的Metadata
>     			ObjectMetadata objectMetadata = new ObjectMetadata();
>     			// objectMetadata.setContentLength(instream.available());
>     			objectMetadata.setCacheControl("no-cache");
>     			objectMetadata.setHeader("Pragma", "no-cache");
>     			objectMetadata.setContentType(getcontentType(fileName.substring(fileName.lastIndexOf("."))));
>     			objectMetadata.setContentDisposition("inline;filename=" + fileName);
>     			FileInputStream in=new FileInputStream(file);
>     			PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, ossFilePath + ossfileName,in);
>     			putObjectRequest.setMetadata(objectMetadata);
>     
>     			// 上传文件
>     			PutObjectResult putObject = ossClient.putObject(putObjectRequest);
>     			if (putObject != null) {
>     				accessUrl = OssClientFactory.getEndpoint().replace("http://", "http://" + bucketName + ".") + "/" + ossFilePath + ossfileName;
>     			}
>     		} catch (Exception e) {
>     			e.printStackTrace();
>     			throw e;
>     		} finally {
>     			/*if (ossClient != null) {
>     				// 关闭OSSClient。
>     				ossClient.shutdown();
>     			}*/
>     			return accessUrl;
>     		}
>     	}
>     	
>     	/**
>     	 * 下载
>     	 * @param filePath
>     	 * @param fileName
>     	 * @param request
>     	 * @param response
>     	 */
>         public void downloadFileByHttp(String filePath,String fileName,HttpServletRequest request, HttpServletResponse response){
>         	BufferedInputStream bis = null;
>     		BufferedOutputStream bos = null;
>     		URL url = null;
>     		URLConnection conn = null;
>     		try {
>     			url = new URL(filePath);
>     		} catch (MalformedURLException e) {
>     			// TODO Auto-generated catch block
>     			e.printStackTrace();
>     		}
>     		
>     		try {
>     			conn = url.openConnection();
>     			conn.setConnectTimeout(30000);
>     			conn.setReadTimeout(300000);
>     			InputStream inStream = conn.getInputStream();
>         		request.setCharacterEncoding("UTF-8");
>         		int index=fileName.lastIndexOf(".");
>     			if (request.getHeader("User-Agent").toUpperCase().indexOf("MSIE") > 0) {  
>     				fileName = URLEncoder.encode(fileName, "UTF-8");
>     			}else if(request.getHeader("User-Agent").toUpperCase().indexOf("FIREFOX") > 0){
>     				fileName = new String(fileName.trim().replace(" ","").replaceAll("　", "").getBytes("UTF-8"), "ISO8859-1");
>     			}else{  
>     				fileName = URLEncoder.encode(fileName, "UTF-8");
>     			}
>                 if(index==-1){
>                 	String fileSuffix = filePath.substring(filePath.lastIndexOf("."));
>                 	fileName=fileName+fileSuffix;
>                 }
>     			response.setHeader("Content-Disposition", "attachment; " + "filename="+ fileName);
>     
>     			bis = new BufferedInputStream(inStream);
>     			bos = new BufferedOutputStream(response.getOutputStream());
>     			byte[] buff = new byte[1024];
>     			int bytesRead;
>     			while (-1 != (bytesRead = bis.read(buff, 0, buff.length))) {
>     				bos.write(buff, 0, bytesRead);
>     			}
>     		} catch (IOException e) {
>     			// TODO Auto-generated catch block
>     			e.printStackTrace();
>     		}finally{
>     			try {
>     				conn.getInputStream().close();
>     				if(bis!=null){
>     					bis.close();
>     				}
>     				if(bos!=null){
>     					bos.close();
>     				}
>     			} catch (IOException e) {
>     				// TODO Auto-generated catch block
>     				e.printStackTrace();
>     			}
>     		}
>     	}
>     	
>     	/**
>     	  * @Title: delFile
>     	  * @Description: TODO(这里用一句话描述这个方法的作用)
>     	  * @param ossFileFullPath  文件所在bucket中的绝对路径
>     	  * @return boolean 
>     	  * @date 2020年6月1日 下午11:26:29
>     	 */
>     	public boolean delFile(String bucketName,String ossFileFullPath) {
>     		boolean result = true;
>     		try {
>     			// 删除文件。如需删除文件夹，请将ObjectName设置为对应的文件夹名称。如果文件夹非空，则需要将文件夹下的所有object删除后才能删除该文件夹。
>     			ossClient.deleteObject(bucketName, ossFileFullPath);
>     		} catch (Exception e) {
>     			result = false;
>     			e.printStackTrace();
>     			throw e;
>     		} finally {
>     			/*if (ossClient != null) {
>     				// 关闭OSSClient。
>     				ossClient.shutdown();
>     			}*/
>     			return result;
>     		}
>     	}
>     	
>     
>     	public String getcontentType(String FilenameExtension) {
>     		if (FilenameExtension.equalsIgnoreCase(".bmp")) {
>     			return "image/bmp";
>     		}
>     		if (FilenameExtension.equalsIgnoreCase(".gif")) {
>     			return "image/gif";
>     		}
>     		if (FilenameExtension.equalsIgnoreCase(".jpeg") || FilenameExtension.equalsIgnoreCase(".jpg")
>     				|| FilenameExtension.equalsIgnoreCase(".png")) {
>     			return "image/jpg";
>     		}
>     		if (FilenameExtension.equalsIgnoreCase(".html")) {
>     			return "text/html";
>     		}
>     		if (FilenameExtension.equalsIgnoreCase(".txt")) {
>     			return "text/plain";
>     		}
>     		if (FilenameExtension.equalsIgnoreCase(".vsd")) {
>     			return "application/vnd.visio";
>     		}
>     		if (FilenameExtension.equalsIgnoreCase(".pptx") || FilenameExtension.equalsIgnoreCase(".ppt")) {
>     			return "application/vnd.ms-powerpoint";
>     		}
>     		if (FilenameExtension.equalsIgnoreCase(".docx") || FilenameExtension.equalsIgnoreCase(".doc")) {
>     			return "application/msword";
>     		}
>     		if (FilenameExtension.equalsIgnoreCase(".xml")) {
>     			return "text/xml";
>     		}
>     		if (FilenameExtension.equalsIgnoreCase(".mp3")) {
>     			return "audio/mp3";
>     		}
>     		if (FilenameExtension.equalsIgnoreCase(".mp4")) {
>     			return "video/mp4";
>     		}
>     		if (FilenameExtension.equalsIgnoreCase(".pdf")) {
>     			return "application/pdf";
>     		}
>     		return "application/octet-stream";
>     	}
>     	
>     	/**
>          * @Description 生成签名
>          * @Author hzl
>          * @Date 2018/11/27
>          * @Param [callBack ：要进行回调的参数，传入为空即默认为不进行回调]
>          * @Return java.util.HashMap<java.lang.String       java.lang.Object>
>          */
>     	/**
>     	  * @Title: generate
>     	  * @Description: TODO(生成签名)
>     	  * @param dir 用户上传文件时指定的前缀
>     	  * @param fileSize 上传文件大小  M
>     	  * @param callBack 回调地址
>     	  * @throws Exception
>     	  * @return HashMap<String,Object> 
>     	  * @date 2020年6月8日 上午11:14:04
>     	 */
>     	public String generateSign(String dir,int fileSize,String callBack) throws Exception {
>             //获取上传oss需要的基本参数
>             if(StringUtils.isBlank(dir)) {
>             	dir="user-dir-prefix/";
>             }
>             //如果文件大小等于0或者大于50M，则重置为2M，防止非法上传操作
>             if(fileSize==0 || fileSize>50) {
>             	fileSize=2;
>             }
>             try {
>                 long expireTime = 30;
>                 long expireEndTime = System.currentTimeMillis() + expireTime * 1000;
>                 //生成的到期时间转换为s，并转换为String
>                 String expire = String.valueOf(expireEndTime / 1000);
>                 PolicyConditions policyConditions = new PolicyConditions();
>                 //PostObject请求最大可支持的文件大小为5 GB，即CONTENT_LENGTH_RANGE为5*1024*1024*1024=1048576000
>                 policyConditions.addConditionItem(PolicyConditions.COND_CONTENT_LENGTH_RANGE, 0, 1024*fileSize);
>                 //dir用户上传文件时指定的前缀
>                 policyConditions.addConditionItem(MatchMode.StartWith, PolicyConditions.COND_KEY, dir);
>                 //根据到期时间生成policy
>                 Date expiration = new Date(expireEndTime);
>                 String postPolicy = ossClient.generatePostPolicy(expiration, policyConditions);
>                 //生成signature
>                 String postSignature = ossClient.calculatePostSignature(postPolicy);
>                 //对policy进行UTF-8编码后转base64
>                 byte[] binaryData = postPolicy.getBytes("utf-8");
>                 String encodedPolicy = BinaryUtil.toBase64String(binaryData);
>                 //生成上传文件的文件名
>                 String fileName = UUID.randomUUID().toString();
>                 //封装生成好的数据进行参数返回
>                 HashMap<String, Object> respMap = new LinkedHashMap<String, Object>();
>                 respMap.put("host", OssClientFactory.getEndpoint());
>                 respMap.put("accessid", OssClientFactory.getAccessKeyId());
>                 respMap.put("policy", encodedPolicy);
>                 respMap.put("signature", postSignature);
>                 respMap.put("expire", expire);
>                 respMap.put("dir", dir);
>                 respMap.put("fileName", fileName);
>                 //callBack不为空时为OSS回调web服务上传
>                 if (callBack != null && callBack != "") {
>                     respMap.put("callback", callBack);
>                 }
>                 JSONObject ja1 = JSONObject.fromObject(respMap);
>                 return ja1.toString();
>             } catch (Exception e) {
>             	e.printStackTrace();
>                 throw new Exception("生成OSS上传签名失败！");
>             }
>         }
>     	
>     	/**
>     	  * @Title: generateCallBack
>     	  * @Description: TODO(OSS回调系统服务参数生成)
>     	  * @param callBackHost：要OSS进行回调的服务域名（不带http）
>     	  * @param callBackInterFace：要进行回调的接口（oss上传结束进行请求的接口）
>     	  * @param callBackBody：进行回调时携带的参数（以：key=value 的形式进行携带）
>     	  * @throws UnsupportedEncodingException
>     	  * @return String 
>     	  * @date 2020年6月8日 下午1:31:21
>     	 */
>         public String generateCallBack(String callBackHost, String callBackInterFace, String callBackBody) throws UnsupportedEncodingException {
>             Map<String, Object> callbackMap = new HashMap<String, Object>();
>             callbackMap.put("callbackUrl", "http://" + callBackHost + callBackInterFace);
>             callbackMap.put("callbackHost", callBackHost);
>             callbackMap.put("callbackBody", callBackBody);
>             callbackMap.put("callbackBodyType", "application/x-www-form-urlencoded");
>             byte[] callBack = JSONObject.fromObject(callbackMap).toString().getBytes("utf-8");
>             String callBackString = BinaryUtil.toBase64String(callBack);
>             return callBackString;
>         }
>         
>     
>     }
> 
>

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIyMDQ5Nzcz_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/2020062217250954.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIyMDQ5Nzcz,size_16,color_FFFFFF,t_70