ApsaraVideo VOD：Enkripsi HLS

Tabel berikut menjelaskan parameter dalam kode sampel. Anda dapat memodifikasinya berdasarkan kebutuhan bisnis 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 tempat KMS digunakan. Wilayah tersebut harus sama dengan wilayah tempat video berada.
        String region = "";
        // Pasangan AccessKey yang digunakan untuk mengotorisasi akses ke KMS.
        // Pasangan AccessKey dari akun Alibaba Cloud memiliki izin untuk memanggil semua operasi API. Kami merekomendasikan Anda menggunakan pasangan AccessKey dari pengguna RAM untuk memanggil operasi API atau melakukan pemeliharaan rutin.
        // Kami merekomendasikan Anda untuk tidak mengkode keras pasangan AccessKey (AccessKey ID dan AccessKey secret) di kode proyek Anda. Jika tidak, pasangan AccessKey mungkin bocor dan keamanan semua sumber daya dalam akun Anda mungkin terganggu.
        // Dalam contoh ini, ApsaraVideo VOD membaca pasangan AccessKey dari variabel lingkungan untuk mengimplementasikan verifikasi identitas untuk akses API. Sebelum Anda menjalankan kode sampel, konfigurasikan variabel lingkungan berikut: 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. Terima permintaan dekripsi dan dapatkan EDK dan token.
     * 2. Panggil operasi DecryptKMSDataKey dari KMS untuk mendapatkan DK.
     * 3. Dekode DK menggunakan algoritma Base64 dan kembalikan DK.
     */
    public class HlsDecryptHandler implements HttpHandler {
        /**
         * Proses permintaan dekripsi.
         * @param httpExchange
         * @throws IOException
         */
        public void handle(HttpExchange httpExchange) throws IOException {
            String requestMethod = httpExchange.getRequestMethod();
            if ("GET".equalsIgnoreCase(requestMethod)) {
                // Periksa apakah token valid.
                String token = getMtsHlsUriToken(httpExchange);
                boolean validRe = validateToken(token);
                if (!validRe) {
                    return;
                }
                // Dapatkan EDK dari URL video.
                String ciphertext = getCiphertext(httpExchange);
                if (null == ciphertext)
                    return;
                // Dekode DK yang diperoleh dari KMS menggunakan algoritma Base64 dan kembalikan DK.
                byte[] key = decrypt(ciphertext);
                // Konfigurasikan header.
                setHeader(httpExchange, key);
                // Kembalikan DK yang didekode menggunakan algoritma 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);
        }
        /**
         * Panggil operasi dekripsi KMS untuk mendekripsi DK dan dekode DK menggunakan algoritma 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: Anda harus mendekode DK menggunakan algoritma Base64.
                return Base64.decodeBase64(plaintext);
            } catch (ClientException e) {
                e.printStackTrace();
                return null;
            }
        }
        /**
         * Dapatkan EDK dari URL video.
         * @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("Not Found CipherText Param");
                return null;
            }
        }
        
          /**
         * Periksa validitas token, yang penting untuk enkripsi M3U8 dan penulisan ulang.
         * @param token
         * @return
         */
        private boolean validateToken(String token) {
            if (null == token || "".equals(token)) {
                return false;
            }
            // TODO. Anda dapat menyesuaikan logika untuk memeriksa apakah token valid.
            return true;
        }
        /**
         * Dapatkan parameter Token, yang penting untuk enkripsi M3U8 dan penulisan ulang.
         *
         * @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("Not Found MtsHlsUriToken Param");
                return null;
            }
        }
    }
    /**
     * Mulai layanan.
     *
     * @throws IOException
     */
    private void serviceBootStrap() throws IOException {
        HttpServerProvider provider = HttpServerProvider.provider();
        // Anda dapat menentukan port kustom untuk mendengarkan. Server web dapat menangani maksimal 30 permintaan secara bersamaan pada port yang sama.
        HttpServer httpserver = provider.createHttpServer(new InetSocketAddress(8099), 30);
        httpserver.createContext("/", new HlsDecryptHandler());
        httpserver.start();
        System.out.println("hls decrypt server started");
    }
    public static void main(String[] args) throws IOException {
        HlsDecryptServer server = new HlsDecryptServer();
        server.serviceBootStrap();
    }}

Proses

• Pemain mengurai tag EXT-X-KEY di file playlist M3U8 untuk mendapatkan URI kunci dekripsi, yang sesuai dengan nilai DecryptKeyUri di EncryptConfig.

• Untuk membatasi akses tidak sah, pemain harus menyertakan informasi autentikasi (diteruskan melalui parameter MtsHlsUriToken) saat meminta operasi dekripsi.

• Pemain secara otomatis memanggil operasi DecryptKMSDataKey untuk mendapatkan DK, mendekripsi file TS yang terenkripsi, dan kemudian melanjutkan dengan pemutaran normal.

Contoh

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

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

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

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

Tabel berikut menjelaskan parameter dalam kode sampel. Anda dapat memodifikasinya berdasarkan kebutuhan bisnis 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 tempat KMS digunakan. Wilayah tersebut harus sama dengan wilayah tempat video berada.
        String region = "cn-beijing";
        // Pasangan AccessKey yang digunakan untuk mengotorisasi akses ke KMS.
        // Pasangan AccessKey dari akun Alibaba Cloud memiliki izin untuk memanggil semua operasi API. Kami merekomendasikan Anda menggunakan pasangan AccessKey dari pengguna RAM untuk memanggil operasi API atau melakukan pemeliharaan rutin.
        // Kami merekomendasikan Anda untuk tidak mengkode keras pasangan AccessKey (AccessKey ID dan AccessKey secret) di kode proyek Anda. Jika tidak, pasangan AccessKey mungkin bocor dan keamanan semua sumber daya dalam akun Anda mungkin terganggu.
        // Dalam contoh ini, ApsaraVideo VOD membaca pasangan AccessKey dari variabel lingkungan untuk mengimplementasikan verifikasi identitas untuk akses API. Sebelum Anda menjalankan kode sampel, konfigurasikan variabel lingkungan berikut: 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. Terima permintaan dekripsi dan dapatkan EDK dan token.
     * 2. Panggil operasi DecryptKMSDataKey dari KMS untuk mendapatkan DK.
     * 3. Dekode DK menggunakan algoritma Base64.
     */
    public class HlsDecryptHandler implements HttpHandler {
        /**
         * Proses permintaan dekripsi.
         * @param httpExchange
         * @throws IOException
         */
        public void handle(HttpExchange httpExchange) throws IOException {
            String requestMethod = httpExchange.getRequestMethod();
            if ("GET".equalsIgnoreCase(requestMethod)) {

                // Dapatkan EDK dari URL video.
                String ciphertext = getCiphertext(httpExchange);
                System.out.println(ciphertext);
                if (null == ciphertext)
                    return;
                // Dekode DK yang diperoleh dari KMS menggunakan algoritma Base64 dan kembalikan DK.
                byte[] key = decrypt(ciphertext);
                // Konfigurasikan header.
                setHeader(httpExchange, key);
                // Kembalikan DK yang didekode menggunakan algoritma 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);
        }
        /**
         * Panggil operasi dekripsi KMS untuk mendekripsi DK dan dekode DK menggunakan algoritma 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: Anda harus mendekode DK menggunakan algoritma Base64.
                return Base64.decodeBase64(plaintext);
            } catch (ClientException e) {
                e.printStackTrace();
                return null;
            }
        }

        /**
         * Dapatkan EDK dari URL video.
         * @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("Not Found CipherText Param");
                return null;
            }
        }
    }

    /**
     * Mulai layanan.
     *
     * @throws IOException
     */
    private void serviceBootStrap() throws IOException {
        HttpServerProvider provider = HttpServerProvider.provider();
        // Anda dapat menentukan port kustom untuk mendengarkan. Server web dapat menangani maksimal 30 permintaan secara bersamaan pada port yang sama.
        HttpServer httpserver = provider.createHttpServer(new InetSocketAddress(8099), 30);
        httpserver.createContext("/", new HlsDecryptHandler());
        httpserver.start();
        System.out.println("hls decrypt server started");
    }
    public static void main(String[] args) throws IOException {
        HlsDecryptServerNoToken server = new HlsDecryptServerNoToken();
        server.serviceBootStrap();
    }}

Proses

• Pemain mengurai tag EXT-X-KEY di file M3U8 untuk mendapatkan URI kunci dekripsi, yang sesuai dengan nilai DecryptKeyUri di EncryptConfig.

• Pemain secara otomatis memanggil operasi DecryptKMSDataKey untuk mendapatkan DK, mendekripsi file TS yang terenkripsi, dan kemudian melanjutkan dengan pemutaran normal.

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.

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

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