ApsaraVideo VOD：Enkripsi HLS

Parameter berikut dalam kode contoh Java harus diubah sesuai kebutuhan Anda:

import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.http.ProtocolType;
import com.aliyuncs.vod.model.v20170321.DecryptKMSDataKeyRequest;
import com.aliyuncs.vod.model.v20170321.DecryptKMSDataKeyResponse;
import com.aliyuncs.profile.DefaultProfile;
import com.sun.net.httpserver.Headers;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import com.sun.net.httpserver.HttpServer;
import com.sun.net.httpserver.spi.HttpServerProvider;
import org.apache.commons.codec.binary.Base64;
import java.io.IOException;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.InetSocketAddress;
import java.net.URI;import java.util.regex.Matcher;
import java.util.regex.Pattern;
public class HlsDecryptServer {
    private static DefaultAcsClient client;
    static {
        // Wilayah KMS. Harus sama dengan wilayah tempat video disimpan.
        String region = "";
        // Pasangan AccessKey yang digunakan untuk mengakses KMS.
        // Pasangan AccessKey akun Alibaba Cloud memiliki izin untuk memanggil semua operasi API. Kami menyarankan agar Anda menggunakan pasangan AccessKey pengguna RAM untuk memanggil operasi API atau melakukan O&M rutin.
        // Kami sangat menyarankan agar Anda tidak menyematkan ID AccessKey dan rahasia AccessKey secara langsung dalam kode proyek Anda. Jika tidak, pasangan AccessKey tersebut dapat bocor, sehingga mengancam keamanan semua sumber daya Anda.
        // Contoh ini menunjukkan cara membaca pasangan AccessKey dari variabel lingkungan untuk mengotentikasi akses API. Sebelum menjalankan kode, konfigurasikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID dan ALIBABA_CLOUD_ACCESS_KEY_SECRET.
        String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
        String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
        client = new DefaultAcsClient(DefaultProfile.getProfile(region, accessKeyId, accessKeySecret));
    }
    /**
     * Catatan:
     * 1. Menerima permintaan dekripsi dan mendapatkan kunci ciphertext serta token pengguna.
     * 2. Memanggil operasi dekripsi KMS untuk mendapatkan kunci plaintext.
     * 3. Mengembalikan kunci plaintext yang telah didekode Base64.
     */
    public class HlsDecryptHandler implements HttpHandler {
        /**
         * Memproses permintaan dekripsi.
         * @param httpExchange
         * @throws IOException
         */
        public void handle(HttpExchange httpExchange) throws IOException {
            String requestMethod = httpExchange.getRequestMethod();
            if ("GET".equalsIgnoreCase(requestMethod)) {
                // Verifikasi validitas token.
                String token = getMtsHlsUriToken(httpExchange);
                boolean validRe = validateToken(token);
                if (!validRe) {
                    return;
                }
                // Dapatkan kunci ciphertext dari URL.
                String ciphertext = getCiphertext(httpExchange);
                if (null == ciphertext)
                    return;
                // Dekripsi kunci dari KMS dan dekode Base64-nya.
                byte[] key = decrypt(ciphertext);
                // Atur header.
                setHeader(httpExchange, key);
                // Kembalikan kunci yang telah didekode Base64.
                OutputStream responseBody = httpExchange.getResponseBody();
                responseBody.write(key);
                responseBody.close();
            }
        }
        private void setHeader(HttpExchange httpExchange, byte[] key) throws IOException {
            Headers responseHeaders = httpExchange.getResponseHeaders();
            responseHeaders.set("Access-Control-Allow-Origin", "*");
            httpExchange.sendResponseHeaders(HttpURLConnection.HTTP_OK, key.length);
        }
        /**
         * Memanggil operasi dekripsi KMS untuk mendekripsi kunci dan mendekode Base64 plaintext.
         * @param ciphertext
         * @return
         */
        private byte[] decrypt(String ciphertext) {
            DecryptKMSDataKeyRequest request = new DecryptKMSDataKeyRequest();
            request.setCipherText(ciphertext);
            request.setProtocol(ProtocolType.HTTPS);
            try {
                DecryptKMSDataKeyResponse response = client.getAcsResponse(request);
                String plaintext = response.getPlaintext();
                System.out.println("PlainText: " + plaintext);
                // Catatan: plaintext harus didekode Base64.
                return Base64.decodeBase64(plaintext);
            } catch (ClientException e) {
                e.printStackTrace();
                return null;
            }
        }
        /**
         * Mendapatkan parameter kunci ciphertext dari URL.
         * @param httpExchange
         * @return
         */
        private String getCiphertext(HttpExchange httpExchange) {
            URI uri = httpExchange.getRequestURI();
            String queryString = uri.getQuery();
            String pattern = "CipherText=(\\w*)";
            Pattern r = Pattern.compile(pattern);
            Matcher m = r.matcher(queryString);
            if (m.find())
                return m.group(1);
            else {
                System.out.println("Parameter CipherText Tidak Ditemukan");
                return null;
            }
        }
        
