集成阿里云oss上傳

1 提供上傳需要的參數(shù)給前端
/**
* 開啟文件上傳
*
* @return
*/
@GetMapping(value = "/policy")
public RespDTO createTransaction() throws Exception {

    //原始方式
    OSSClient ossClientForDirect = new OSSClient(jingvideoProperties.getOSSENDPOINT(), jingvideoProperties.getAccessKeyID(), jingvideoProperties.getAppSecret());
    String host = "https://" + jingvideoProperties.getStoreName() + "." + jingvideoProperties.getOSSENDPOINT();
    String dir = jingvideoProperties.getDir();

    Date expiration = PhotoDateUtil.getExpiredDate(2);
    PolicyConditions policyConds = new PolicyConditions();
    policyConds.addConditionItem(PolicyConditions.COND_CONTENT_LENGTH_RANGE, 0, 1048576000);
    policyConds.addConditionItem(MatchMode.StartWith, PolicyConditions.COND_KEY, dir);

    String postPolicy = ossClientForDirect.generatePostPolicy(expiration, policyConds);
    byte[] binaryData = postPolicy.getBytes("utf-8");
    String encodedPolicy = BinaryUtil.toBase64String(binaryData);
    String postSignature = ossClientForDirect.calculatePostSignature(postPolicy);

    Map<String, String> respMap = new LinkedHashMap<String, String>();
    respMap.put("accessid", jingvideoProperties.getAccessKeyID());

    respMap.put("policy", encodedPolicy);
    respMap.put("signature", postSignature);
    respMap.put("dir", dir);
    respMap.put("host", host);
    respMap.put("expire", String.valueOf(expiration.getTime() / 1000));

    return RespDTO.onSuc(respMap);
}

2 上傳成功后阿里云調(diào) 回調(diào)接口令蛉,ossCallbackBody是自定義的參數(shù)

/**
* 提供給oss服務(wù)器回調(diào)的地址
* @param ossCallbackBody
* @param authorization
* @param publicKeyUrlBase64
* @param request
* @param response
* @return
*/
@RequestMapping(value = "oss/callback", method = {RequestMethod.POST,RequestMethod.GET})
public String callback(@RequestBody String ossCallbackBody,
@RequestHeader("Authorization") String authorization,
@RequestHeader("x-oss-pub-key-url") String publicKeyUrlBase64,
HttpServletRequest request,
HttpServletResponse response) throws Exception{
logger.info("ossCallbackBody:{}", ossCallbackBody);
logger.info("authorization:{}",authorization);
logger.info("publicKeyUrlBase64:{}", publicKeyUrlBase64);

    //驗(yàn)證是不是oss發(fā)過來的回調(diào)請求
    boolean isOssCallback = CallbackUtil.VerifyOSSCallbackRequest(request, ossCallbackBody);

    if (isOssCallback) {
        JSONObject jsonObject = JSON.parseObject(ossCallbackBody);
        Integer id = Integer.valueOf(jsonObject.get("albumId").toString());
        String key = (String) jsonObject.get("objectKey");
        videoService.insertVideo(id, key);
        response.setStatus(HttpServletResponse.SC_OK);
        logger.info("oss/callback==================== : success");
        JSONObject json = new JSONObject();
        json.put("success",true);
        return json.toString();
    } else {
        response.setStatus(HttpServletResponse.SC_BAD_REQUEST);
        logger.info("oss/callback=============== : false");
        JSONObject json = new JSONObject();
        json.put("success",false);
        return json.toString();
    }
}

3阿里云jdk的工具類啰扛,用來驗(yàn)證簽名(是否是阿里云oss的回調(diào)請求)

package com.jingdaka.photo_backend.utils;

import com.aliyun.oss.common.utils.BinaryUtil;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;

import javax.servlet.http.HttpServletRequest;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URI;
import java.security.KeyFactory;
import java.security.PublicKey;
import java.security.spec.X509EncodedKeySpec;

