JAVA 对接腾讯云直播的实现

JAVA 对接腾讯云直播的实现

签名授权

public static T TecentDoPostjsonV3(String url,String key,String secretId, TecentPublicParams header, String json, OkHttpClient httpClient, Class clazz) throws Exception {

// ************* 步骤 1：拼接规范请求串 *************

String date = DateUtils.format(new Date(Long.valueOf(header.getX_TC_Timestamp() + "000")),DateUtils.FORMAT_SHORT);

String service = url.substring(0,url.indexOf(".")); //截取服务类型 云直播是live

System.out.println(json);

String canonicalRequest ="POST\n" +

"/\n" +

"\n" +

"content-type:application/json; charset=utf-8\n" +

"host:"+url+"\n" +

"\n" +

"content-type;host\n" +

sha256Hex(json);

System.out.println(canonicalRequest);

// ************* 步骤 2：拼接待签名字符串 *************

String credentialScope = date+ "/" + service + "/" + http://"tc3_request";

String hashedCanonicalRequest = sha256Hex(canonicalRequest);

String algorithm = "TC3-HMAC-SHA256";

String stringToSign = algorithm + "\n" + header.getX_TC_Timestamp() + "\n" + credentialScope + "\n" + hashedCanonicalRequest;

System.out.println(stringToSign);

// ************* 步骤 3：计算签名 *************

byte[] secretDate = hmac256(("TC3" + key).getBytes(CHARSET), date);

byte[] secretService = hmac256(secretDate, service);

byte[] secretSigning = hmac256(secretService, "tc3_request");

String signature = DatatypeConverter.printHexBinary(hmac256(secretSigning, stringToSign)).toLowerCase();

System.out.println(signature);

// ************* 步骤 4：拼接 Authorization *************

String authorization = algorithm + " " + "Credential=" + secretId + "/" + credentialScope + ", "

+ "SignedHeaders=" + "content-type;host" + ", " + "Signature=" + signature;

System.out.println(authorization);

header.setAuthorization(authorization);

JSONObject jsonObject = (JSONObject)JSON.toJSON(header);

RequestBody requestBody = RequestBody.create(CONTENT_TYPE, json);

Request.Builder builder = new Request.Builder();

for (Map.Entry entry:jsonObject.entrySet()) {

if(entry.getValue()==null){

continue;

}

builder.addHeader(String.valueOf(entry.getKey()).replaceAll("_","-"),String.valueOf(entry.getValue()));

}

// 用okhttp3 拼接发送请求

try {

Response response = httpClient.newCall((builder).url("https://"+url).post(requestBody).build()).execute();

String request = response.body().string();

T t = JSON.parseObject(request, clazz);

return t;

} catch (IOException var8) {

throw new ApiProcessException(ErrorCode.HTTP_REQUEST_ERROR, var8.getMessage());

}

}

public static byte[] hmac256(byte[] key, String msg) throws Exception {

Mac mac = Mac.getInstance("HmacSHA256");

SecretKeySpec secretKeySpec = new SecretKeySpec(key, mac.getAlgorithm());

mac.init(secretKeySpec);

return mac.doFinal(msg.getBytes(CHARSET));

}

公共参数实体类

public class TecentPublicParams {

private String X_TC_Action;

private String X_TC_Region;

private String X_TC_Timestamp = Long.toString(System.currentTimeMillis() / 1000);

private String X_TC_Version;

private String Authorization;

private String X_TC_Language = "zh-CN";

private String X_TC_Token;

public String getX_TC_Action() {

return X_TC_Action;

}

public void setX_TC_Action(String x_TC_Action) {

X_TC_Action = x_TC_Action;

}

public String getX_TC_Region() {

return X_TC_Region;

}

public void setX_TC_Region(String x_TC_Region) {

X_TC_Region =http:// x_TC_Region;

}

public String getX_TC_Timestamp() {

return X_TC_Timestamp;

}

public void setX_TC_Timestamp(String x_TC_Timestamp) {

X_TC_Timestamp = x_TC_Timestamp;

}

public String getX_TC_Version() {

return X_TC_Version;

}

public void setX_TC_Version(String x_TC_Version) {

X_TC_Version = x_TC_Version;

}

public String getAuthorization() {

return Authorization;

}

public void setAuthorization(String authorization) {

Authorization = authorization;

}

joSeAsWUwP public String getX_TC_Language() {

return X_TC_Language;

}

public void setX_TC_Language(String x_TC_Language) {

X_TC_Language = x_TC_Language;

}

public String getX_TC_Token() {

return X_TC_Token;

}

public void setX_TC_Token(String x_TC_Token) {

X_TC_Token = x_TC_Token;

}

}

调用方法

String tencentLiveApi = "live.tencentcloudapi.com";

String SECRET_KEY = "***"; //此处填写自己腾讯云key

String SECRET_ID = "***"; //此处填写自己腾讯云密匙

TecentPublicParams tecentPublicParams = new TecentPublicParams();

tecentPublicParams.setX_TC_Action("DescribeLiveStreamPublishedList"); //对应方法名

tecentPublicParams.setX_TC_Version("2018-08-01");

TreeMap keyValues = new TreeMap(); //参数

keyValues.put("DomainName","***");

keyValues.put("EndTime", DateUtils.format(new Date(),"yyyy-MM-dd'T'HH:mm:ss'Z'"));

keyValues.put("StartTime", DateUtils.format(DateUtils.addDay(new Date(),-30),"yyyy-MM-dd'T'HH:mm:ss'Z'"));

String back ="";

try {

back = LiveUtils.TecentDoPostJsonV3(tencentLiveApi,SECRET_KEY,SECRET_ID,tecentPublicParams,JSON.toJSONString(keyValues),httpClient,String.class);

} catch (Exception e) {

e.printStackTrace();

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。