ApsaraVideo VOD：Gunakan upload SDK untuk Java

public class UploadVideoDemo {
    // Wajib. Tentukan pasangan AccessKey.
    // Pasangan AccessKey Akun Alibaba Cloud memiliki izin untuk mengakses semua API. Kami menyarankan agar Anda menggunakan pasangan AccessKey Pengguna RAM untuk panggilan API atau O&M rutin.
    // Kami sangat menyarankan agar Anda tidak menyematkan ID AccessKey dan Rahasia AccessKey secara langsung ke dalam kode proyek Anda. Jika tidak, pasangan AccessKey tersebut dapat bocor dan keamanan semua resource dalam akun Anda akan terganggu.
    // Contoh ini menunjukkan cara membaca pasangan AccessKey dari variabel lingkungan untuk mengotentikasi akses API. Sebelum menjalankan kode contoh, konfigurasikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID dan ALIBABA_CLOUD_ACCESS_KEY_SECRET.
    private static final String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
    private static final String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");

    public static void main(String[] args) {
    // Unggah file video.
    // Judul video. Parameter ini wajib.
    String title = "Test Title";
    // 1. Untuk upload file lokal dan upload aliran file, atur nama file ke jalur mutlak file yang diunggah, misalnya /User/sample/FileName.mp4. Parameter ini wajib.
    // 2. Untuk upload aliran jaringan, atur nama file ke nama file sumber, misalnya FileName.mp4. Parameter ini wajib.
    // 3. Untuk unggah streaming, atur nama file ke nama file sumber, misalnya FileName.mp4. Parameter ini wajib.
    // Nama file harus mencakup ekstensi nama file terlepas dari metode upload yang digunakan.
    String fileName = "/Users/test/video/test.mp4";
    // Unggah file lokal.
    testUploadVideo(accessKeyId, accessKeySecret, title, fileName);

    // URL aliran jaringan untuk video yang akan diunggah.
    String url = "http://test.aliyun.com/video/test.mp4";

    // 2. Unggah aliran jaringan.
    // Ekstensi nama file. Jika URL tidak berisi ekstensi nama file, Anda harus mengatur parameter ini.
    String fileExtension = "mp4";
    testUploadURLStream(accessKeyId, accessKeySecret, title, url, fileExtension);

    // 3. Unggah aliran file.
    testUploadFileStream(accessKeyId, accessKeySecret, title, fileName);

    // 4. Unggah streaming, seperti aliran file dan aliran jaringan.
    InputStream inputStream = null;
    // 4.1 Aliran file.
    try {
        inputStream = new FileInputStream(fileName);
    } catch (FileNotFoundException e) {
        e.printStackTrace();
    }
    // 4.2 Aliran jaringan.
    try {
        inputStream = new URL(url).openStream();
    } catch (IOException e) {
        e.printStackTrace();
    }
    testUploadStream(accessKeyId, accessKeySecret, title, fileName, inputStream);
}

/**
 * API untuk upload file lokal.
 *
 * @param accessKeyId
 * @param accessKeySecret
 * @param title
 * @param fileName
 */
private static void testUploadVideo(String accessKeyId, String accessKeySecret, String title, String fileName) {
    UploadVideoRequest request = new UploadVideoRequest(accessKeyId, accessKeySecret, title, fileName);
    /* Ukuran setiap bagian untuk unggah multi-bagian. Nilai default: 2 MB. */
    request.setPartSize(2 * 1024 * 1024L);
    /* Jumlah thread konkuren untuk unggah multi-bagian. Nilai default: 1. Catatan: Konfigurasi ini mengonsumsi sumber daya CPU server. Tentukan jumlah thread berdasarkan kinerja server Anda. */
    request.setTaskNum(1);
    /* Menentukan apakah akan mengaktifkan unggah yang dapat dilanjutkan. Nilai default: false. Jika jaringan tidak stabil atau program crash, Anda dapat melanjutkan tugas upload dengan mengirim permintaan upload yang sama. Fitur ini cocok untuk file besar yang tidak dapat diunggah dalam waktu 3.000 detik.
    Catatan: Jika Anda mengaktifkan unggah yang dapat dilanjutkan, kemajuan upload ditulis ke file disk lokal selama proses upload. Hal ini memengaruhi kecepatan upload. Pilih apakah akan mengaktifkan fitur ini sesuai kebutuhan. */
    //request.setEnableCheckpoint(false);
    /* Periode timeout untuk mencatat permintaan OSS lambat. Jika waktu untuk mengunggah satu bagian melebihi ambang batas ini, log debug akan dicetak. Untuk menekan log ini, sesuaikan ambang batasnya. Satuan: milidetik. Nilai default: 300000. */
    //request.setSlowRequestsThreshold(300000L);
    /* Ambang batas waktu untuk mencatat permintaan lambat setiap bagian. Nilai default: 300 detik. */
    //request.setSlowRequestsThreshold(300000L);
    /* Menentukan apakah akan menampilkan watermark. Parameter ini opsional. Jika Anda menentukan ID grup templat, watermark akan ditampilkan berdasarkan konfigurasi grup templat. */
    //request.setIsShowWaterMark(true);
    /* Pengaturan callback pesan kustom dan pengaturan akselerasi upload. Parameter ini opsional. Extend menentukan pengaturan ekstensi kustom. MessageCallback menentukan pengaturan callback pesan. AccelerateConfig menentukan pengaturan akselerasi upload. Anda harus mengaktifkan fitur akselerasi upload sebelum menggunakannya. */
    //request.setUserData("{\"Extend\":{\"test\":\"www\",\"localId\":\"xxxx\"},\"MessageCallback\":{\"CallbackType\":\"http\",\"CallbackURL\":\"http://example.aliyundoc.com\"},\"AccelerateConfig\":{\"Type\":\"oss\",\"Domain\":\"****Bucket.oss-accelerate.aliyuncs.com\"}}");
    /* ID kategori video. Parameter ini opsional. */
    //request.setCateId(0);
    /* Tag video. Pisahkan beberapa tag dengan koma (,). Parameter ini opsional. */
    //request.setTags("Tag 1,Tag 2");
    /* Deskripsi video. Parameter ini opsional. */
    //request.setDescription("Video description");
    /* URL gambar mini. Parameter ini opsional. */
    //request.setCoverURL("http://cover.example.com/image_01.jpg");
    /* ID grup templat. Parameter ini opsional. */
    //request.setTemplateGroupId("8c4792cbc8694e7084fd5330e5****");
    /* ID alur kerja. Parameter ini opsional. */
    //request.setWorkflowId("d4430d07361f0*be1339577859b0****");
    /* Wilayah penyimpanan. Parameter ini opsional. */
    //request.setStorageLocation("in-201703232118266-5sejd****.oss-cn-shanghai.aliyuncs.com");
    /* Mengaktifkan callback kemajuan upload default. */
    //request.setPrintProgress(false);
    /* Menetapkan callback kemajuan upload kustom. Callback harus mewarisi VoDProgressListener. */
    /* Fitur ini dinonaktifkan secara default. Jika Anda mengaktifkan fitur ini, server mengembalikan detail upload dalam log selama proses upload. Jika Anda tidak perlu menerima pesan ini, nonaktifkan fitur ini. */
    //request.setProgressListener(new PutObjectProgressListener());
    /* Menetapkan kelas implementasi antarmuka yang digunakan untuk menghasilkan informasi STS. */
    // request.setVoDRefreshSTSTokenListener(new RefreshSTSTokenImpl());
    /* Menetapkan ID aplikasi. */
    //request.setAppId("app-100****");
    /* Titik akhir ApsaraVideo VOD. */
    //request.setApiRegionId("cn-shanghai");
    /* Wilayah penerapan ECS. */
    // request.setEcsRegionId("cn-shanghai");
    // Jika wilayah penerapan ECS sama dengan wilayah titik akhir ApsaraVideo VOD, upload jaringan internal akan diaktifkan secara otomatis.

    /* Mengonfigurasi proxy. Parameter ini opsional. */
    //OSSConfig ossConfig = new OSSConfig();
    /* <Wajib> Host server proxy. */
    //ossConfig.setProxyHost("<yourProxyHost>");
    /* <Wajib> Port server proxy. */
    //ossConfig.setProxyPort(-1);
    /* Protokol yang digunakan untuk menghubungkan ke OSS. Nilai yang valid: HTTP dan HTTPS. Nilai default: HTTP. */
    //ossConfig.setProtocol("HTTP");
    /* User agent, yaitu header User-Agent dalam HTTP. Nilai default: aliyun-sdk-java. */
    //ossConfig.setUserAgent("<yourUserAgent>");
    /* Username untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
    //ossConfig.setProxyUsername("<yourProxyUserName>");
    /* Password untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
    //ossConfig.setProxyPassword("<yourProxyPassword>");
    //request.setOssConfig(ossConfig);

    UploadVideoImpl uploader = new UploadVideoImpl();
    UploadVideoResponse response = uploader.uploadVideo(request);
    System.out.print("RequestId=" + response.getRequestId() + "\n");  // ID permintaan yang dikirim ke ApsaraVideo VOD.
    if (response.isSuccess()) {
        System.out.print("VideoId=" + response.getVideoId() + "\n");
    } else {
        /* Jika URL callback yang ditentukan tidak valid, upload video tidak terpengaruh. VideoId dan kode kesalahan dikembalikan. Dalam kasus lain, jika upload gagal, VideoId kosong. Dalam hal ini, analisis penyebab kegagalan berdasarkan kode kesalahan yang dikembalikan. */
        System.out.print("VideoId=" + response.getVideoId() + "\n");
        System.out.print("ErrorCode=" + response.getCode() + "\n");
        System.out.print("ErrorMessage=" + response.getMessage() + "\n");
    }
}

