1. 程式人生 > >spring boot 圖片上傳阿里雲oss雲端儲存

spring boot 圖片上傳阿里雲oss雲端儲存

上傳阿里雲工具類:

package com.example.demo.common;
import java.io.*;
import java.net.URL;
import java.util.Date;
import java.util.Random;


import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import com.aliyun.oss.OSSClient;
import com.aliyun.oss.model.ObjectMetadata;
import
com.aliyun.oss.model.PutObjectResult; import org.springframework.context.annotation.Bean; import org.springframework.util.StringUtils; import org.springframework.web.multipart.MultipartFile; /** * Created by Administrator on 2018/1/27 0027. */ public class OSSClientUtil { Log log = LogFactory.getLog(OSSClientUtil.class); // endpoint以杭州為例,其它region請按實際情況填寫
protected static String endpoint = "http://oss-cn-shanghai.aliyuncs.com"; protected static String accessKeyId = "你的accessKeyId"; protected static String accessKeySecret = "你的accessKeySecret"; protected static String bucketName = "weishang-fc"; //檔案儲存目錄 private String filedir = "imgupload/"
; private OSSClient ossClient; public OSSClientUtil() { ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret); } /** * 初始化 */ public void init() { ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret); } /** * 銷燬 */ public void destory() { ossClient.shutdown(); } /** * 上傳圖片 * * @param url */ public void uploadImg2Oss(String url) throws Exception { File fileOnServer = new File(url); FileInputStream fin; try { fin = new FileInputStream(fileOnServer); String[] split = url.split("/"); this.uploadFile2OSS(fin, split[split.length - 1]); } catch (FileNotFoundException e) { throw new Exception("圖片上傳失敗01"); } } public String uploadImg2Oss(MultipartFile file) throws Exception { if (file.getSize() > 1024 * 1024) { throw new Exception("上傳圖片大小不能超過1M!"); } String originalFilename = file.getOriginalFilename(); String substring = originalFilename.substring(originalFilename.lastIndexOf(".")).toLowerCase(); Random random = new Random(); String name = random.nextInt(10000) + System.currentTimeMillis() + substring; try { InputStream inputStream = file.getInputStream(); this.uploadFile2OSS(inputStream, name); return name; } catch (Exception e) { throw new Exception("圖片上傳失敗02"); } } /** * 獲得圖片路徑 * * @param fileUrl * @return */ public String getImgUrl(String fileUrl) { if (!StringUtils.isEmpty(fileUrl)) { String[] split = fileUrl.split("/"); return this.getUrl(this.filedir + split[split.length - 1]); } return null; } /** * 上傳到OSS伺服器 如果同名檔案會覆蓋伺服器上的 * * @param instream 檔案流 * @param fileName 檔名稱 包括字尾名 * @return 出錯返回"" ,唯一MD5數字簽名 */ public String uploadFile2OSS(InputStream instream, String fileName) { String ret = ""; try { //建立上傳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); //上傳檔案 PutObjectResult putResult = ossClient.putObject(bucketName, filedir + fileName, instream, objectMetadata); ret = putResult.getETag(); } catch (IOException e) { log.error(e.getMessage(), e); } finally { try { if (instream != null) { instream.close(); } } catch (IOException e) { e.printStackTrace(); } } return ret; } /** * Description: 判斷OSS服務檔案上傳時檔案的contentType * * @param FilenameExtension 檔案字尾 * @return String */ public static 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/jpeg"; } 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"; } return "image/jpeg"; } /** * 獲得url連結 * * @param key * @return */ public String getUrl(String key) { // 設定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, key, expiration); if (url != null) { return url.toString(); } return null; } }

service:(這個根據需要,也可以省略直接在controller裡面寫)

@Service
public class UpDownServiceImpl {

    private OSSClientUtil ossClient=new OSSClientUtil();
    public String updateHead(MultipartFile file, long userId) throws Exception {
        if (file == null || file.getSize() <= 0) {
            throw new Exception("頭像不能為空");
        }
        String name = ossClient.uploadImg2Oss(file);
        String imgUrl = ossClient.getImgUrl(name);
        //userDao.updateHead(userId, imgUrl);//只是本地上傳使用的
        return imgUrl;
    }
}

controller:

@Controller
@RequestMapping("/user")
public class UserController {

//處理檔案上傳
    @RequestMapping(value="/testuploadimg", method = RequestMethod.POST)
    @ResponseBody
    /*public  String uploadImg(@RequestParam("file") MultipartFile file,
                             HttpServletRequest request) {*/
        public Map<String, Object> headImgUpload(HttpServletRequest request,@RequestParam("file")MultipartFile file) {
            Map<String, Object> value = new HashMap<String, Object>();
            value.put("success", true);
            value.put("errorCode", 0);
            value.put("errorMsg", "");
            try {
                String head = upDownServiceImpl.updateHead(file, 4);//此處是呼叫上傳服務介面,4是需要更新的userId 測試資料。
                value.put("data", head);
            } catch (IOException e) {
                e.printStackTrace();
                value.put("success", false);
                value.put("errorCode", 200);
                value.put("errorMsg", "圖片上傳失敗");
            } catch (Exception e) {
                e.printStackTrace();
            }
        return value; 
    }
}

前端頁面:

<!--檔案上傳-->
        <div style="border: solid 1px">
            <form enctype="multipart/form-data" method="post" th:action= "@{/user/testuploadimg}">
                圖片<input type="file" name="file"/>
                <input type="submit" value="上傳"/>
            </form>
        </div>

我自己搗鼓了半天的小坑:
bucket.oss-cn-hangzhou.aliyuncs.com 不要填類似這樣的
應該直接填Endpoint,如:
oss-cn-shanghai.aliyuncs.com
我一直寫成:

// endpoint以杭州為例,其它region請按實際情況填寫
    protected static String endpoint = "http://weishang-fc.oss-cn-shanghai.aliyuncs.com";
    protected static String accessKeyId  = "xx";
    protected static String accessKeySecret  = "xx";
    protected static String bucketName  = "weishang-fc"; 

正確應該是這樣:

   // endpoint以杭州為例,其它region請按實際情況填寫
    protected static String endpoint = "http://oss-cn-shanghai.aliyuncs.com";
    protected static String accessKeyId  = "xx";
    protected static String accessKeySecret  = "xx";
    protected static String bucketName  = "weishang-fc"; 

這裡只是簡單的單個圖片/檔案的上傳,記錄下來,方便下次使用。