devbox
2023面试高手
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

阿里云视频点播获取视频点播的video信息_c# 阿里云视频点播获取点播视频列表信息

作者：2023面试高手 | 2024-04-29 11:54:27

赞

踩

c# 阿里云视频点播获取点播视频列表信息

背景

因为在项目中需要使用阿里云的视频点播服务，需要获取视频点播的时长信息。

工具类

生成签名串Signature
SignatureUtils.java


package com.meeno.wzq.alibaba.signature;

import com.google.common.collect.Maps;
import com.meeno.framework.util.HttpUtils;
import lombok.extern.java.Log;
import sun.misc.BASE64Encoder;

import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.security.SignatureException;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * @description: 生成签名串Signature
 * @author: Wzq
 * @create: 2020-01-14 17:38
 */
@Log
public class SignatureUtils {


    /*对所有参数名称和参数值做URL编码*/
    public static List<String> getAllParams(Map<String, String> publicParams, Map<String, String> privateParams) {
        List<String> encodeParams = new ArrayList<String>();
        if (publicParams != null) {
            for (String key : publicParams.keySet()) {
                String value = publicParams.get(key);
                //将参数和值都urlEncode一下。
                String encodeKey = percentEncode(key);
                String encodeVal = percentEncode(value);
                encodeParams.add(encodeKey + "=" + encodeVal);
            }
        }
        if (privateParams != null) {
            for (String key : privateParams.keySet()) {
                String value = privateParams.get(key);
                //将参数和值都urlEncode一下。
                String encodeKey = percentEncode(key);
                String encodeVal = percentEncode(value);
                encodeParams.add(encodeKey + "=" + encodeVal);
            }
        }
        return encodeParams;
    }
    /*获取 CanonicalizedQueryString*/
    public static String getCQS(List<String> allParams) {
        ParamsComparator paramsComparator = new ParamsComparator();
        Collections.sort(allParams, paramsComparator);
        String cqString = "";
        for (int i = 0; i < allParams.size(); i++) {
            cqString += allParams.get(i);
            if (i != allParams.size() - 1) {
                cqString += "&";
            }
        }
        return cqString;
    }
    /*字符串参数比较器，按字母序升序*/
    public static class ParamsComparator implements Comparator<String> {
        @Override
        public int compare(String lhs, String rhs) {
            return lhs.compareTo(rhs);
        }
    }

    public static byte[] hmacSHA1Signature(String accessKeySecret, String stringToSign) {
        try {
            String key = accessKeySecret + "&";
            try {
                SecretKeySpec signKey = new SecretKeySpec(key.getBytes(), "HmacSHA1");
                Mac mac = Mac.getInstance("HmacSHA1");
                mac.init(signKey);
                return mac.doFinal(stringToSign.getBytes());
            } catch (Exception e) {
                throw new SignatureException("Failed to generate HMAC : " + e.getMessage());
            }
        } catch (SignatureException e) {
            e.printStackTrace();
        }
        return null;
    }


    public static String newStringByBase64(byte[] bytes)
            throws UnsupportedEncodingException {
        if (bytes == null || bytes.length == 0) {
            return null;
        }
        return new String(new BASE64Encoder().encode(bytes));
    }