/**
 * Mengunggah aliran jaringan menggunakan URL. Metode ini mendukung unggah yang dapat dilanjutkan. Anda dapat mengunggah satu file hingga 48,8 TB.
 * Metode ini memerlukan file jaringan diunduh ke disk lokal sebelum diunggah. Pastikan disk lokal Anda memiliki ruang yang cukup.
 * Jika URL yang Anda tentukan tidak menyertakan ekstensi nama file, Anda harus mengatur parameter fileExtension.
 * @param accessKeyId
 * @param accessKeySecret
 * @param title
 * @param fileExtension
 * @param url
 */
private static void testUploadURLStream(String accessKeyId, String accessKeySecret, String title, String url, String fileExtension) {
    UploadURLStreamRequest request = new UploadURLStreamRequest(accessKeyId, accessKeySecret, title, url);

    /* Ekstensi nama file. */
    request.setFileExtension(fileExtension);
    /* Periode timeout koneksi untuk mengunduh file jaringan. Satuan: milidetik. Nilai 0 menunjukkan tanpa batas. */
    request.setDownloadConnectTimeout(1000);
    /* Periode timeout baca untuk mengunduh file jaringan. Satuan: milidetik. Nilai 0 menunjukkan tanpa batas. */
    request.setDownloadReadTimeout(0);
    /* Direktori lokal tempat file jaringan yang diunduh disimpan. */
    request.setLocalDownloadFilePath("/Users/download");
    /* Menentukan apakah akan menampilkan watermark. Parameter ini opsional. Jika Anda menentukan ID grup templat, watermark akan ditampilkan berdasarkan konfigurasi grup templat. */
    //request.setShowWaterMark(true);
    /* Pengaturan callback pesan kustom dan pengaturan akselerasi upload. Parameter ini opsional. Extend menentukan pengaturan ekstensi kustom. MessageCallback menentukan pengaturan callback pesan. AccelerateConfig menentukan pengaturan akselerasi upload. Anda harus mengaktifkan fitur akselerasi upload sebelum menggunakannya. */
    //request.setUserData("{\"Extend\":{\"test\":\"www\",\"localId\":\"xxxx\"},\"MessageCallback\":{\"CallbackType\":\"http\",\"CallbackURL\":\"http://example.aliyundoc.com\"},\"AccelerateConfig\":{\"Type\":\"oss\",\"Domain\":\"****Bucket.oss-accelerate.aliyuncs.com\"}}");
    /* ID kategori video. Parameter ini opsional. */
    //request.setCateId(0);
    /* Tag video. Pisahkan beberapa tag dengan koma (,). Parameter ini opsional. */
    //request.setTags("Tag 1,Tag 2");
    /* Deskripsi video. Parameter ini opsional. */
    //request.setDescription("Video description");
    /* URL gambar mini. Parameter ini opsional. */
    //request.setCoverURL("http://cover.example.com/image_01.jpg");
    /* ID grup templat. Parameter ini opsional. */
    //request.setTemplateGroupId("8c4792cbc8694e7084fd5330e56****");
    /* ID alur kerja. Parameter ini opsional. */
    //request.setWorkflowId("d4430d07361f0*be1339577859b0****");
    /* Wilayah penyimpanan. Parameter ini opsional. */
    //request.setStorageLocation("in-201703232118266-5sejd****.oss-cn-shanghai.aliyuncs.com");
    /* Mengaktifkan callback kemajuan upload default. */
    //request.setPrintProgress(true);
    /* Menetapkan callback kemajuan upload kustom. Callback harus mewarisi VoDProgressListener. */
    /* Fitur ini dinonaktifkan secara default. Jika Anda mengaktifkan fitur ini, server mengembalikan detail upload dalam log selama proses upload. Jika Anda tidak perlu menerima pesan ini, nonaktifkan fitur ini. */
    //request.setProgressListener(new PutObjectProgressListener());
    /* Menetapkan ID aplikasi. */
    //request.setAppId("app-100****");
    /* Titik akhir ApsaraVideo VOD. */
    //request.setApiRegionId("cn-shanghai");
    /* Wilayah penerapan ECS. */
    // request.setEcsRegionId("cn-shanghai");
    // Jika wilayah penerapan ECS sama dengan wilayah titik akhir ApsaraVideo VOD, upload jaringan internal akan diaktifkan secara otomatis.

     /* Mengonfigurasi proxy. Parameter ini opsional. */
     //OSSConfig ossConfig = new OSSConfig();
     /* <Wajib> Host server proxy. */
     //ossConfig.setProxyHost("<yourProxyHost>");
     /* <Wajib> Port server proxy. */
     //ossConfig.setProxyPort(-1);
     /* Protokol yang digunakan untuk menghubungkan ke OSS. Nilai yang valid: HTTP dan HTTPS. Nilai default: HTTP. */
     //ossConfig.setProtocol("HTTP");
     /* User agent, yaitu header User-Agent dalam HTTP. Nilai default: aliyun-sdk-java. */
     //ossConfig.setUserAgent("<yourUserAgent>");
     /* Username untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
     //ossConfig.setProxyUsername("<yourProxyUserName>");
     /* Password untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
     //ossConfig.setProxyPassword("<yourProxyPassword>");
     //request.setOssConfig(ossConfig);

    UploadVideoImpl uploader = new UploadVideoImpl();
    UploadURLStreamResponse response = uploader.uploadURLStream(request);
    System.out.print("RequestId=" + response.getRequestId() + "\n"); // ID permintaan yang dikirim ke ApsaraVideo VOD.
    if (response.isSuccess()) {
        System.out.print("VideoId=" + response.getVideoId() + "\n");
    } else {
        /* Jika URL callback yang ditentukan tidak valid, upload video tidak terpengaruh. VideoId dan kode kesalahan dikembalikan. Dalam kasus lain, jika upload gagal, VideoId kosong. Dalam hal ini, analisis penyebab kegagalan berdasarkan kode kesalahan yang dikembalikan. */
        System.out.print("VideoId=" + response.getVideoId() + "\n");
        System.out.print("ErrorCode=" + response.getCode() + "\n");
        System.out.print("ErrorMessage=" + response.getMessage() + "\n");
    }
}