          /**
         * Memverifikasi validitas token. Ini diperlukan untuk Enkripsi dan penulisan ulang M3U8.
         * @param token
         * @return
         */
        private boolean validateToken(String token) {
            if (null == token || "".equals(token)) {
                return false;
            }
            //TODO: Implementasikan verifikasi validitas token.
            return true;
        }
        /**
         * Mendapatkan parameter token. Ini diperlukan untuk Enkripsi dan penulisan ulang M3U8.
         *
         * @param httpExchange
         * @return
         */
        private String getMtsHlsUriToken(HttpExchange httpExchange) {
            URI uri = httpExchange.getRequestURI();
            String queryString = uri.getQuery();
            String pattern = "MtsHlsUriToken=(\\w*)";
            Pattern r = Pattern.compile(pattern);
            Matcher m = r.matcher(queryString);
            if (m.find())
                return m.group(1);
            else {
                System.out.println("Parameter MtsHlsUriToken Tidak Ditemukan");
                return null;
            }
        }
    }
    /**
     * Menjalankan layanan.
     *
     * @throws IOException
     */
    private void serviceBootStrap() throws IOException {
        HttpServerProvider provider = HttpServerProvider.provider();
        // Anda dapat menyesuaikan port pendengar. Dapat menerima hingga 30 permintaan secara bersamaan.
        HttpServer httpserver = provider.createHttpServer(new InetSocketAddress(8099), 30);
        httpserver.createContext("/", new HlsDecryptHandler());
        httpserver.start();
        System.out.println("server dekripsi hls dimulai");
    }
    public static void main(String[] args) throws IOException {
        HlsDecryptServer server = new HlsDecryptServer();
        server.serviceBootStrap();
    }}

Proses

• Pemutar mengurai tag EXT-X-KEY dalam file M3U8 untuk mendapatkan URI kunci dekripsi. URI ini sesuai dengan nilai parameter DecryptKeyUri dalam EncryptConfig.

• Untuk mencegah akses tidak sah, pemutar harus menyertakan informasi otentikasi, yang diteruskan menggunakan parameter MtsHlsUriToken, saat meminta API dekripsi.

• Pemutar secara otomatis meminta API dekripsi untuk mendapatkan kunci, mendekripsi file TS terenkripsi, lalu memulai pemutaran.

Contoh

• URL pemutaran video adalah https://demo.aliyundoc.com/encrypt-stream****-hd.m3u8. Permintaan harus menyertakan parameter MtsHlsUriToken.

• URL permintaan akhir adalah https://demo.aliyundoc.com/encrypt-stream****-hd.m3u8?MtsHlsUriToken=<token>.

• Alamat dekripsi adalah https://demo.aliyundoc.com?CipherText=ZjJmZGViNzUtZWY1Mi00Y2RlLTk3MTMtOT****.

• URL permintaan dekripsi akhir adalah https://demo.aliyundoc.com?CipherText=ZjJmZGViNzUtZWY1Mi00Y2RlLTk3MTMtOT****&MtsHlsUriToken=<issued_token>.

Parameter berikut dalam kode contoh Java harus diubah sesuai kebutuhan Anda:

import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.http.ProtocolType;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.vod.model.v20170321.DecryptKMSDataKeyRequest;
import com.aliyuncs.vod.model.v20170321.DecryptKMSDataKeyResponse;
import com.sun.net.httpserver.Headers;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import com.sun.net.httpserver.HttpServer;
import com.sun.net.httpserver.spi.HttpServerProvider;
import org.apache.commons.codec.binary.Base64;

import java.io.IOException;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.InetSocketAddress;
import java.net.URI;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

public class HlsDecryptServerNoToken {

