ApsaraVideo VOD:Enkripsi HLS

Tabel berikut menjelaskan parameter dalam kode contoh yang dapat Anda sesuaikan.

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, yang harus sama dengan wilayah video.
        String region = "";
        // Pasangan AccessKey untuk mengakses KMS.
        // Pasangan AccessKey akun Alibaba Cloud memiliki izin untuk semua operasi API. Kami menyarankan Anda menggunakan 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. Melakukannya dapat menyebabkan kebocoran pasangan AccessKey dan mengompromikan keamanan semua sumber daya di akun Anda.
        // Contoh ini menunjukkan cara mengautentikasi permintaan API dengan membaca pasangan AccessKey dari variabel lingkungan. Sebelum menjalankan kode contoh, 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));
    }
    /**
     * Deskripsi:
     * 1. Menerima permintaan dekripsi untuk mendapatkan ciphertext dan token pengguna.
     * 2. Memanggil operasi dekripsi KMS untuk mendapatkan kunci plaintext.
     * 3. Mengembalikan kunci plaintext hasil decoding Base64.
     */
    public class HlsDecryptHandler implements HttpHandler {
        /**
         * Menangani 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 ciphertext dari URL.
                String ciphertext = getCiphertext(httpExchange);
                if (null == ciphertext)
                    return;
                // Dekripsi kunci dari KMS dan lakukan decoding Base64.
                byte[] key = decrypt(ciphertext);
                // Atur header.
                setHeader(httpExchange, key);
                // Kembalikan kunci hasil decoding 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 dan melakukan decoding Base64 pada 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: Diperlukan decoding Base64.
                return Base64.decodeBase64(plaintext);
            } catch (ClientException e) {
                e.printStackTrace();
                return null;
            }
        }
        /**
         * Mendapatkan parameter 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 logika validasi token Anda di sini.
            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();
        // Port pendengar dapat disesuaikan. Server dapat menerima hingga 30 permintaan konkuren.
        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();
    }}

Alur kerja

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

• Untuk membatasi akses tidak sah, pemutar harus menyertakan informasi autentikasi (dilewatkan dalam parameter MtsHlsUriToken) dalam permintaan ke titik akhir dekripsi.

• Pemutar secara otomatis meminta titik akhir dekripsi untuk mendapatkan kunci, mendekripsi file TS, lalu memutar video.

Contoh

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

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

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

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

Tabel berikut menjelaskan parameter dalam kode contoh yang dapat Anda sesuaikan.

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, yang harus sama dengan wilayah video.
        String region = "cn-beijing";
        // Pasangan AccessKey untuk mengakses KMS.
        // Pasangan AccessKey akun Alibaba Cloud memiliki izin untuk semua operasi API. Kami menyarankan Anda menggunakan 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. Melakukannya dapat menyebabkan kebocoran pasangan AccessKey dan mengompromikan keamanan semua sumber daya di akun Anda.
        // Contoh ini menunjukkan cara mengautentikasi permintaan API dengan membaca pasangan AccessKey dari variabel lingkungan. Sebelum menjalankan kode contoh, 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));
    }
    /**
     * Deskripsi:
     * 1. Menerima permintaan dekripsi untuk mendapatkan ciphertext.
     * 2. Memanggil operasi dekripsi KMS untuk mendapatkan kunci plaintext.
     * 3. Mengembalikan kunci plaintext hasil decoding Base64.
     */
    public class HlsDecryptHandler implements HttpHandler {
        /**
         * Menangani permintaan dekripsi.
         * @param httpExchange
         * @throws IOException
         */
        public void handle(HttpExchange httpExchange) throws IOException {
            String requestMethod = httpExchange.getRequestMethod();
            if ("GET".equalsIgnoreCase(requestMethod)) {
                // Dapatkan ciphertext dari URL.
                String ciphertext = getCiphertext(httpExchange);
                System.out.println(ciphertext);
                if (null == ciphertext)
                    return;
                // Dekripsi kunci dari KMS dan lakukan decoding Base64.
                byte[] key = decrypt(ciphertext);
                // Atur header.
                setHeader(httpExchange, key);
                // Kembalikan kunci hasil decoding 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 dan melakukan decoding Base64 pada 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: Diperlukan decoding Base64.
                return Base64.decodeBase64(plaintext);
            } catch (ClientException e) {
                e.printStackTrace();
                return null;
            }
        }
        /**
         * Mendapatkan parameter 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();
        // Port pendengar dapat disesuaikan. Server dapat menerima hingga 30 permintaan konkuren.
        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();
    }}

Alur kerja

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

• Pemutar secara otomatis meminta titik akhir dekripsi untuk mendapatkan kunci, mendekripsi file TS, lalu memutar video.

Contoh

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

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

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

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