/**
 * API untuk upload aliran file.
 *
 * @param accessKeyId
 * @param accessKeySecret
 * @param title
 * @param fileName
 */
private static void testUploadFileStream(String accessKeyId, String accessKeySecret, String title, String fileName) {
    UploadFileStreamRequest request = new UploadFileStreamRequest(accessKeyId, accessKeySecret, title, fileName);
    /* Menentukan apakah akan menggunakan watermark default. Parameter ini opsional. Jika Anda menentukan ID grup templat, watermark default akan digunakan berdasarkan konfigurasi grup templat. */
    //request.setShowWaterMark(true);
    /* Pengaturan callback pesan kustom dan pengaturan akselerasi upload. Parameter ini opsional. Extend menentukan pengaturan ekstensi kustom. MessageCallback menentukan pengaturan callback pesan. AccelerateConfig menentukan pengaturan akselerasi upload. Anda harus mengaktifkan fitur akselerasi upload sebelum menggunakannya. */
    //request.setUserData("{\"Extend\":{\"test\":\"www\",\"localId\":\"xxxx\"},\"MessageCallback\":{\"CallbackType\":\"http\",\"CallbackURL\":\"http://example.aliyundoc.com\"},\"AccelerateConfig\":{\"Type\":\"oss\",\"Domain\":\"****Bucket.oss-accelerate.aliyuncs.com\"}}");
    /* ID kategori video. Parameter ini opsional. */
    //request.setCateId(0);
    /* Tag video. Pisahkan beberapa tag dengan koma (,). Parameter ini opsional. */
    //request.setTags("Tag 1,Tag 2");
    /* Deskripsi video. Parameter ini opsional. */
    //request.setDescription("Video description");
    /* URL gambar mini. Parameter ini opsional. */
    //request.setCoverURL("http://cover.example.com/image_01.jpg");
    /* ID grup templat. Parameter ini opsional. */
    //request.setTemplateGroupId("8c4792cbc8694e7084fd5330e56****");
    /* ID alur kerja. Parameter ini opsional. */
    //request.setWorkflowId("d4430d07361f0*be1339577859b0****");
    /* Wilayah penyimpanan. Parameter ini opsional. */
    //request.setStorageLocation("in-201703232118266-5sejd****.oss-cn-shanghai.aliyuncs.com");
    /* Mengaktifkan callback kemajuan upload default. */
    //request.setPrintProgress(true);
    /* Menetapkan callback kemajuan upload kustom. Callback harus mewarisi VoDProgressListener. */
    /* Fitur ini dinonaktifkan secara default. Jika Anda mengaktifkan fitur ini, server mengembalikan detail upload dalam log selama proses upload. Jika Anda tidak perlu menerima pesan ini, nonaktifkan fitur ini. */
    //request.setProgressListener(new PutObjectProgressListener());
    /* Menetapkan ID aplikasi. */
    //request.setAppId("app-100****");
    /* Titik akhir ApsaraVideo VOD. */
    //request.setApiRegionId("cn-shanghai");
    /* Wilayah penerapan ECS. */
    // request.setEcsRegionId("cn-shanghai");
    // Jika wilayah penerapan ECS sama dengan wilayah titik akhir ApsaraVideo VOD, upload jaringan internal akan diaktifkan secara otomatis.

     /* Mengonfigurasi proxy. Parameter ini opsional. */
     //OSSConfig ossConfig = new OSSConfig();
     /* <Wajib> Host server proxy. */
     //ossConfig.setProxyHost("<yourProxyHost>");
     /* <Wajib> Port server proxy. */
     //ossConfig.setProxyPort(-1);
     /* Protokol yang digunakan untuk menghubungkan ke OSS. Nilai yang valid: HTTP dan HTTPS. Nilai default: HTTP. */
     //ossConfig.setProtocol("HTTP");
     /* User agent, yaitu header User-Agent dalam HTTP. Nilai default: aliyun-sdk-java. */
     //ossConfig.setUserAgent("<yourUserAgent>");
     /* Username untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
     //ossConfig.setProxyUsername("<yourProxyUserName>");
     /* Password untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
     //ossConfig.setProxyPassword("<yourProxyPassword>");
     //request.setOssConfig(ossConfig);

    UploadVideoImpl uploader = new UploadVideoImpl();
    UploadFileStreamResponse response = uploader.uploadFileStream(request);
    System.out.print("RequestId=" + response.getRequestId() + "\n"); // ID permintaan yang dikirim ke ApsaraVideo VOD.
    if (response.isSuccess()) {
        System.out.print("VideoId=" + response.getVideoId() + "\n");
    } else {
        /* Jika URL callback yang ditentukan tidak valid, upload video tidak terpengaruh. VideoId dan kode kesalahan dikembalikan. Dalam kasus lain, jika upload gagal, VideoId kosong. Dalam hal ini, analisis penyebab kegagalan berdasarkan kode kesalahan yang dikembalikan. */
        System.out.print("VideoId=" + response.getVideoId() + "\n");
        System.out.print("ErrorCode=" + response.getCode() + "\n");
        System.out.print("ErrorMessage=" + response.getMessage() + "\n");
    }
}

/**
 * API untuk unggah streaming.
 *
 * @param accessKeyId
 * @param accessKeySecret
 * @param title
 * @param fileName
 * @param inputStream
 */
