| | |
| | | package com.stylefeng.guns.core.util; |
| | | |
| | | import com.obs.services.ObsClient; |
| | | import com.obs.services.model.ObjectMetadata; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import javax.servlet.http.HttpServletRequest; |
| | | import java.io.IOException; |
| | | import java.io.InputStream; |
| | | import java.util.UUID; |
| | | |
| | | public class ObsUploadUtil { |
| | | //OBS图片访问域名 |
| | | public static String endPoint = "obs.cn-east-3.myhuaweicloud.com"; |
| | | public static String accessKeyId = "HB7DOVELEVWYYUS7QHYX"; |
| | | public static String accessKeySecret = "nEwDoSdLRkA1BRfW17pMZL9RlnrVywuTeHSkMn7y"; |
| | | public static String bucketName = "mian-ju-mi-liao"; |
| | | public static String oss_domain = "https://mian-ju-mi-liao.obs.cn-east-3.myhuaweicloud.com/"; |
| | | |
| | | |
| | | // 创建ObsClient实例 |
| | | public static ObsClient obsClient = new ObsClient(accessKeyId, accessKeySecret, endPoint); |
| | | |
| | | public static String obsUpload(HttpServletRequest request, MultipartFile file) throws IOException{ |
| | | //CommonsMultipartFile file = (CommonsMultipartFile)multipartFile; |
| | | String fileName = ""; |
| | | if(file!=null && !"".equals(file.getOriginalFilename()) && file.getOriginalFilename()!=null){ |
| | | InputStream content = file.getInputStream();//获得指定文件的输入流 |
| | | ObjectMetadata meta = new ObjectMetadata();// 创建上传Object的Metadata |
| | | meta.setContentLength(file.getSize()); // 必须设置ContentLength |
| | | String originalFilename = file.getOriginalFilename(); |
| | | fileName = UUID.randomUUID().toString().replaceAll("-","") + originalFilename.subSequence(originalFilename.lastIndexOf("."), originalFilename.length()); |
| | | obsClient.putObject(bucketName,"admin/"+fileName,content,meta);// 上传Object. |
| | | if(fileName != null && !"".equals(fileName)){ |
| | | System.out.println(fileName); |
| | | fileName = oss_domain+"admin/"+fileName; |
| | | } |
| | | } |
| | | return fileName; |
| | | } |
| | | |
| | | /** |
| | | * 删除某个Object |
| | | * |
| | | * @param bucketUrl |
| | | * @return |
| | | */ |
| | | public static boolean deleteObject(String bucketUrl) { |
| | | try { |
| | | bucketUrl=bucketUrl.replace(oss_domain+"web",""); |
| | | // 删除Object. |
| | | obsClient.deleteObject(bucketName, bucketUrl); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | return false; |
| | | } finally { |
| | | //ossClient.shutdown(); |
| | | } |
| | | return true; |
| | | } |
| | | |
| | | // public static void createBucket(String bucketName) |
| | | // { |
| | | // //初始化 OSSClient |
| | | //// ossClient = new OssClient(endPoint, accessKeyId, accessKeySecret); |
| | | //package com.stylefeng.guns.core.util; |
| | | // |
| | | // // 新建一个Bucket |
| | | // Bucket bucket = ossClient.createBucket(bucketName); |
| | | // System.out.println(bucket.getName()); |
| | | // System.out.println(bucket.getCreationDate()); |
| | | //import com.obs.services.ObsClient; |
| | | //import com.obs.services.model.ObjectMetadata; |
| | | //import org.springframework.web.multipart.MultipartFile; |
| | | // |
| | | //import javax.servlet.http.HttpServletRequest; |
| | | //import java.io.IOException; |
| | | //import java.io.InputStream; |
| | | //import java.util.UUID; |
| | | // |
| | | //public class ObsUploadUtil { |
| | | // //OBS图片访问域名 |
| | | // public static String endPoint = "obs.cn-east-3.myhuaweicloud.com"; |
| | | // public static String accessKeyId = "HB7DOVELEVWYYUS7QHYX"; |
| | | // public static String accessKeySecret = "nEwDoSdLRkA1BRfW17pMZL9RlnrVywuTeHSkMn7y"; |
| | | // public static String bucketName = "mian-ju-mi-liao"; |
| | | // public static String oss_domain = "https://mian-ju-mi-liao.obs.cn-east-3.myhuaweicloud.com/"; |
| | | // |
| | | // |
| | | // // 创建ObsClient实例 |
| | | // public static ObsClient obsClient = new ObsClient(accessKeyId, accessKeySecret, endPoint); |
| | | // |
| | | // public static String obsUpload(HttpServletRequest request, MultipartFile file) throws IOException{ |
| | | // //CommonsMultipartFile file = (CommonsMultipartFile)multipartFile; |
| | | // String fileName = ""; |
| | | // if(file!=null && !"".equals(file.getOriginalFilename()) && file.getOriginalFilename()!=null){ |
| | | // InputStream content = file.getInputStream();//获得指定文件的输入流 |
| | | // ObjectMetadata meta = new ObjectMetadata();// 创建上传Object的Metadata |
| | | // meta.setContentLength(file.getSize()); // 必须设置ContentLength |
| | | // String originalFilename = file.getOriginalFilename(); |
| | | // fileName = UUID.randomUUID().toString().replaceAll("-","") + originalFilename.subSequence(originalFilename.lastIndexOf("."), originalFilename.length()); |
| | | // obsClient.putObject(bucketName,"admin/"+fileName,content,meta);// 上传Object. |
| | | // if(fileName != null && !"".equals(fileName)){ |
| | | // System.out.println(fileName); |
| | | // fileName = oss_domain+"admin/"+fileName; |
| | | // } |
| | | // } |
| | | // return fileName; |
| | | // } |
| | | // |
| | | // public static void main(String[] args) { |
| | | // OssUploadUtil.createBucket("ssfdfsd"); |
| | | // /** |
| | | // * 删除某个Object |
| | | // * |
| | | // * @param bucketUrl |
| | | // * @return |
| | | // */ |
| | | // public static boolean deleteObject(String bucketUrl) { |
| | | // try { |
| | | // bucketUrl=bucketUrl.replace(oss_domain+"web",""); |
| | | // // 删除Object. |
| | | // obsClient.deleteObject(bucketName, bucketUrl); |
| | | // } catch (Exception e) { |
| | | // e.printStackTrace(); |
| | | // return false; |
| | | // } finally { |
| | | // //ossClient.shutdown(); |
| | | // } |
| | | } |
| | | // return true; |
| | | // } |
| | | // |
| | | //// public static void createBucket(String bucketName) |
| | | //// { |
| | | //// //初始化 OSSClient |
| | | ////// ossClient = new OssClient(endPoint, accessKeyId, accessKeySecret); |
| | | //// |
| | | //// // 新建一个Bucket |
| | | //// Bucket bucket = ossClient.createBucket(bucketName); |
| | | //// System.out.println(bucket.getName()); |
| | | //// System.out.println(bucket.getCreationDate()); |
| | | //// } |
| | | //// |
| | | //// public static void main(String[] args) { |
| | | //// OssUploadUtil.createBucket("ssfdfsd"); |
| | | //// } |
| | | //} |