ApsaraVideo VOD:HLS 暗号化

次の表に、サンプルコードでカスタマイズできるパラメーターを示します。

パラメーター	説明
region	リージョン ID。KMS サービスのリージョンは、ApsaraVideo VOD の動画が保存されているリージョンと同じである必要があります。たとえば、中国 (上海) の場合は、このパラメーターを cn-shanghai に設定します。その他のリージョン ID については、「ApsaraVideo VOD リージョン ID」をご参照ください。
AccessKey	Alibaba Cloud アカウントまたは RAM ユーザーのアクセスキーペア (AccessKey ID および AccessKey Secret) です。詳細については、「アクセスキーペアの作成」をご参照ください。
httpserver	サービスを開始するポート番号。

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 {
        // KMS リージョン。動画のリージョンと同じである必要があります。
        String region = "";
        // KMS にアクセスするためのアクセスキーペア。
        // Alibaba Cloud アカウントのアクセスキーペアは、すべての API 操作に対する権限を持っています。API 操作の呼び出しや日常の O&M の実行には、RAM ユーザーを使用することを推奨します。
        // AccessKey ID と AccessKey Secret をプロジェクトコードにハードコーディングしないことを強く推奨します。ハードコーディングすると、アクセスキーペアが漏洩し、アカウント内のすべてのリソースのセキュリティが侵害されるおそれがあります。
        // この例では、環境変数からアクセスキーペアを読み取って API リクエストを認証する方法を示します。サンプルコードを実行する前に、ALIBABA_CLOUD_ACCESS_KEY_ID と 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));
    }
    /**
     * 説明
     * 1. 復号リクエストを受信して、暗号文とユーザートークンを取得します。
     * 2. KMS の復号 API を呼び出して、プレーンテキストキーを取得します。
     * 3. Base64 デコードされたプレーンテキストキーを返します。
     */
    public class HlsDecryptHandler implements HttpHandler {
        /**
         * 復号リクエストを処理します。
         * @param httpExchange
         * @throws IOException
         */
        public void handle(HttpExchange httpExchange) throws IOException {
            String requestMethod = httpExchange.getRequestMethod();
            if ("GET".equalsIgnoreCase(requestMethod)) {
                // トークンの有効性を検証します。
                String token = getMtsHlsUriToken(httpExchange);
                boolean validRe = validateToken(token);
                if (!validRe) {
                    return;
                }
                // URL から暗号文を取得します。
                String ciphertext = getCiphertext(httpExchange);
                if (null == ciphertext)
                    return;
                // KMS からキーを復号し、Base64 デコードを実行します。
                byte[] key = decrypt(ciphertext);
                // ヘッダーを設定します。
                setHeader(httpExchange, key);
                // 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);
        }
        /**
         * KMS の復号 API を呼び出し、プレーンテキストを 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);
                // 注：Base64 デコードが必要です。
                return Base64.decodeBase64(plaintext);
            } catch (ClientException e) {
                e.printStackTrace();
                return null;
            }
        }
        /**
         * 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("Not Found CipherText Param");
                return null;
            }
        }
          /**
         * トークンの有効性を検証します。これは M3U8 の暗号化と書き換えに必要です。
         * @param token
         * @return
         */
        private boolean validateToken(String token) {
            if (null == token || "".equals(token)) {
                return false;
            }
            //TODO: ここにトークン検証ロジックを実装します。
            return true;
        }
        /**
         * トークンパラメーターを取得します。これは 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("Not Found MtsHlsUriToken Param");
                return null;
            }
        }
    }
    /**
     * サービスを開始します。
     *
     * @throws IOException
     */
    private void serviceBootStrap() throws IOException {
        HttpServerProvider provider = HttpServerProvider.provider();
        // リッスンポートはカスタマイズ可能です。サーバーは最大 30 の同時リクエストを受け付けます。
        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();
    }}

ワークフロー

• プレーヤーは、M3U8 ファイルの EXT-X-KEY タグを解析して、復号キー URI を取得します。この URI は、EncryptConfig の DecryptKeyUri パラメーターの値に対応します。

• 不正アクセスを制限するために、プレーヤーは復号エンドポイントへのリクエストに認証情報 (MtsHlsUriToken パラメーターで渡される) を含める必要があります。

• プレーヤーは、復号エンドポイントに自動的にリクエストしてキーを取得し、TS ファイルを復号してから動画を再生します。

例

• 再生 URL が https://demo.aliyundoc.com/encrypt-stream****-hd.m3u8 の場合、リクエストには MtsHlsUriToken パラメーターを含める必要があります。

• 最終的なリクエスト URL： https://demo.aliyundoc.com/encrypt-stream****-hd.m3u8?MtsHlsUriToken=<token>

• 復号 URL： https://demo.aliyundoc.com?CipherText=ZjJmZGViNzUtZWY1Mi00Y2RlLTk3MTMtOT****

• 最終的な復号リクエスト URL： https://demo.aliyundoc.com?CipherText=ZjJmZGViNzUtZWY1Mi00Y2RlLTk3MTMtOT****&MtsHlsUriToken=<token>

次の表に、サンプルコードでカスタマイズできるパラメーターを示します。

パラメーター	説明
region	リージョン ID。KMS サービスのリージョンは、ApsaraVideo VOD の動画が保存されているリージョンと同じである必要があります。たとえば、中国 (上海) の場合は、このパラメーターを cn-shanghai に設定します。その他のリージョン ID については、「ApsaraVideo VOD リージョン ID」をご参照ください。
AccessKey	Alibaba Cloud アカウントまたは RAM ユーザーのアクセスキーペア (AccessKey ID および AccessKey Secret) です。詳細については、「アクセスキーペアの作成」をご参照ください。
httpserver	サービスを開始するポート番号。

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 {
        // KMS リージョン。動画のリージョンと同じである必要があります。
        String region = "cn-shanghai";
        // KMS にアクセスするためのアクセスキーペア。
        // Alibaba Cloud アカウントのアクセスキーペアは、すべての API 操作に対する権限を持っています。API 操作の呼び出しや日常の O&M の実行には、RAM ユーザーを使用することを推奨します。
        // AccessKey ID と AccessKey Secret をプロジェクトコードにハードコーディングしないことを強く推奨します。ハードコーディングすると、アクセスキーペアが漏洩し、アカウント内のすべてのリソースのセキュリティが侵害されるおそれがあります。
        // この例では、環境変数からアクセスキーペアを読み取って API リクエストを認証する方法を示します。サンプルコードを実行する前に、ALIBABA_CLOUD_ACCESS_KEY_ID と 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));
    }
    /**
     * 説明
     * 1. 復号リクエストを受信して、暗号文を取得します。
     * 2. KMS の復号 API を呼び出して、プレーンテキストキーを取得します。
     * 3. Base64 デコードされたプレーンテキストキーを返します。
     */
    public class HlsDecryptHandler implements HttpHandler {
        /**
         * 復号リクエストを処理します。
         * @param httpExchange
         * @throws IOException
         */
        public void handle(HttpExchange httpExchange) throws IOException {
            String requestMethod = httpExchange.getRequestMethod();
            if ("GET".equalsIgnoreCase(requestMethod)) {
                // URL から暗号文を取得します。
                String ciphertext = getCiphertext(httpExchange);
                System.out.println(ciphertext);
                if (null == ciphertext)
                    return;
                // KMS からキーを復号し、Base64 デコードを実行します。
                byte[] key = decrypt(ciphertext);
                // ヘッダーを設定します。
                setHeader(httpExchange, key);
                // 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);
        }
        /**
         * KMS の復号 API を呼び出し、プレーンテキストを 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);
                // 注：Base64 デコードが必要です。
                return Base64.decodeBase64(plaintext);
            } catch (ClientException e) {
                e.printStackTrace();
                return null;
            }
        }
        /**
         * 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("Not Found CipherText Param");
                return null;
            }
        }
    }
    /**
     * サービスを開始します。
     *
     * @throws IOException
     */
    private void serviceBootStrap() throws IOException {
        HttpServerProvider provider = HttpServerProvider.provider();
        // リッスンポートはカスタマイズ可能です。サーバーは最大 30 の同時リクエストを受け付けます。
        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();
    }}

ワークフロー

• プレーヤーは、M3U8 ファイルの EXT-X-KEY タグを解析して復号キー URI を取得します。この URI は、EncryptConfig の DecryptKeyUri パラメーターの値に対応します。

• プレーヤーは、復号エンドポイントに自動的にリクエストしてキーを取得し、TS ファイルを復号してから動画を再生します。

例

• 再生 URL： https://demo.aliyundoc.com/encrypt-stream****-hd.m3u8

• 最終的なリクエスト URL： https://demo.aliyundoc.com/encrypt-stream****-hd.m3u8

• 復号 URL： https://demo.aliyundoc.com?CipherText=ZjJmZGViNzUtZWY1Mi00Y2RlLTk3MTMtOT****

• 最終的な復号リクエスト URL： https://demo.aliyundoc.com?CipherText=ZjJmZGViNzUtZWY1Mi00Y2RlLTk3MTMtOT****