private static void testUploadStream(String accessKeyId, String accessKeySecret, String title, String fileName, InputStream inputStream) {
    UploadStreamRequest request = new UploadStreamRequest(accessKeyId, accessKeySecret, title, fileName, inputStream);
     /* Menentukan apakah akan menggunakan watermark default. Parameter ini opsional. Jika Anda menentukan ID grup templat, watermark default akan digunakan berdasarkan konfigurasi grup templat. */
    //request.setShowWaterMark(true);
    /* Pengaturan callback pesan kustom dan pengaturan akselerasi upload. Parameter ini opsional. Extend menentukan pengaturan ekstensi kustom. MessageCallback menentukan pengaturan callback pesan. AccelerateConfig menentukan pengaturan akselerasi upload. Anda harus mengaktifkan fitur akselerasi upload sebelum menggunakannya. */
    //request.setUserData("{\"Extend\":{\"test\":\"www\",\"localId\":\"xxxx\"},\"MessageCallback\":{\"CallbackType\":\"http\",\"CallbackURL\":\"http://example.aliyundoc.com\"},\"AccelerateConfig\":{\"Type\":\"oss\",\"Domain\":\"****Bucket.oss-accelerate.aliyuncs.com\"}}");
    /* ID kategori video. Parameter ini opsional. */
    //request.setCateId(0);
    /* Tag video. Pisahkan beberapa tag dengan koma (,). Parameter ini opsional. */
    //request.setTags("Tag 1,Tag 2");
    /* Deskripsi video. Parameter ini opsional. */
    //request.setDescription("Video description");
    /* URL gambar mini. Parameter ini opsional. */
    //request.setCoverURL("http://cover.example.com/image_01.jpg");
    /* ID grup templat. Parameter ini opsional. */
    //request.setTemplateGroupId("8c4792cbc8694e7084fd5330e56****");
    /* ID alur kerja. Parameter ini opsional. */
    //request.setWorkflowId("d4430d07361f0*be1339577859b0****");
    /* Wilayah penyimpanan. Parameter ini opsional. */
    //request.setStorageLocation("in-201703232118266-5sejd****.oss-cn-shanghai.aliyuncs.com");
    /* Mengaktifkan callback kemajuan upload default. */
    // request.setPrintProgress(true);
    /* Menetapkan callback kemajuan upload kustom. Callback harus mewarisi VoDProgressListener. */
    /* Fitur ini dinonaktifkan secara default. Jika Anda mengaktifkan fitur ini, server mengembalikan detail upload dalam log selama proses upload. Jika Anda tidak perlu menerima pesan ini, nonaktifkan fitur ini. */
    // request.setProgressListener(new PutObjectProgressListener());
     /* Menetapkan ID aplikasi. */
    //request.setAppId("app-100****");
    /* Titik akhir ApsaraVideo VOD. */
    //request.setApiRegionId("cn-shanghai");
    /* Wilayah penerapan ECS. */
    // request.setEcsRegionId("cn-shanghai");
    // Jika wilayah penerapan ECS sama dengan wilayah titik akhir ApsaraVideo VOD, upload jaringan internal akan diaktifkan secara otomatis.

     /* Mengonfigurasi proxy. Parameter ini opsional. */
     //OSSConfig ossConfig = new OSSConfig();
     /* <Wajib> Host server proxy. */
     //ossConfig.setProxyHost("<yourProxyHost>");
     /* <Wajib> Port server proxy. */
     //ossConfig.setProxyPort(-1);
     /* Protokol yang digunakan untuk menghubungkan ke OSS. Nilai yang valid: HTTP dan HTTPS. Nilai default: HTTP. */
     //ossConfig.setProtocol("HTTP");
     /* User agent, yaitu header User-Agent dalam HTTP. Nilai default: aliyun-sdk-java. */
     //ossConfig.setUserAgent("<yourUserAgent>");
     /* Username untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
     //ossConfig.setProxyUsername("<yourProxyUserName>");
     /* Password untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
     //ossConfig.setProxyPassword("<yourProxyPassword>");
     //request.setOssConfig(ossConfig);
        
    UploadVideoImpl uploader = new UploadVideoImpl();
    UploadStreamResponse response = uploader.uploadStream(request);
    System.out.print("RequestId=" + response.getRequestId() + "\n");  // ID permintaan yang dikirim ke ApsaraVideo VOD.
    if (response.isSuccess()) {
        System.out.print("VideoId=" + response.getVideoId() + "\n");
    } else { // Jika URL callback yang ditentukan tidak valid, upload video tidak terpengaruh. VideoId dan kode kesalahan dikembalikan. Dalam kasus lain, jika upload gagal, VideoId kosong. Dalam hal ini, analisis penyebab kegagalan berdasarkan kode kesalahan yang dikembalikan.
        System.out.print("VideoId=" + response.getVideoId() + "\n");
        System.out.print("ErrorCode=" + response.getCode() + "\n");
        System.out.print("ErrorMessage=" + response.getMessage() + "\n");
    }
  }
}

public class UploadVideoDemo {
    // Wajib. Tentukan pasangan AccessKey.
    // Pasangan AccessKey Akun Alibaba Cloud memiliki izin untuk mengakses semua API. Kami menyarankan agar Anda menggunakan pasangan AccessKey Pengguna RAM untuk panggilan API atau O&M rutin.
    // Kami sangat menyarankan agar Anda tidak menyematkan ID AccessKey dan Rahasia AccessKey secara langsung ke dalam kode proyek Anda. Jika tidak, pasangan AccessKey tersebut dapat bocor dan keamanan semua resource dalam akun Anda akan terganggu.
    // Contoh ini menunjukkan cara membaca pasangan AccessKey dari variabel lingkungan untuk mengotentikasi akses API. Sebelum menjalankan kode contoh, konfigurasikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID dan ALIBABA_CLOUD_ACCESS_KEY_SECRET.
    private static final String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
    private static final String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");

    public static void main(String[] args) {
    // Unggah file M3U8.
        // 1. Unggah file audio atau video M3U8 lokal.
        testUploadLocalM3u8(accessKeyId, accessKeySecret);
        // 2. Unggah file audio atau video M3U8 berbasis web.
        testUploadWebM3u8(accessKeyId, accessKeySecret);
    }
    /**
     * Mengunggah file video atau audio M3U8 lokal ke ApsaraVideo VOD. Secara default, file M3U8 dan shard-nya berada di direktori yang sama. Jika sliceFilenames kosong, alamat shard diurai dari direktori yang sama.
     *
     * @param request Permintaan untuk mengunggah file M3U8 lokal.
     *                m3u8Filename: Jalur mutlak manifes M3U8 lokal. Informasi shard dalam file M3U8 harus berupa jalur relatif. Tidak boleh berisi URL atau jalur lokal absolut.
     *                sliceFilenames: Daftar jalur mutlak shard TS. Jika Anda menentukan parameter ini, daftar ini akan digunakan. Jika tidak, file m3u8 yang ditentukan oleh m3u8Filename akan diurai secara otomatis.
     */
    private static void testUploadLocalM3u8(String accessKeyId, String accessKeySecret) {
        String title = "test_upload_local_m3u8";
        String m3u8Filename = "/Users/test/0e9ecfc6da934d1887ed7bdfc925****/cc38da35c7b24de0abe58619cdd7****-6479a12446b994719838e0307f****-ld.m3u8";
        UploadLocalM3u8Request request = new UploadLocalM3u8Request(accessKeyId, accessKeySecret, title, m3u8Filename);
        String[] sliceFilenames = new String[]{
                "/Users/test/0e9ecfc6da934d1887ed7bdfc925****/slices/cc38da35c7b24de0abe58619cdd7****-c45797a1ad6e75fbb9d1a8493703****-ld-00001.ts",
                "/Users/test/0e9ecfc6da934d1887ed7bdfc925****/slices/cc38da35c7b24de0abe58619cdd7****-c45797a1ad6e75fbb9d1a8493703****-ld-00002.ts",
                "/Users/test/0e9ecfc6da934d1887ed7bdfc925****/slices/cc38da35c7b24de0abe58619cdd7****-c45797a1ad6e75fbb9d1a8493703****-ld-00003.ts",
                "/Users/test/0e9ecfc6da934d1887ed7bdfc925****/slices/cc38da35c7b24de0abe58619cdd7****-c45797a1ad6e75fbb9d1a8493703****-ld-00004.ts",
                "/Users/test/0e9ecfc6da934d1887ed7bdfc925****/slices/cc38da35c7b24de0abe58619cdd7****-c45797a1ad6e75fbb9d1a8493703****-ld-00005.ts"
        };
        // Daftar file shard TS. Parameter ini opsional. Jika Anda tidak menentukan parameter ini, alamat shard diurai langsung dari file M3U8.
        request.setSliceFilenames(sliceFilenames);
        /* Ukuran setiap bagian untuk unggah multi-bagian. Nilai default: 2 MB. */
        request.setPartSize(2 * 1024 * 1024L);
        /* Jumlah thread konkuren untuk unggah multi-bagian. Nilai default: 1. Catatan: Konfigurasi ini mengonsumsi sumber daya CPU server. Tentukan jumlah thread berdasarkan kinerja server Anda. */
        request.setTaskNum(1);
        /* Menentukan apakah akan menampilkan watermark. Parameter ini opsional. Jika Anda menentukan ID grup templat, watermark akan ditampilkan berdasarkan konfigurasi grup templat. */
        //request.setShowWaterMark(true);
        /* Pengaturan callback pesan kustom dan pengaturan akselerasi upload. Parameter ini opsional. Extend menentukan pengaturan ekstensi kustom. MessageCallback menentukan pengaturan callback pesan. AccelerateConfig menentukan pengaturan akselerasi upload. Anda harus mengaktifkan fitur akselerasi upload sebelum menggunakannya. */
        //request.setUserData("{\"Extend\":{\"test\":\"www\",\"localId\":\"xxxx\"},\"MessageCallback\":{\"CallbackType\":\"http\",\"CallbackURL\":\"http://example.aliyundoc.com\"},\"AccelerateConfig\":{\"Type\":\"oss\",\"Domain\":\"****Bucket.oss-accelerate.aliyuncs.com\"}}");
        /* ID kategori video. Parameter ini opsional. */
        //request.setCateId(-1L);
        /* Tag video. Pisahkan beberapa tag dengan koma (,). Parameter ini opsional. */
        //request.setTags("Tag 1,Tag 2");
        /* Deskripsi video. Parameter ini opsional. */
        //request.setDescription("Video description");
        /* URL gambar mini. Parameter ini opsional. */
        //request.setCoverURL("http://cover.sample.com/sample.jpg");
        /* ID grup templat. Parameter ini opsional. */
        //request.setTemplateGroupId("8c4792cbc8694e7084fd5330e56****");
        /* ID alur kerja. Parameter ini opsional. */
        //request.setWorkflowId("d4430d07361f0*be1339577859b0****");
        /* Wilayah penyimpanan. Parameter ini opsional. */
        //request.setStorageLocation("in-201703232118266-5sejd****.oss-cn-shanghai.aliyuncs.com");
        /* Menetapkan ID aplikasi. */
        // request.setAppId("app-1000000");
        /* Titik akhir ApsaraVideo VOD. */
        // request.setApiRegionId("cn-shanghai");
        /* Wilayah penerapan ECS. */
        // request.setEcsRegionId("cn-shanghai");

        /* Mengonfigurasi proxy. Parameter ini opsional. */
        //OSSConfig ossConfig = new OSSConfig();
        /* <Wajib> Host server proxy. */
        //ossConfig.setProxyHost("<yourProxyHost>");
        /* <Wajib> Port server proxy. */
        //ossConfig.setProxyPort(-1);
        /* Protokol yang digunakan untuk menghubungkan ke OSS. Nilai yang valid: HTTP dan HTTPS. Nilai default: HTTP. */
        //ossConfig.setProtocol("HTTP");
        /* User agent, yaitu header User-Agent dalam HTTP. Nilai default: aliyun-sdk-java. */
        //ossConfig.setUserAgent("<yourUserAgent>");
        /* Username untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyUsername("<yourProxyUserName>");
        /* Password untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyPassword("<yourProxyPassword>");
        //request.setOssConfig(ossConfig);
        
        UploadM3u8FileImpl uploadM3u8File = new UploadM3u8FileImpl();
        UploadLocalM3u8Response uploadLocalM3u8Response = uploadM3u8File.uploadLocalM3u8(request);
        System.out.println("code = " + uploadLocalM3u8Response.getCode());
        System.out.println("message = " + uploadLocalM3u8Response.getMessage());
        System.out.println("videoId = " + uploadLocalM3u8Response.getVideoId());
        System.out.println("requestId = " + uploadLocalM3u8Response.getRequestId());
    }

    /**
     * Mengunggah file video atau audio M3U8 berbasis web ke ApsaraVideo VOD. Ruang disk lokal yang cukup diperlukan karena file tersebut pertama-tama diunduh ke direktori lokal sementara lalu diunggah ke penyimpanan ApsaraVideo VOD.
     *
     * @param request Permintaan untuk mengunggah file M3U8 berbasis web.
     *                m3u8FileURL: URL manifes M3U8 berbasis web. Informasi shard dalam file M3U8 harus berupa jalur relatif. Tidak boleh berisi URL atau jalur lokal absolut.
     *                sliceFileURLs: Daftar URL shard TS. Anda harus membuat daftar URL shard TS sendiri.
     */
    private static void testUploadWebM3u8(String accessKeyId, String accessKeySecret) {
        String title = "test_upload_web_m3u8";
        String m3u8FileURL = "http://test.aliyun.com/f0d644abc547129e957b386f77****/a0e1e2817ab9425aa558fe67a90e****-538087dcf2c201c31ce4324bf76af69****.m3u8";
        UploadWebM3u8Request request = new UploadWebM3u8Request(accessKeyId, accessKeySecret, title, m3u8FileURL);
        String[] sliceFileURLs = new String[]{
                "http://test.aliyun.com/f0d644abc547129e957b386f77****/a0e1e2817ab9425aa558fe67a90e****-822598b9c170a8c6dad985e20cd9c27d-ld-0****.ts",
                "http://test.aliyun.com/f0d644abc547129e957b386f77****/a0e1e2817ab9425aa558fe67a90e****-822598b9c170a8c6dad985e20cd9c27d-ld-0****.ts",
                "http://test.aliyun.com/f0d644abc547129e957b386f77****/a0e1e2817ab9425aa558fe67a90e****-822598b9c170a8c6dad985e20cd9c27d-ld-0****.ts",
                "http://test.aliyun.com/f0d644abc547129e957b386f77****/a0e1e2817ab9425aa558fe67a90e****-822598b9c170a8c6dad985e20cd9c27d-ld-0****.ts",
                "http://test.aliyun.com/f0d644abc547129e957b386f77****/a0e1e2817ab9425aa558fe67a90e****-822598b9c170a8c6dad985e20cd9c27d-ld-0****.ts"
        };
        // Alamat shard TS. Parameter ini opsional. Jika Anda tidak menentukan parameter ini, alamat shard diurai langsung dari m3u8FileURL.
        request.setSliceFileURLs(sliceFileURLs);
        /* Direktori penyimpanan sementara untuk file yang diunduh. Anda dapat menyesuaikan direktori ini. Jika Anda tidak menentukan direktori, file akan disimpan di direktori tempat program dijalankan. */
        // request.setGlobalLocalFilePath("/User/download/");
        /* Ukuran setiap bagian untuk unggah multi-bagian. Nilai default: 2 MB. */
        request.setPartSize(2 * 1024 * 1024L);
        /* Jumlah thread konkuren untuk unggah multi-bagian. Nilai default: 1. Catatan: Konfigurasi ini mengonsumsi sumber daya CPU server. Tentukan jumlah thread berdasarkan kinerja server Anda. */
        request.setTaskNum(1);
        /* Menentukan apakah akan menampilkan watermark. Parameter ini opsional. Jika Anda menentukan ID grup templat, watermark akan ditampilkan berdasarkan konfigurasi grup templat. */
        //request.setShowWaterMark(true);
        /* Pengaturan callback pesan kustom dan pengaturan akselerasi upload. Parameter ini opsional. Extend menentukan pengaturan ekstensi kustom. MessageCallback menentukan pengaturan callback pesan. AccelerateConfig menentukan pengaturan akselerasi upload. Anda harus mengaktifkan fitur akselerasi upload sebelum menggunakannya. */
        //request.setUserData("{\"Extend\":{\"test\":\"www\",\"localId\":\"xxxx\"},\"MessageCallback\":{\"CallbackType\":\"http\",\"CallbackURL\":\"http://example.aliyundoc.com\"},\"AccelerateConfig\":{\"Type\":\"oss\",\"Domain\":\"****Bucket.oss-accelerate.aliyuncs.com\"}}");
        /* ID kategori video. Parameter ini opsional. */
        //request.setCateId(-1L);
        /* Tag video. Pisahkan beberapa tag dengan koma (,). Parameter ini opsional. */
        //request.setTags("Tag 1,Tag 2");
        /* Deskripsi video. Parameter ini opsional. */
        //request.setDescription("Video description");
        /* URL gambar mini. Parameter ini opsional. */
        //request.setCoverURL("http://cover.example.com/sample.jpg");
        /* ID grup templat. Parameter ini opsional. */
        //request.setTemplateGroupId("8c4792cbc8694e7084fd5330e56****");
        /* ID alur kerja. Parameter ini opsional. */
        //request.setWorkflowId("d4430d07361f0*be1339577859b0****");
        /* Wilayah penyimpanan. Parameter ini opsional. */
        //request.setStorageLocation("in-2017032321****-5sejdln9o.oss-cn-shanghai.aliyuncs.com");
        /* Menetapkan ID aplikasi. */
        //request.setAppId("app-100****");
        /* Titik akhir ApsaraVideo VOD. */
        //request.setApiRegionId("cn-shanghai");
        /* Wilayah penerapan ECS. */
        // request.setEcsRegionId("cn-shanghai");

        /* Mengonfigurasi proxy. Parameter ini opsional. */
        //OSSConfig ossConfig = new OSSConfig();
        /* <Wajib> Host server proxy. */
        //ossConfig.setProxyHost("<yourProxyHost>");
        /* <Wajib> Port server proxy. */
        //ossConfig.setProxyPort(-1);
        /* Protokol yang digunakan untuk menghubungkan ke OSS. Nilai yang valid: HTTP dan HTTPS. Nilai default: HTTP. */
        //ossConfig.setProtocol("HTTP");
        /* User agent, yaitu header User-Agent dalam HTTP. Nilai default: aliyun-sdk-java. */
        //ossConfig.setUserAgent("<yourUserAgent>");
        /* Username untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyUsername("<yourProxyUserName>");
        /* Password untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyPassword("<yourProxyPassword>");
        //request.setOssConfig(ossConfig);

        UploadM3u8FileImpl uploadM3u8File = new UploadM3u8FileImpl();
        UploadWebM3u8Response uploadWebM3u8Response = uploadM3u8File.uploadWebM3u8(request);
        System.out.println("code = " + uploadWebM3u8Response.getCode());
        System.out.println("message = " + uploadWebM3u8Response.getMessage());
        System.out.println("videoId = " + uploadWebM3u8Response.getVideoId());
        System.out.println("requestId = " + uploadWebM3u8Response.getRequestId());
    }
}

public class UploadImageDemo {
    // Wajib. Tentukan pasangan AccessKey.
    // Pasangan AccessKey Akun Alibaba Cloud memiliki izin untuk mengakses semua API. Kami menyarankan agar Anda menggunakan pasangan AccessKey Pengguna RAM untuk panggilan API atau O&M rutin.
    // Kami sangat menyarankan agar Anda tidak menyematkan ID AccessKey dan Rahasia AccessKey secara langsung ke dalam kode proyek Anda. Jika tidak, pasangan AccessKey tersebut dapat bocor dan keamanan semua resource dalam akun Anda akan terganggu.
    // Contoh ini menunjukkan cara membaca pasangan AccessKey dari variabel lingkungan untuk mengotentikasi akses API. Sebelum menjalankan kode contoh, konfigurasikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID dan ALIBABA_CLOUD_ACCESS_KEY_SECRET.
    private static final String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
    private static final String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
    
    public static void main(String[] args) {
        // Unggah gambar.
        // 1. Unggah file gambar lokal.
         testUploadImageLocalFile(accessKeyId, accessKeySecret);
        // 2. Gunakan unggah streaming untuk mengunggah aliran file atau aliran jaringan sebagai gambar.
         testUploadImageStream(accessKeyId, accessKeySecret);
    }
    /**
     * API untuk upload file gambar lokal.
     *
     * @param accessKeyId
     * @param accessKeySecret
     */
    private static void testUploadImageLocalFile(String accessKeyId, String accessKeySecret) {
        /* Tipe gambar. Parameter ini wajib. Nilai yang valid: default, cover, dan watermark. */
        String imageType = "cover";
        UploadImageRequest request = new UploadImageRequest(accessKeyId, accessKeySecret, imageType);
        request.setImageType("cover");
        /* Ekstensi nama file gambar. Parameter ini opsional. Nilai yang valid: png, jpg, dan jpeg. */
        //request.setImageExt("png");
        /* Judul gambar. Parameter ini opsional. Judul dapat memiliki panjang hingga 128 byte dan harus dikodekan UTF-8. */
        //request.setTitle("Image Title");
        /* Tag gambar. Parameter ini opsional. Satu tag dapat memiliki panjang hingga 32 byte. Anda dapat menambahkan hingga 16 tag. Pisahkan beberapa tag dengan koma (,). Tag harus dikodekan UTF-8. */
        //request.setTags("Tag 1,Tag 2");
        /* Wilayah penyimpanan. Parameter ini opsional. */
        //request.setStorageLocation("out-4f3952f78c0211e8b30200****.oss-cn-shanghai.aliyuncs.com");
        /* Untuk unggah streaming, InputStream wajib, dan fileName opsional. fileName menentukan nama file sumber, seperti FileName.png. */
        String fileName = "/Users/demo/png/test.png";
        request.setFileName(fileName);
        /* Mengaktifkan callback kemajuan upload default. */
        //request.setPrintProgress(false);
        /* Menetapkan callback kemajuan upload kustom. Callback harus mewarisi VoDProgressListener. */
        /* Fitur ini dinonaktifkan secara default. Jika Anda mengaktifkan fitur ini, server mengembalikan detail upload dalam log selama proses upload. Jika Anda tidak perlu menerima pesan ini, nonaktifkan fitur ini. */
        // request.setProgressListener(new PutObjectProgressListener());
        /* Menetapkan ID aplikasi. */
        //request.setAppId("app-100****");
        /* Titik akhir ApsaraVideo VOD. */
        //request.setApiRegionId("cn-shanghai");

        /* Mengonfigurasi proxy. Parameter ini opsional. */
        //OSSConfig ossConfig = new OSSConfig();
        /* <Wajib> Host server proxy. */
        //ossConfig.setProxyHost("<yourProxyHost>");
        /* <Wajib> Port server proxy. */
        //ossConfig.setProxyPort(-1);
        /* Protokol yang digunakan untuk menghubungkan ke OSS. Nilai yang valid: HTTP dan HTTPS. Nilai default: HTTP. */
        //ossConfig.setProtocol("HTTP");
        /* User agent, yaitu header User-Agent dalam HTTP. Nilai default: aliyun-sdk-java. */
        //ossConfig.setUserAgent("<yourUserAgent>");
        /* Username untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyUsername("<yourProxyUserName>");
        /* Password untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyPassword("<yourProxyPassword>");
        //request.setOssConfig(ossConfig);

        UploadImageImpl uploadImage = new UploadImageImpl();
        UploadImageResponse response = uploadImage.upload(request);
        System.out.print("RequestId=" + response.getRequestId() + "\n");
        if (response.isSuccess()) {
            System.out.print("ImageId=" + response.getImageId() + "\n");
            System.out.print("ImageURL=" + response.getImageURL() + "\n");
        } else {
            System.out.print("ErrorCode=" + response.getCode() + "\n");
            System.out.print("ErrorMessage=" + response.getMessage() + "\n");
        }
    }
    /**
     * API untuk unggah streaming gambar. Metode ini mendukung aliran file dan aliran jaringan.
     *
     * @param accessKeyId
     * @param accessKeySecret
     */
    private static void testUploadImageStream(String accessKeyId, String accessKeySecret) {
        /* Tipe gambar. Parameter ini wajib. Nilai yang valid: default, cover, dan watermark. */
        String imageType = "cover";
        UploadImageRequest request = new UploadImageRequest(accessKeyId, accessKeySecret, imageType);
        /* Ekstensi nama file gambar. Parameter ini opsional. Nilai yang valid: png, jpg, dan jpeg. */
        //request.setImageExt("png");
        /* Judul gambar. Parameter ini opsional. Judul dapat memiliki panjang hingga 128 byte dan harus dikodekan UTF-8. */
        //request.setTitle("Image Title");
        /* Tag gambar. Parameter ini opsional. Satu tag dapat memiliki panjang hingga 32 byte. Anda dapat menambahkan hingga 16 tag. Pisahkan beberapa tag dengan koma (,). Tag harus dikodekan UTF-8. */
        //request.setTags("Tag 1,Tag 2");
        /* Wilayah penyimpanan. Parameter ini opsional. */
        //request.setStorageLocation("out-4f3952f78c0211e8b30200****.oss-cn-shanghai.aliyuncs.com");
        /* Untuk unggah streaming, InputStream wajib, dan fileName opsional. fileName menentukan nama file sumber, seperti FileName.png. */
        //request.setFileName("TestFileName.png");
        /* Mengaktifkan callback kemajuan upload default. */
        // request.setPrintProgress(true);
        /* Menetapkan callback kemajuan upload kustom. Callback harus mewarisi VoDProgressListener. */
        /* Fitur ini dinonaktifkan secara default. Jika Anda mengaktifkan fitur ini, server mengembalikan detail upload dalam log selama proses upload. Jika Anda tidak perlu menerima pesan ini, nonaktifkan fitur ini. */
        // request.setProgressListener(new PutObjectProgressListener());
        /* Menetapkan ID aplikasi. */
        //request.setAppId("app-1000000");

        /* Mengonfigurasi proxy. Parameter ini opsional. */
        //OSSConfig ossConfig = new OSSConfig();
        /* <Wajib> Host server proxy. */
        //ossConfig.setProxyHost("<yourProxyHost>");
        /* <Wajib> Port server proxy. */
        //ossConfig.setProxyPort(-1);
        /* Protokol yang digunakan untuk menghubungkan ke OSS. Nilai yang valid: HTTP dan HTTPS. Nilai default: HTTP. */
        //ossConfig.setProtocol("HTTP");
        /* User agent, yaitu header User-Agent dalam HTTP. Nilai default: aliyun-sdk-java. */
        //ossConfig.setUserAgent("<yourUserAgent>");
        /* Username untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyUsername("<yourProxyUserName>");
        /* Password untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyPassword("<yourProxyPassword>");
        //request.setOssConfig(ossConfig);
        
        // 1. Unggah aliran file.
        // InputStream fileStream = getFileStream(request.getFileName());
        // if (fileStream != null) { 
        //     request.setInputStream(fileStream);
        // }
        // 2. Unggah aliran jaringan.
        String url = "http://test.aliyun.com/image/default/test.png";
        InputStream urlStream = getUrlStream(url);
        if (urlStream != null) {
            request.setInputStream(urlStream); 
       }
        // Mulai mengunggah gambar.
        UploadImageImpl uploadImage = new UploadImageImpl();
        UploadImageResponse response = uploadImage.upload(request);
        System.out.print("RequestId=" + response.getRequestId() + "\n");
        if (response.isSuccess()) {
            System.out.print("ImageId=" + response.getImageId() + "\n");
            System.out.print("ImageURL=" + response.getImageURL() + "\n");
        } else {
            System.out.print("ErrorCode=" + response.getCode() + "\n");
            System.out.print("ErrorMessage=" + response.getMessage() + "\n");
        }
    }
    private static InputStream getFileStream(String fileName) {
        try {
            return new FileInputStream(fileName);
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        }
        return null;
    }
    private static InputStream getUrlStream(String url) {
        try {
            return new URL(url).openStream();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return null;
    }
}          

public class UploadAttachedMediaDemo {
    // Wajib. Tentukan pasangan AccessKey.
    // Pasangan AccessKey Akun Alibaba Cloud memiliki izin untuk mengakses semua API. Kami menyarankan agar Anda menggunakan pasangan AccessKey Pengguna RAM untuk panggilan API atau O&M rutin.
    // Kami sangat menyarankan agar Anda tidak menyematkan ID AccessKey dan Rahasia AccessKey secara langsung ke dalam kode proyek Anda. Jika tidak, pasangan AccessKey tersebut dapat bocor dan keamanan semua resource dalam akun Anda akan terganggu.
    // Contoh ini menunjukkan cara membaca pasangan AccessKey dari variabel lingkungan untuk mengotentikasi akses API. Sebelum menjalankan kode contoh, konfigurasikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID dan ALIBABA_CLOUD_ACCESS_KEY_SECRET.
    private static final String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
    private static final String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
    
    public static void main(String[] args) {
        // Unggah aset media pendukung.
        // Unggah file aset media pendukung lokal.
        testUploadAttachedMediaLocalFile(accessKeyId, accessKeySecret);
        // Gunakan unggah streaming untuk mengunggah aset media pendukung. Metode ini mendukung aliran file dan aliran jaringan.
        testUploadAttachedMediaStream(accessKeyId, accessKeySecret);
    }
 /**
     * API untuk upload file aset media pendukung lokal.
     *
     * @param accessKeyId
     * @param accessKeySecret
     */
    private static void testUploadAttachedMediaLocalFile(String accessKeyId, String accessKeySecret) {
        /* Tipe bisnis. */
        String businessType = "watermark";
        /* Ekstensi nama file. */
        String mediaExt = "png";
        String filename = "/Users/demo/png/test.png";
        UploadAttachedMediaRequest request = new UploadAttachedMediaRequest(accessKeyId, accessKeySecret, businessType, mediaExt);
        request.setFileName(filename);
        /* Judul. */
        request.setTitle("test_attached_media");
        /* ID kategori. */
        request.setCateId(-1L);
        /* Tag. Pisahkan beberapa tag dengan koma (,). Parameter ini opsional. */
        request.setTags("tag1,tag2");
        /* Deskripsi. Parameter ini opsional. */
        request.setDescription("test_desc");
        /* Wilayah penyimpanan. Parameter ini opsional. */
        request.setStorageLocation("out-20170323225118266-5l3hs5****.oss-cn-shanghai.aliyuncs.com");
        /* Titik akhir ApsaraVideo VOD. */
        request.setApiRegionId("cn-shanghai");
        /* Menetapkan ID aplikasi. */
        //request.setAppId("app-1000000");

        /* Mengonfigurasi proxy. Parameter ini opsional. */
        //OSSConfig ossConfig = new OSSConfig();
        /* <Wajib> Host server proxy. */
        //ossConfig.setProxyHost("<yourProxyHost>");
        /* <Wajib> Port server proxy. */
        //ossConfig.setProxyPort(-1);
        /* Protokol yang digunakan untuk menghubungkan ke OSS. Nilai yang valid: HTTP dan HTTPS. Nilai default: HTTP. */
        //ossConfig.setProtocol("HTTP");
        /* User agent, yaitu header User-Agent dalam HTTP. Nilai default: aliyun-sdk-java. */
        //ossConfig.setUserAgent("<yourUserAgent>");
        /* Username untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyUsername("<yourProxyUserName>");
        /* Password untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyPassword("<yourProxyPassword>");
        //request.setOssConfig(ossConfig);
        
        UploadAttachedMediaImpl uploader = new UploadAttachedMediaImpl();
        UploadAttachedMediaResponse response = uploader.upload(request);
        System.out.print("RequestId=" + response.getRequestId() + "\n");
        if (response.isSuccess()) {
            System.out.print("MediaId=" + response.getMediaId() + "\n");
            System.out.print("MediaURL=" + response.getMediaURL() + "\n");
            System.out.print("FileURL=" + response.getFileURL() + "\n");
        } else {
            System.out.print("ErrorCode=" + response.getCode() + "\n");
            System.out.print("ErrorMessage=" + response.getMessage() + "\n");
        }
    }
     /**
     * API untuk unggah streaming aset media pendukung. Metode ini mendukung aliran file dan aliran jaringan.
     *
     * @param accessKeyId
     * @param accessKeySecret
     */
    private static void testUploadAttachedMediaStream(String accessKeyId, String accessKeySecret) {
        /* Tipe bisnis. */

        String businessType = "watermark";

        /* Ekstensi nama file. */
        String mediaExt = "png";

        String filename = "http://test.aliyun.com/test.png";

        UploadAttachedMediaRequest request;
        // 1. Unggah aliran file.

        InputStream fileStream = getFileStream(filename);

        request = new UploadAttachedMediaRequest(accessKeyId, accessKeySecret, businessType, mediaExt);
        request.setInputStream(fileStream);


        // 2. Unggah aliran jaringan.

//        String url = "http://test.aliyun.com/image//test.png";

//        InputStream urlStream = getUrlStream(url);

//        request = new UploadAttachedMediaRequest(accessKeyId, accessKeySecret, businessType, mediaExt);
//        request.setInputStream(urlStream);

        /* Judul. */

        request.setTitle("test_attached_media");
        /* ID kategori. */
        request.setCateId(-1L);
        /* Tag. Pisahkan beberapa tag dengan koma (,). Parameter ini opsional. */
        request.setTags("tag1,tag2");

        /* Deskripsi. Parameter ini opsional. */
        request.setDescription("test_desc");

        /* Wilayah penyimpanan. Parameter ini opsional. */

        request.setStorageLocation("out-20170323225118266-5l3****wa.oss-cn-shanghai.aliyuncs.com");

        /* Titik akhir ApsaraVideo VOD. */
        request.setApiRegionId("cn-shanghai");

        /* Menetapkan ID aplikasi. */

        // request.setAppId("app-1000000");

        /* Mengonfigurasi proxy. Parameter ini opsional. */
        //OSSConfig ossConfig = new OSSConfig();
        /* <Wajib> Host server proxy. */
        //ossConfig.setProxyHost("<yourProxyHost>");
        /* <Wajib> Port server proxy. */
        //ossConfig.setProxyPort(-1);
        /* Protokol yang digunakan untuk menghubungkan ke OSS. Nilai yang valid: HTTP dan HTTPS. Nilai default: HTTP. */
        //ossConfig.setProtocol("HTTP");
        /* User agent, yaitu header User-Agent dalam HTTP. Nilai default: aliyun-sdk-java. */
        //ossConfig.setUserAgent("<yourUserAgent>");
        /* Username untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyUsername("<yourProxyUserName>");
        /* Password untuk autentikasi server proxy. Parameter ini wajib untuk protokol HTTPS. */
        //ossConfig.setProxyPassword("<yourProxyPassword>");
        //request.setOssConfig(ossConfig);

        // Mulai upload.

        UploadAttachedMediaImpl uploader = new UploadAttachedMediaImpl();

        UploadAttachedMediaResponse response = uploader.upload(request);
        System.out.print("RequestId=" + response.getRequestId() + "\n");
        if (response.isSuccess()) {

            System.out.print("MediaId=" + response.getMediaId() + "\n");

            System.out.print("MediaURL=" + response.getMediaURL() + "\n");

            System.out.print("FileURL=" + response.getFileURL() + "\n");
        } else {

            System.out.print("ErrorCode=" + response.getCode() + "\n");

            System.out.print("ErrorMessage=" + response.getMessage() + "\n");

        }

    }
    private static InputStream getFileStream(String fileName) {
        try {
            return new FileInputStream(fileName);
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        }
        return null;
    }
    private static InputStream getUrlStream(String url) {
        try {
            return new URL(url).openStream();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return null;
    }
}