    private static DefaultAcsClient client;
    static {
        // Wilayah KMS. Harus sama dengan wilayah tempat video disimpan.
        String region = "cn-beijing";
        // Pasangan AccessKey yang digunakan untuk mengakses KMS.
        // Pasangan AccessKey akun Alibaba Cloud memiliki izin untuk memanggil semua operasi API. Kami menyarankan Anda menggunakan pasangan AccessKey pengguna RAM untuk memanggil operasi API atau melakukan O&M rutin.
        // Kami sangat menyarankan agar Anda tidak menyematkan ID AccessKey dan rahasia AccessKey secara langsung dalam kode proyek Anda. Jika tidak, pasangan AccessKey tersebut dapat bocor, sehingga mengancam keamanan semua sumber daya Anda.
        // Contoh ini menunjukkan cara membaca pasangan AccessKey dari variabel lingkungan untuk mengotentikasi akses API. Sebelum menjalankan kode, konfigurasikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID dan ALIBABA_CLOUD_ACCESS_KEY_SECRET.
        String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
        String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
        client = new DefaultAcsClient(DefaultProfile.getProfile(region, accessKeyId, accessKeySecret));
    }
    /**
     * Catatan:
     * 1. Menerima permintaan dekripsi dan mendapatkan kunci ciphertext dan token.
     * 2. Memanggil operasi dekripsi KMS untuk mendapatkan kunci plaintext.
     * 3. Mengembalikan kunci plaintext yang telah didekode Base64.
     */
    public class HlsDecryptHandler implements HttpHandler {
        /**
         * Memproses permintaan dekripsi.
         * @param httpExchange
         * @throws IOException
         */
        public void handle(HttpExchange httpExchange) throws IOException {
            String requestMethod = httpExchange.getRequestMethod();
            if ("GET".equalsIgnoreCase(requestMethod)) {

                // Dapatkan kunci ciphertext dari URL.
                String ciphertext = getCiphertext(httpExchange);
                System.out.println(ciphertext);
                if (null == ciphertext)
                    return;
                // Dekripsi kunci dari KMS dan dekode Base64-nya.
                byte[] key = decrypt(ciphertext);
                // Atur header.
                setHeader(httpExchange, key);
                // Kembalikan kunci yang telah didekode Base64.
                OutputStream responseBody = httpExchange.getResponseBody();
                responseBody.write(key);
                responseBody.close();
            }
        }
        private void setHeader(HttpExchange httpExchange, byte[] key) throws IOException {
            Headers responseHeaders = httpExchange.getResponseHeaders();
            responseHeaders.set("Access-Control-Allow-Origin", "*");
            httpExchange.sendResponseHeaders(HttpURLConnection.HTTP_OK, key.length);
        }
        /**
         * Memanggil operasi dekripsi KMS untuk mendekripsi kunci dan mendekode plaintext-nya dengan Base64.
         * @param ciphertext
         * @return
         */
        private byte[] decrypt(String ciphertext) {

            DecryptKMSDataKeyRequest request = new DecryptKMSDataKeyRequest();
            request.setCipherText(ciphertext);
            request.setProtocol(ProtocolType.HTTPS);
            try {
                DecryptKMSDataKeyResponse response = client.getAcsResponse(request);
                String plaintext = response.getPlaintext();
                System.out.println("PlainText: " + plaintext);
                // Catatan: plaintext harus didekode Base64.
                return Base64.decodeBase64(plaintext);
            } catch (ClientException e) {
                e.printStackTrace();
                return null;
            }
        }

        /**
         * Mendapatkan parameter kunci ciphertext dari URL.
         * @param httpExchange
         * @return
         */
        private String getCiphertext(HttpExchange httpExchange) {
            URI uri = httpExchange.getRequestURI();
            String queryString = uri.getQuery();
            String pattern = "CipherText=(\\w*)";
            Pattern r = Pattern.compile(pattern);
            Matcher m = r.matcher(queryString);
            if (m.find())
                return m.group(1);
            else {
                System.out.println("Parameter CipherText Tidak Ditemukan");
                return null;
            }
        }
    }

    /**
     * Menjalankan layanan.
     *
     * @throws IOException
     */
    private void serviceBootStrap() throws IOException {
        HttpServerProvider provider = HttpServerProvider.provider();
        // Anda dapat menyesuaikan port pendengar. Dapat menerima hingga 30 permintaan secara bersamaan.
        HttpServer httpserver = provider.createHttpServer(new InetSocketAddress(8099), 30);
        httpserver.createContext("/", new HlsDecryptHandler());
        httpserver.start();
        System.out.println("server dekripsi hls dimulai");
    }
    public static void main(String[] args) throws IOException {
        HlsDecryptServerNoToken server = new HlsDecryptServerNoToken();
        server.serviceBootStrap();
    }}

Proses

• Pemutar mengurai tag EXT-X-KEY dalam file M3U8 untuk mendapatkan URI kunci dekripsi. URI ini sesuai dengan nilai parameter DecryptKeyUri dalam EncryptConfig.

• Pemutar secara otomatis meminta API dekripsi untuk mendapatkan kunci, mendekripsi file TS terenkripsi, lalu memulai pemutaran.

Contoh

• URL pemutaran video adalah https://demo.aliyundoc.com/encrypt-stream****-hd.m3u8.

• URL permintaan akhir adalah https://demo.aliyundoc.com/encrypt-stream****-hd.m3u8.

• Alamat dekripsi adalah https://demo.aliyundoc.com?CipherText=ZjJmZGViNzUtZWY1Mi00Y2RlLTk3MTMtOT****.

• URL permintaan dekripsi akhir adalah https://demo.aliyundoc.com?CipherText=ZjJmZGViNzUtZWY1Mi00Y2RlLTk3MTMtOT****.