    /*特殊字符替换为转义字符*/
    public static String percentEncode(String value) {
        try {
            String urlEncodeOrignStr = URLEncoder.encode(value, "UTF-8");
            String plusReplaced = urlEncodeOrignStr.replace("+", "%20");
            String starReplaced = plusReplaced.replace("*", "%2A");
            String waveReplaced = starReplaced.replace("%7E", "~");
            return waveReplaced;
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        return value;
    }

    /*生成当前UTC时间戳Time*/
    public static String generateTimestamp() {
        Date date = new Date(System.currentTimeMillis());
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss'Z'");
        df.setTimeZone(new SimpleTimeZone(0, "GMT"));
        return df.format(date);
    }

    /*生成随机数SignatureNonce*/
    public static String generateRandom() {
        String signatureNonce = UUID.randomUUID().toString();
        return signatureNonce;
    }

}



  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
  • 105
  • 106
  • 107
  • 108
  • 109
  • 110
  • 111
  • 112
  • 113
  • 114
  • 115
  • 116
  • 117
  • 118
  • 119
  • 120
  • 121
  • 122
  • 123
  • 124
  • 125
  • 126
  • 127

httpUtils.java
请求工具类

package com.meeno.framework.util;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Lists;
import com.meeno.encryptionmodule.testPaper.service.TestpaperServiceImpl;
import com.meeno.wzq.config.PlatformServerConfig;
import com.meeno.wzq.constants.EncryptionConstants;
import com.meeno.wzq.constants.PlatformUrlEnum;
import org.apache.http.*;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.HttpRequestRetryHandler;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.protocol.HttpClientContext;
import org.apache.http.client.utils.URLEncodedUtils;
import org.apache.http.conn.ConnectTimeoutException;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.params.CoreConnectionPNames;
import org.apache.http.protocol.HttpContext;

import java.io.*;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.net.URI;
import java.net.UnknownHostException;
import java.util.*;

/**
 * @Auther: Wzq
 * @Date: 2019/4/2 11:20
 * @Description: 得不到的永远在骚动，被偏爱的都有恃无恐。 -- HttpUtils
 */
public class HttpUtils {


    private final static PoolingHttpClientConnectionManager poolConnManager = new PoolingHttpClientConnectionManager();  //连接池管理器
    private final static HttpRequestRetryHandler httpRequestRetryHandler = new HttpRequestRetryHandler() {  //retry handler
        public boolean retryRequest(IOException exception,
                                    int executionCount, HttpContext context) {
            if (executionCount >= 5) {
                return false;
            }
            if (exception instanceof NoHttpResponseException) {
                return true;
            }
            if (exception instanceof InterruptedIOException) {
                return false;
            }
            if (exception instanceof UnknownHostException) {
                return false;
            }
            if (exception instanceof ConnectTimeoutException) {
                return false;
            }
            HttpClientContext clientContext = HttpClientContext
                    .adapt(context);
            HttpRequest request = clientContext.getRequest();

            if (!(request instanceof HttpEntityEnclosingRequest)) {
                return true;
            }
            return false;
        }
    };

    static {   //类加载的时候 设置最大连接数 和 每个路由的最大连接数
        poolConnManager.setMaxTotal(200000);
        poolConnManager.setDefaultMaxPerRoute(100000);
    }
    /**
     * ########################### core code#######################
     * @return
     */
    private static CloseableHttpClient getCloseableHttpClient() {
        CloseableHttpClient httpClient = HttpClients.custom()
                .setConnectionManager(poolConnManager)
                .setRetryHandler(httpRequestRetryHandler)
                .build();

        return httpClient;
    }

    /**
     * 封装HTTP GET方法
     * 有参数的Get请求
     * @param
     * @param
     * @return
     * @throws ClientProtocolException
     * @throws java.io.IOException
     */
    public static String getAjax(String url, Map<String, String> paramMap) throws ClientProtocolException, IOException {
        HttpClient httpClient = getCloseableHttpClient();
        HttpGet httpGet = new HttpGet();
        List<NameValuePair> formparams = setHttpParams(paramMap);
        String param = URLEncodedUtils.format(formparams, "UTF-8");
        httpGet.setURI(URI.create(url + "?" + param));
        HttpResponse response = httpClient.execute(httpGet);
        String httpEntityContent = getHttpEntityContent(response);
        httpGet.abort();
        return httpEntityContent;
    }

    /**
     * 封装HTTP GET方法
     * 有参数的Get请求
     * @param
     * @param
     * @return
     * @throws ClientProtocolException
     * @throws java.io.IOException
     */
    public static String get(String url, Map<String, String> paramMap) throws ClientProtocolException, IOException {
        paramMap = getParamsData(paramMap);
        HttpClient httpClient = getCloseableHttpClient();
        HttpGet httpGet = new HttpGet();
        List<NameValuePair> formparams = setHttpParams(paramMap);
        String param = URLEncodedUtils.format(formparams, "UTF-8");
        httpGet.setURI(URI.create(url + "?" + param));
        HttpResponse response = httpClient.execute(httpGet);
        String httpEntityContent = getHttpEntityContent(response);
        httpGet.abort();
        return httpEntityContent;
    }

