- 创建AcsClient实例。
DefaultProfile profile = DefaultProfile.getProfile( mpsRegionId, // Region ID accessKeyId, // AccessKey ID accessKeySecret); // Access Key Secret IAcsClient client = new DefaultAcsClient(profile);
- 创建request,并设置参数。
SubmitJobsRequest request = new SubmitJobsRequest();
- 设置转码参数。
- Input
JSONObject input = new JSONObject(); input.put("Location", ossLocation); input.put("Bucket", ossBucket); try { input.put("Object", URLEncoder.encode(headObject, "utf-8")); } catch (UnsupportedEncodingException e) { throw new RuntimeException("input URL encode failed"); } request.setInput(input.toJSONString());
- Output
String outputOSSObject; try { outputOSSObject = URLEncoder.encode(ossOutputObject, "utf-8"); } catch (UnsupportedEncodingException e) { throw new RuntimeException("output URL encode failed"); } JSONObject output = new JSONObject(); output.put("OutputObject", outputOSSObject); // Ouput->TemplateId output.put("TemplateId", templateId);
- Video
JSONObject video = new JSONObject(); video.put("Width", "1280"); video.put("Height", "720"); output.put("Video", video.toJSONString());
- OpeningList
JSONObject openingVideo = new JSONObject(); String openingVideoURL; try { openingVideoURL = String.format( "http://%s.%s.aliyuncs.com/%s", ossBucket, ossLocation, URLEncoder.encode(headObject, "utf-8")); } catch (UnsupportedEncodingException e) { throw new RuntimeException("mergeVideoURL encode failed"); } openingVideo.put("OpenUrl", openingVideoURL); openingVideo.put("Width", "640"); openingVideo.put("Start", "2"); JSONArray openingVideoList = new JSONArray(); openingVideoList.add(openingVideo); output.put("OpeningList", openingVideoList.toJSONString());
- TailSlateList
JSONObject tailSlateVideo = new JSONObject(); String tailSlateVideoURL; try { tailSlateVideoURL = String.format( "http://%s.%s.aliyuncs.com/%s", ossBucket, ossLocation, URLEncoder.encode(tailObject, "utf-8")); } catch (UnsupportedEncodingException e) { throw new RuntimeException("mergeTailURL encode failed"); } tailSlateVideo.put("TailUrl", tailSlateVideoURL); tailSlateVideo.put("Width", "640"); tailSlateVideo.put("BlendDuration", "3"); tailSlateVideo.put("BgColor", "Black"); JSONArray tailSlateVideoList = new JSONArray(); tailSlateVideoList.add(tailSlateVideo); output.put("TailSlateList", tailSlateVideoList.toJSONString());
- Video
- Input
- 发起API请求并显示返回值。
SubmitJobsResponse response; response = client.getAcsResponse(request); System.out.println("RequestId is:"+response.getRequestId()); if (response.getJobResultList().get(0).getSuccess()) { System.out.println("JobId is:" + response.getJobResultList().get(0).getJob().getJobId()); } else { System.out.println("SubmitJobs Failed code:" + response.getJobResultList().get(0).getCode() + " message:" + response.getJobResultList().get(0).getMessage()); }
完整代码
package com.aliyun.mts;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.exceptions.ServerException;
import com.aliyuncs.mts.model.v20140618.*;
public class OpenTail {
private static String accessKeyId = "xxx";
private static String accessKeySecret = "xxx";
private static String mpsRegionId = "cn-hangzhou";
private static String pipelineId = "xxx";
private static String templateId = "S00000001-200030";
private static String ossLocation = "oss-cn-hangzhou";
private static String ossBucket = "xxx";
private static String ossInputObject = "input.mp4";
private static String ossOutputObject = "output.mp4";
private static String headObject = "head.mp4";
private static String tailObject = "tail.mp4";
public static void main(String[] args) {
// DefaultAcsClient
DefaultProfile profile = DefaultProfile.getProfile(
mpsRegionId, // Region ID
accessKeyId, // AccessKey ID
accessKeySecret); // Access Key Secret
IAcsClient client = new DefaultAcsClient(profile);
// request
SubmitJobsRequest request = new SubmitJobsRequest();
// Input
JSONObject input = new JSONObject();
input.put("Location", ossLocation);
input.put("Bucket", ossBucket);
try {
input.put("Object", URLEncoder.encode(ossInputObject, "utf-8"));
} catch (UnsupportedEncodingException e) {
throw new RuntimeException("input URL encode failed");
}
request.setInput(input.toJSONString());
// Output
String outputOSSObject;
try {
outputOSSObject = URLEncoder.encode(ossOutputObject, "utf-8");
} catch (UnsupportedEncodingException e) {
throw new RuntimeException("output URL encode failed");
}
JSONObject output = new JSONObject();
output.put("OutputObject", outputOSSObject);
// Ouput->TemplateId
output.put("TemplateId", templateId);
// Output->OpeningList
JSONObject openingVideo = new JSONObject();
String openingVideoURL;
try {
openingVideoURL = String.format(
"http://%s.%s.aliyuncs.com/%s",
ossBucket,
ossLocation,
URLEncoder.encode(headObject, "utf-8"));
} catch (UnsupportedEncodingException e) {
throw new RuntimeException("mergeVideoURL encode failed");
}
openingVideo.put("OpenUrl", openingVideoURL);
openingVideo.put("Width", "640");
openingVideo.put("Start", "2");
JSONArray openingVideoList = new JSONArray();
openingVideoList.add(openingVideo);
output.put("OpeningList", openingVideoList.toJSONString());
// Output->TailSlateList
JSONObject tailSlateVideo = new JSONObject();
String tailSlateVideoURL;
try {
tailSlateVideoURL = String.format(
"http://%s.%s.aliyuncs.com/%s",
ossBucket,
ossLocation,
URLEncoder.encode(tailObject, "utf-8"));
} catch (UnsupportedEncodingException e) {
throw new RuntimeException("mergeTailURL encode failed");
}
tailSlateVideo.put("TailUrl", tailSlateVideoURL);
tailSlateVideo.put("Width", "640");
tailSlateVideo.put("BlendDuration", "3");
tailSlateVideo.put("BgColor", "Black");
JSONArray tailSlateVideoList = new JSONArray();
tailSlateVideoList.add(tailSlateVideo);
output.put("TailSlateList", tailSlateVideoList.toJSONString());
// Outputs
JSONArray outputs = new JSONArray();
outputs.add(output);
request.setOutputs(outputs.toJSONString());
request.setOutputBucket(ossBucket);
request.setOutputLocation(ossLocation);
// PipelineId
request.setPipelineId(pipelineId);
// call api
SubmitJobsResponse response;
try {
response = client.getAcsResponse(request);
System.out.println("RequestId is:"+response.getRequestId());
if (response.getJobResultList().get(0).getSuccess()) {
System.out.println("JobId is:" + response.getJobResultList().get(0).getJob().getJobId());
} else {
System.out.println("SubmitJobs Failed code:" + response.getJobResultList().get(0).getCode() +
" message:" + response.getJobResultList().get(0).getMessage());
}
} catch (ServerException e) {
e.printStackTrace();
} catch (ClientException e) {
e.printStackTrace();
}
}
}