边转边播任务

public static void generatePlayList(COSClient client)  {
    //1.创建任务请求对象
    MediaJobsRequestV2 request = new MediaJobsRequestV2();
    request.setBucketName("demo-1234567890");
    //2.添加请求参数 参数详情请见api接口文档
    request.setTag("GeneratePlayList");
    request.getInput().setObject("1.mp4");
    MediaContainerObject container = request.getOperation().getTranscode().getContainer();
    container.setFormat("hls");
    container.getClipConfig().setDuration("5");
    MediaTransConfigObject transConfig = request.getOperation().getTranscode().getTransConfig();
    transConfig.setCosTag("DemoTag=demo1&DemoTag2=demo2");
    //hls加密操作 默认非加密
    //transConfig.getHlsEncrypt().setIsHlsEncrypt("true");
    MediaTranscodeVideoObject video = request.getOperation().getTranscode().getVideo();
    video.setCodec("H.264");
    video.setWidth("1280");
    video.setHeight("960");

    request.getOperation().getOutput().setBucket("demo-1234567890");
    request.getOperation().getOutput().setRegion("ap-beijing");
    request.getOperation().getOutput().setObject("output/media/test.m3u8");
    //3.调用接口,获取任务响应对象
    MediaJobResponseV2 response = client.createMediaJobsV2(request);
    System.out.println(Jackson.toJsonString(response));
}

public static void generatePlayListUrl(COSClient client)  {
    String bucketName = "demo-1251704708";
    String key = "output/media/test.m3u8";
    // 设置签名过期时间(可选), 若未进行设置则默认使用 ClientConfig 中的签名过期时间(1小时)
    Date expirationDate = new Date(System.currentTimeMillis() + 30 * 60 * 1000);
    // 填写本次请求的参数，需与实际请求相同，能够防止用户篡改此签名的 HTTP 请求的参数
    Map<String, String> params = new HashMap<String, String>();
    params.put("ci-process", "getplaylist");
    params.put("expires", "43200");
    Map<String, String> headers = new HashMap<String, String>();

    HttpMethodName method = HttpMethodName.GET;
    URL url = client.generatePresignedUrl(bucketName, key, expirationDate, method, headers, params);
    System.out.println(url.toString());
}

public static void getPlayListSimple(COSClient client) throws UnsupportedEncodingException {
    String bucketName = bucket;
    String key = objectKey;
    // 设置签名过期时间(可选), 若未进行设置则默认使用 ClientConfig 中的签名过期时间(1小时)
    Instant now = Instant.now();
    Instant expire = now.plus(Long.parseLong(expires), ChronoUnit.SECONDS);
    Date expirationDate = Date.from(expire);
    String token = generateToken(appId, bucket, objectKey, secret, expirationDate);
    Map<String, String> params = new HashMap<String, String>();
    params.put("ci-process", "getplaylist");
    params.put("expires", "43200");
    params.put("token-type", "JwtToken");
    params.put("token",token);
    Map<String, String> headers = new HashMap<String, String>();

    HttpMethodName method = HttpMethodName.GET;
    URL url = client.generatePresignedUrl(bucketName, key, expirationDate, method, headers, params);
    System.out.println(url.toString());
}

public static String generateToken(String appId, String bucketId, String objectKey, byte[] secret, Date expires) throws UnsupportedEncodingException {
    Instant now = Instant.now();
    String encodedObjectKey;
    encodedObjectKey = URLEncoder.encode(objectKey, "UTF-8");

    Algorithm algorithm = Algorithm.HMAC256(secret);
    JWTCreator.Builder builder = JWT.create().withIssuer("client")
            .withIssuedAt(Date.from(now))
            .withExpiresAt(expires)
            .withClaim("Type", "CosCiToken")
            .withClaim("AppId", appId)
            .withClaim("BucketId", bucketId)
            .withClaim("Object", encodedObjectKey)
            .withClaim("Issuer", "client")
            .withClaim("IssuedTimeStamp", now.getEpochSecond())
            .withClaim("ExpireTimeStamp", expires.getTime()/1000)
            .withClaim("UsageLimit", 20)
            .withClaim("ProtectSchema", "rsa1024")
//          .withClaim("PublicKey", "xxx")
            .withClaim("ProtectContentKey", 0);
    return builder.sign(algorithm);
}