    /**
     * 封装HTTP GET方法
     * 无参数的Get请求
     * @param
     * @return
     * @throws ClientProtocolException
     * @throws java.io.IOException
     */
    public static String get(String url) throws ClientProtocolException, IOException {
        //首先需要先创建一个DefaultHttpClient的实例
        HttpClient httpClient = new DefaultHttpClient();
        //先创建一个HttpGet对象,传入目标的网络地址,然后调用HttpClient的execute()方法即可:
        HttpGet httpGet = new HttpGet();
        httpGet.setURI(URI.create(url));
        HttpResponse response = httpClient.execute(httpGet);
        String httpEntityContent = getHttpEntityContent(response);
        httpGet.abort();
        return httpEntityContent;
    }
    /**
     * 获得响应HTTP实体内容
     * @param response
     * @return
     * @throws java.io.IOException
     * @throws java.io.UnsupportedEncodingException
     */
    private static String getHttpEntityContent(HttpResponse response) throws IOException, UnsupportedEncodingException {
        //通过HttpResponse 的getEntity()方法获取返回信息
        HttpEntity entity = response.getEntity();
        if (entity != null) {
            InputStream is = entity.getContent();
            BufferedReader br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
            String line = br.readLine();
            StringBuilder sb = new StringBuilder();
            while (line != null) {
                sb.append(line + "\n");
                line = br.readLine();
            }
            br.close();
            is.close();
            return sb.toString();
        }
        return "";
    }


    /**
     * 封装支付HTTP POST方法
     * @param
     * @param
     * @return
     * @throws ClientProtocolException
     * @throws java.io.IOException
     */
    public static String postPayMsg(String url, Map<String, String> paramMap) throws ClientProtocolException, IOException {
        HttpClient httpClient = new DefaultHttpClient();
        httpClient.getParams().setIntParameter(CoreConnectionPNames.SO_TIMEOUT, 5000);
        httpClient.getParams().setIntParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, 3000);
        HttpPost httpPost = new HttpPost(url);
        paramMap = getParamsData(paramMap);
        List<NameValuePair> formparams = setHttpParams(paramMap);
        UrlEncodedFormEntity param = new UrlEncodedFormEntity(formparams, "UTF-8");
        //通过setEntity()设置参数给post
        httpPost.setEntity(param);
        //利用httpClient的execute()方法发送请求并且获取返回参数
        HttpResponse response = httpClient.execute(httpPost);
        String httpEntityContent = getHttpEntityContent(response);
        httpPost.abort();
        return httpEntityContent;
    }

    /**
     * 设置请求参数
     * @param
     * @return
     */
    private static List<NameValuePair> setHttpParams(Map<String, String> paramMap) {
        List<NameValuePair> formparams = new ArrayList<NameValuePair>();
        Set<Map.Entry<String, String>> set = paramMap.entrySet();
        for (Map.Entry<String, String> entry : set) {
            formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
        }
        return formparams;
    }

    public static Map<String,String> getParamsData(Map<String,String> paramsMap){
        Map<String,String> params = new HashMap<>();
        String dataJson = JSONObject.toJSONString(paramsMap);
        params.put("Data",dataJson);

        return params;
    }

    /**
     * @描述:  获取http请求的JSONObject
     * @参数: [jsonStr]
     * @返回值: com.alibaba.fastjson.JSONObject
     * @创建人 WZQ
     * @创建时间: 11:38 2019/4/2
     */
    public static JSONObject getResponseJson(String jsonStr){
        JSONObject jsonObject = JSONObject.parseObject(jsonStr);
        return jsonObject;
    }

    /**
     * @描述: 获取新增返回的data id
     * @参数: [jsonStr]
     * @返回值: java.lang.Long
     * @创建人 WZQ
     * @创建时间: 11:38 2019/4/2
     */
    public static Long getResponseData(String jsonStr){
        return JSONObject.parseObject(jsonStr).getLong("data");
    }