public class CallbackUtil {

public static boolean VerifyOSSCallbackRequest(HttpServletRequest request, String ossCallbackBody) throws NumberFormatException, IOException
{
    boolean ret = false;
    String autorizationInput = new String(request.getHeader("Authorization"));
    String pubKeyInput = request.getHeader("x-oss-pub-key-url");
    byte[] authorization = BinaryUtil.fromBase64String(autorizationInput);
    byte[] pubKey = BinaryUtil.fromBase64String(pubKeyInput);
    String pubKeyAddr = new String(pubKey);
    if (!pubKeyAddr.startsWith("http://gosspublic.alicdn.com/") && !pubKeyAddr.startsWith("https://gosspublic.alicdn.com/"))
    {
        System.out.println("pub key addr must be oss addrss");
        return false;
    }
    String retString = executeGet(pubKeyAddr);
    retString = retString.replace("-----BEGIN PUBLIC KEY-----", "");
    retString = retString.replace("-----END PUBLIC KEY-----", "");
    String queryString = request.getQueryString();
    String uri = request.getRequestURI();
    String decodeUri = java.net.URLDecoder.decode(uri, "UTF-8");
    String authStr = decodeUri;
    if (queryString != null && !queryString.equals("")) {
        authStr += "?" + queryString;
    }
    authStr += "\n" + ossCallbackBody;
    ret = doCheck(authStr, authorization, retString);
    return ret;
}

public static boolean doCheck(String content, byte[] sign, String publicKey) {
    try {
        KeyFactory keyFactory = KeyFactory.getInstance("RSA");
        byte[] encodedKey = BinaryUtil.fromBase64String(publicKey);
        PublicKey pubKey = keyFactory.generatePublic(new X509EncodedKeySpec(encodedKey));
        java.security.Signature signature = java.security.Signature.getInstance("MD5withRSA");
        signature.initVerify(pubKey);
        signature.update(content.getBytes());
        boolean bverify = signature.verify(sign);
        return bverify;

    } catch (Exception e) {
        e.printStackTrace();
    }

    return false;
}

@SuppressWarnings({ "finally" })
public static String executeGet(String url) {
    BufferedReader in = null;

    String content = null;
    try {
        // 定義HttpClient
        @SuppressWarnings("resource")
        DefaultHttpClient client = new DefaultHttpClient();
        // 實(shí)例化HTTP方法
        HttpGet request = new HttpGet();
        request.setURI(new URI(url));
        HttpResponse response = client.execute(request);

        in = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
        StringBuffer sb = new StringBuffer("");
        String line = "";
        String NL = System.getProperty("line.separator");
        while ((line = in.readLine()) != null) {
            sb.append(line + NL);
        }
        in.close();
        content = sb.toString();
    } catch (Exception e) {
    } finally {
        if (in != null) {
            try {
                in.close();// 最后要關(guān)閉BufferedReader
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        return content;
    }
}

}

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市莺褒,隨后出現(xiàn)的幾起案子异吻,更是在濱河造成了極大的恐慌迈窟,老刑警劉巖茂洒,帶你破解...
    沈念sama閱讀 222,807評論 6 518
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件威根,死亡現(xiàn)場離奇詭異,居然都是意外死亡嘴脾,警方通過查閱死者的電腦和手機(jī)湘换,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,284評論 3 399
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來统阿,“玉大人,你說我怎么就攤上這事筹我》銎剑” “怎么了?”我有些...
    開封第一講書人閱讀 169,589評論 0 363
  • 文/不壞的土叔 我叫張陵蔬蕊,是天一觀的道長结澄。 經(jīng)常有香客問我,道長岸夯,這世上最難降的妖魔是什么麻献? 我笑而不...
    開封第一講書人閱讀 60,188評論 1 300
  • 正文 為了忘掉前任,我火速辦了婚禮猜扮,結(jié)果婚禮上勉吻,老公的妹妹穿的比我還像新娘。我一直安慰自己旅赢,他們只是感情好齿桃,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,185評論 6 398
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著煮盼,像睡著了一般短纵。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上僵控,一...
    開封第一講書人閱讀 52,785評論 1 314
  • 那天香到,我揣著相機(jī)與錄音,去河邊找鬼报破。 笑死悠就,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的充易。 我是一名探鬼主播理卑,決...
    沈念sama閱讀 41,220評論 3 423
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼蔽氨!你這毒婦竟也來了藐唠?” 一聲冷哼從身側(cè)響起帆疟,我...
    開封第一講書人閱讀 40,167評論 0 277
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎宇立,沒想到半個(gè)月后踪宠,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 46,698評論 1 320
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡妈嘹,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,767評論 3 343
  • 正文 我和宋清朗相戀三年柳琢,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片润脸。...
    茶點(diǎn)故事閱讀 40,912評論 1 353
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡柬脸,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出毙驯,到底是詐尸還是另有隱情倒堕,我是刑警寧澤,帶...
    沈念sama閱讀 36,572評論 5 351
  • 正文 年R本政府宣布爆价,位于F島的核電站垦巴,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏铭段。R本人自食惡果不足惜骤宣,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,254評論 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望序愚。 院中可真熱鬧憔披,春花似錦、人聲如沸爸吮。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,746評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽拗胜。三九已至蔗候,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間埂软,已是汗流浹背锈遥。 一陣腳步聲響...
    開封第一講書人閱讀 33,859評論 1 274
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留勘畔,地道東北人所灸。 一個(gè)月前我還...
    沈念sama閱讀 49,359評論 3 379
  • 正文 我出身青樓,卻偏偏與公主長得像炫七,于是被迫代替她去往敵國和親爬立。 傳聞我的和親對象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,922評論 2 361

推薦閱讀更多精彩內(nèi)容