    /**
     * @描述: 执行获取Id
     * @参数: [url, paramsMap]
     * @返回值: java.lang.Long
     * @创建人 WZQ
     * @创建时间: 17:24 2019/4/2
     */
  /*  public static Long executeHttpGetId(String url,Map<String,String> paramsMap){
//        JSONObject jsonObject = executeHttp(url,paramsMap);
        System.out.println(url);
        String getStr = null;
        try {
            getStr = get(url,paramsMap);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return JSONObject.parseObject(getStr).getLong("data");
    }*/

    /**
     * @描述: 执行返回JSONArr
     * @参数: [utl, paramsMap]
     * @返回值: java.lang.String
     * @创建人 WZQ
     * @创建时间: 17:17 2019/4/2
     */
    public static JSONArray executeHttpGetResultArr(String url, Map<String,String> paramsMap){
        System.out.println(url);
        String getStr = null;
        try {
            getStr = get(url,paramsMap);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return JSONObject.parseObject(getStr).getJSONArray("data");
    }

    public static JSONArray executeHttpGetResultArr(PlatformUrlEnum url, Map<String,String> paramsMap){
        System.out.println(url);
        String getStr = null;
        try {
            getStr = postPayMsg(PlatformServerConfig.baseUrl+url.getUrl(),paramsMap);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return JSONObject.parseObject(getStr).getJSONArray("data");
    }

    public static void executeHttpNoReturn(String url,Map<String,String> paramsMap){
        System.out.println(url);
        String getStr = null;
        try {
            getStr = get(url,paramsMap);
        } catch (IOException e) {
            e.printStackTrace();
        }
        //JSONObject jsonObject = JSONObject.parseObject(getStr);
    }

   /**
     * @描述: 执行返回JSON
     * @参数: [utl, paramsMap]
     * @返回值: java.lang.String
     * @创建人 WZQ
     * @创建时间: 17:17 2019/4/2
     */
    public static JSONObject executeHttpGetResult(String url,Map<String,String> paramsMap){
        System.out.println(url);
        String getStr = null;
        try {
            getStr = get(url,paramsMap);
        } catch (IOException e) {
            e.printStackTrace();
        }
        JSONObject jsonObject = JSONObject.parseObject(getStr);
        return jsonObject.getJSONObject("data");
    }

    public static JSONObject executeHttpGetResult(PlatformUrlEnum url, Map<String,String> paramsMap){
        System.out.println(url);
        String getStr = null;
        try {
            getStr = get(PlatformServerConfig.baseUrl+url.getUrl(),paramsMap);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return JSONObject.parseObject(getStr).getJSONObject("data");
    }

    /**
     * @描述:
     * @参数: [url, paramsMap]
     * @返回值: com.alibaba.fastjson.JSONObject
     * @创建人 WZQ
     * @创建时间: 15:44 2019/4/8
     */
  /*  public static JSONObject execute(String url,Map<String,String> paramsMap){
        System.out.println(url);
        String getStr = null;
        try {
            getStr = get(url,paramsMap);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return JSONObject.parseObject(getStr);
    }
*/


    /**
     * @描述: 执行获取Id
     * @参数: [url, paramsMap]
     * @返回值: java.lang.Long
     * @创建人 WZQ
     * @创建时间: 17:24 2019/4/2
     */
    public static Long executeHttpGetId(String url,Map<String,String> paramsMap){
        Map<String,Object> tempMap = EncryptionConstants.encryptionConstantsMap.get(url);
        Method method = (Method) tempMap.get("method");
        Object obj = tempMap.get("object");
        List params = Lists.newArrayList();

        for(String key : paramsMap.keySet()){
            String value = paramsMap.get(key);
            if(value!=null&&(key.toLowerCase().equals("id")||key.toLowerCase().equals("indexid"))){
                Long tempVal = Long.valueOf(value);
                params.add(tempVal);
            }else{
                if("null".equals(value)){
                    params.add(null);
                }else{
                    params.add(value);
                }
            }
        }
        Object object = null;
        try {
            /*LocalVariableTableParameterNameDiscoverer u =
                    new LocalVariableTableParameterNameDiscoverer();
            String[] params1 = u.getParameterNames(method);
            String name = method.getParameters()[0].getName();*/
            object =  method.invoke(obj,params.toArray());
        } catch (Exception e) {
            e.printStackTrace();
            MeenoAssert.notTrue(true,"加密数据发生错误!");
        }

        return ((JSONObject)object).getLong("id");
    }

    /**
     * @描述: 执行返回JSON
     * @参数: [utl, paramsMap]
     * @返回值: java.lang.String
     * @创建人 WZQ
     * @创建时间: 17:17 2019/4/2
     */
    public static JSONObject executeHttp(String url,Map<String,String> paramsMap){
        Map<String,Object> tempMap = EncryptionConstants.encryptionConstantsMap.get(url);
        Method method = (Method) tempMap.get("method");
        Object obj = tempMap.get("object");
        List params = Lists.newArrayList();

        for(String key : paramsMap.keySet()){
            String value = paramsMap.get(key);
            if(value!=null&&(key.toLowerCase().equals("id")||key.toLowerCase().equals("indexid"))){
                Long tempVal = Long.valueOf(value);
                params.add(tempVal);
            }else{
                if("null".equals(value)){
                    params.add(null);
                }else{
                    params.add(value);
                }
            }
        }
        Object object = null;
        try {
            object =  method.invoke(obj,params.toArray());
        } catch (Exception e) {
            e.printStackTrace();
            MeenoAssert.notTrue(true,"加密数据发生错误!");
        }

        return ((JSONObject)object);
    }

    /**
     * @描述:
     * @参数: [url, paramsMap]
     * @返回值: com.alibaba.fastjson.JSONObject
     * @创建人 WZQ
     * @创建时间: 15:44 2019/4/8
     */
    public static JSONObject execute(String url,Map<String,String> paramsMap){
        Map<String,Object> tempMap = EncryptionConstants.encryptionConstantsMap.get(url);
        Method method = (Method) tempMap.get("method");
        Object obj = tempMap.get("object");
        List params = Lists.newArrayList();

        for(String key : paramsMap.keySet()){
            String value = paramsMap.get(key);
            if(value!=null&&(key.toLowerCase().equals("id")||key.toLowerCase().equals("indexid"))){
                Long tempVal = Long.valueOf(value);
                params.add(tempVal);
            }else{
                if("null".equals(value)){
                    params.add(null);
                }else{
                    params.add(value);
                }
            }
        }
        Object object = null;
        try {
            object =  method.invoke(obj,params.toArray());
        } catch (Exception e) {
            e.printStackTrace();
            MeenoAssert.notTrue(true,"加密数据发生错误!");
        }

        return ((JSONObject)object);
    }



}


  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
  • 105
  • 106
  • 107
  • 108
  • 109
  • 110
  • 111
  • 112
  • 113
  • 114
  • 115
  • 116
  • 117
  • 118
  • 119
  • 120
  • 121
  • 122
  • 123
  • 124
  • 125
  • 126
  • 127
  • 128
  • 129
  • 130
  • 131
  • 132
  • 133
  • 134
  • 135
  • 136
  • 137
  • 138
  • 139
  • 140
  • 141
  • 142
  • 143
  • 144
  • 145
  • 146
  • 147
  • 148
  • 149
  • 150
  • 151
  • 152
  • 153
  • 154
  • 155
  • 156
  • 157
  • 158
  • 159
  • 160
  • 161
  • 162
  • 163
  • 164
  • 165
  • 166
  • 167
  • 168
  • 169
  • 170
  • 171
  • 172
  • 173
  • 174
  • 175
  • 176
  • 177
  • 178
  • 179
  • 180
  • 181
  • 182
  • 183
  • 184
  • 185
  • 186
  • 187
  • 188
  • 189
  • 190
  • 191
  • 192
  • 193
  • 194
  • 195
  • 196
  • 197
  • 198
  • 199
  • 200
  • 201
  • 202
  • 203
  • 204
  • 205
  • 206
  • 207
  • 208
  • 209
  • 210
  • 211
  • 212
  • 213
  • 214
  • 215
  • 216
  • 217
  • 218
  • 219
  • 220
  • 221
  • 222
  • 223
  • 224
  • 225
  • 226
  • 227
  • 228
  • 229
  • 230
  • 231
  • 232
  • 233
  • 234
  • 235
  • 236
  • 237
  • 238
  • 239
  • 240
  • 241
  • 242
  • 243
  • 244
  • 245
  • 246
  • 247
  • 248
  • 249
  • 250
  • 251
  • 252
  • 253
  • 254
  • 255
  • 256
  • 257
  • 258
  • 259
  • 260
  • 261
  • 262
  • 263
  • 264
  • 265
  • 266
  • 267
  • 268
  • 269
  • 270
  • 271
  • 272
  • 273
  • 274
  • 275
  • 276
  • 277
  • 278
  • 279
  • 280
  • 281
  • 282
  • 283
  • 284
  • 285
  • 286
  • 287
  • 288
  • 289
  • 290
  • 291
  • 292
  • 293
  • 294
  • 295
  • 296
  • 297
  • 298
  • 299
  • 300
  • 301
  • 302
  • 303
  • 304
  • 305
  • 306
  • 307
  • 308
  • 309
  • 310
  • 311
  • 312
  • 313
  • 314
  • 315
  • 316
  • 317
  • 318
  • 319
  • 320
  • 321
  • 322
  • 323
  • 324
  • 325
  • 326
  • 327
  • 328
  • 329
  • 330
  • 331
  • 332
  • 333
  • 334
  • 335
  • 336
  • 337
  • 338
  • 339
  • 340
  • 341
  • 342
  • 343
  • 344
  • 345
  • 346
  • 347
  • 348
  • 349
  • 350
  • 351
  • 352
  • 353
  • 354
  • 355
  • 356
  • 357
  • 358
  • 359
  • 360
  • 361
  • 362
  • 363
  • 364
  • 365
  • 366
  • 367
  • 368
  • 369
  • 370
  • 371
  • 372
  • 373
  • 374
  • 375
  • 376
  • 377
  • 378
  • 379
  • 380
  • 381
  • 382
  • 383
  • 384
  • 385
  • 386
  • 387
  • 388
  • 389
  • 390
  • 391
  • 392
  • 393
  • 394
  • 395
  • 396
  • 397
  • 398
  • 399
  • 400
  • 401
  • 402
  • 403
  • 404
  • 405
  • 406
  • 407
  • 408
  • 409
  • 410
  • 411
  • 412
  • 413
  • 414
  • 415
  • 416
  • 417
  • 418
  • 419
  • 420
  • 421
  • 422
  • 423
  • 424
  • 425
  • 426
  • 427
  • 428
  • 429
  • 430
  • 431
  • 432
  • 433
  • 434
  • 435
  • 436
  • 437
  • 438
  • 439
  • 440
  • 441
  • 442
  • 443
  • 444
  • 445
  • 446
  • 447
  • 448
  • 449
  • 450
  • 451
  • 452
  • 453
  • 454
  • 455
  • 456
  • 457
  • 458
  • 459
  • 460
  • 461
  • 462
  • 463
  • 464
  • 465
  • 466
  • 467
  • 468
  • 469
  • 470
  • 471
  • 472
  • 473
  • 474
  • 475
  • 476
  • 477

VideoUtils.java
videoUtils获取视频信息工具类


package com.meeno.wzq.alibaba.video;

import com.google.common.collect.Maps;
import com.meeno.framework.util.HttpUtils;
import com.meeno.wzq.alibaba.signature.SignatureUtils;

import java.io.IOException;
import java.util.List;
import java.util.Map;

/**
 * @description: videoUtils获取视频信息工具类
 * @author: Wzq
 * @create: 2020-01-14 19:31
 */
public class VideoUtils {


    /**
     *@Description 获取签名结果
     *@Param [accessKeyId, accessKeySecret, videoId]
     *@Return java.lang.String
     *@Author Wzq
     *@Date 2020/1/14
     *@Time 19:30
     */
    public static String getVideoInfo(String accessKeyId,String accessKeySecret,String videoId) throws IOException {
        String timestamp = SignatureUtils.generateTimestamp();
        String signatureNonce = SignatureUtils.generateRandom();
        //1.1. 构造规范化的请求字符串
        Map<String, String> privateParams = Maps.newLinkedHashMap();
        privateParams.put("Action","GetVideoInfo");
        privateParams.put("VideoId", videoId);
        Map<String, String> publicParams = Maps.newLinkedHashMap();
        publicParams.put("Timestamp",timestamp);
        publicParams.put("Format","JSON");
        publicParams.put("AccessKeyId",accessKeyId);
        publicParams.put("SignatureMethod", "HMAC-SHA1");
        publicParams.put("SignatureNonce",signatureNonce);
        publicParams.put("Version", "2017-03-21");
        publicParams.put("SignatureVersion","1.0");

        List<String> allParams = SignatureUtils.getAllParams(publicParams, privateParams);

        String canonicalizedQueryString = SignatureUtils.getCQS(allParams);

        //1.2. 构造待签名的字符串
        /*构造待签名的字符串*/
        String StringToSign = "GET" + "&" + SignatureUtils.percentEncode("/") + "&" + SignatureUtils.percentEncode(canonicalizedQueryString);

        //1.3. 计算待签名字符串的HMAC值
        byte[] bytes = SignatureUtils.hmacSHA1Signature(accessKeySecret, StringToSign);

        //1.4. 编码得到最终签名值
        //按照 Base64 编码规则将1.3中计算得到的HMAC值编码成字符串，得到最终签名值（Signature）。
        String signature = SignatureUtils.newStringByBase64(bytes);
//        log.info("-------------"+signature);
        Map<String,String> videoInfoMap = Maps.newLinkedHashMap();
        videoInfoMap.put("Action","GetVideoInfo");
        videoInfoMap.put("VideoId", videoId);
        videoInfoMap.put("Format","JSON");
        videoInfoMap.put("AccessKeyId",accessKeyId);
        videoInfoMap.put("Signature",signature);
        videoInfoMap.put("SignatureMethod","HMAC-SHA1");
        videoInfoMap.put("SignatureVersion","1.0");
        videoInfoMap.put("SignatureNonce",signatureNonce);
        videoInfoMap.put("Timestamp", timestamp);
        videoInfoMap.put("Version","2017-03-21");
        //调用http get请求
        String resultStr = HttpUtils.getAjax("http://vod.cn-shanghai.aliyuncs.com", videoInfoMap);
//        log.info(s);
        return resultStr;
    }

}


  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77

调用获取视频点播工具类获取videoinfo

controller层代码如下:



    /**
    *@Description 获取视频点播的视频信息
    *@Param [session, request, response, data]
    *@Return void
    *@Author Wzq
    *@Date 2020/1/14
    *@Time 19:34
    */
    @RequestMapping(value = "getVideoInfo.action")
    public void getVideoInfo(final HttpSession session,
                             final HttpServletRequest request,
                             final HttpServletResponse response,
                             @RequestParam(value = "Data") String data) throws IOException {

        JSONObject jsonObject = JSONObject.parseObject(data);
        //视频点播videoId
        String videoId = jsonObject.getString("videoId");
        Bank indexBank = this.enterpriseDao.getEnterprise().getIndexBank();
        String accessKeyId = "";
        String accessKeySecret = "";
        String videoInfo = VideoUtils.getVideoInfo(accessKeyId, accessKeySecret, videoId);
        JSONObject resultJson = null;
        if(videoInfo != null && !videoInfo.isEmpty()){
            resultJson = JSONObject.parseObject(videoInfo);
        }
        CommonUtil.toJson(response, new ResponseBean(Constant.RESPONSE_SUCCESS,"",resultJson));
    }



  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31

个人微信公众，经常更新一些实用的干货:
image.png

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/2023面试高手/article/detail/507608
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号