生成推流地址和播放地址

import java.math.BigInteger;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

public class AuthDemo {
    private static String md5Sum(String src) {
        MessageDigest md5 = null;
        try {
            md5 = MessageDigest.getInstance("MD5");
        } catch (NoSuchAlgorithmException e) {
            e.printStackTrace();
        }
        md5.update(StandardCharsets.UTF_8.encode(src));
        return String.format("%032x", new BigInteger(1, md5.digest()));
    }

private static String aAuth(String uri, String key, long exp) {
    String pattern = "^(rtmp://)?([^/?]+)(/[^?]*)?(\\\\?.*)?$";
    Pattern r = Pattern.compile(pattern);
    Matcher m = r.matcher(uri);
    String scheme = "", host = "", path = "", args = "";
    if (m.find()) {
        scheme = m.group(1) == null ? "rtmp://" : m.group(1);
        host = m.group(2) == null ? "" : m.group(2);
        path = m.group(3) == null ? "/" : m.group(3);
        args = m.group(4) == null ? "" : m.group(4);
    } else {
        System.out.println("NO MATCH");
    }

    String rand = "0";  // "0" by default, other value is ok
    String uid = "0";   // "0" by default, other value is ok
    String sString = String.format("%s-%s-%s-%s-%s", path, exp, rand, uid, key);
    String hashValue = md5Sum(sString);
    String authKey = String.format("%s-%s-%s-%s", exp, rand, uid, hashValue);
    if (args.isEmpty()) {
        return String.format("%s%s%s%s?auth_key=%s", scheme, host, path, args, authKey);
    } else {
        return String.format("%s%s%s%s&auth_key=%s", scheme, host, path, args, authKey);
    }
}

public static void main(String[] args) {
    // 待加密的推/播流地址，example.aliyundoc.com为推/播流域名，liveApp为AppName，liveStream为StreamName
    // 推流和播流URL采用同样的加密方法
    // AppName或StreamName不超过256字符，支持数字、大小写字母、短划线（-）、下划线（_）、等号（=）。
    String uri = "rtmp://example.aliyundoc.com/liveApp/liveStream";  
    // 鉴权Key，推流地址使用推流域名URL鉴权Key，播流地址使用播流域名URL鉴权Key
    String key = "<input private key>";                       
    // exp值为UNIX时间戳，单位秒，最终失效时间由该值加上域名URL鉴权有效时长决定
    // 比如您在此处设置exp为：当前时间+3600秒，那最终失效时间为：当前时间+3600秒+域名URL鉴权有效时长。如果设置exp为：当前时间，那最终失效时间为：当前时间+域名URL鉴权有效时长
    long exp = System.currentTimeMillis() / 1000 + 1 * 3600;  
    String authUri = aAuth(uri, key, exp);                    
    System.out.printf("URL : %s\nAuth: %s", uri, authUri);
}
}

import re
import time
import hashlib
import datetime
def md5sum(src):
    m = hashlib.md5()
    m.update(src)
    return m.hexdigest()
def a_auth(uri, key, exp):
    p = re.compile("^(rtmp://)?([^/?]+)(/[^?]*)?(\\?.*)?$")
    if not p:
        return None
    m = p.match(uri)
    scheme, host, path, args = m.groups()
    if not scheme: scheme = "rtmp://"
    if not path: path = "/"
    if not args: args = ""
    rand = "0"      # "0" by default, other value is ok
    uid = "0"       # "0" by default, other value is ok
    sstring = "%s-%s-%s-%s-%s" %(path, exp, rand, uid, key)
    hashvalue = md5sum(sstring.encode('utf-8'))
    auth_key = "%s-%s-%s-%s" %(exp, rand, uid, hashvalue)
    if args:
        return "%s%s%s%s&auth_key=%s" %(scheme, host, path, args, auth_key)
    else:
        return "%s%s%s%s?auth_key=%s" %(scheme, host, path, args, auth_key)
def main():
    # 待加密的推/播流地址，example.aliyundoc.com为推/播流域名，liveApp为AppName，liveStream为StreamName
    # 推流和播流URL采用同样的加密方法
    # AppName或StreamName不超过256字符，支持数字、大小写字母、短划线（-）、下划线（_）、等号（=）。
    uri = "rtmp://example.aliyundoc.com/liveApp/liveStream"  
    # 鉴权Key，推流地址使用推流域名URL鉴权Key，播流地址使用播流域名URL鉴权Key
    key = "<input private key>"                         
    # exp值为UNIX时间戳，单位秒，最终失效时间由该值加上域名URL鉴权有效时长决定
    # 比如您在此处设置exp为：当前时间+3600秒，那最终失效时间为：当前时间+3600秒+域名URL鉴权有效时长。如果设置exp为：当前时间，那最终失效时间为：当前时间+域名URL鉴权有效时长
    exp = int(time.time()) + 1 * 3600                   
    authuri = a_auth(uri, key, exp)                     
    print("URL : %s\nAUTH: %s" %(uri, authuri))
if __name__ == "__main__":
    main()

package main
import (
    "crypto/md5"
    "encoding/hex"
    "fmt"
    "regexp"
    "time"
)

func md5sum(src string) string {
    h := md5.New()
    h.Write([]byte(src))
    return hex.EncodeToString(h.Sum(nil))
}

func a_auth(uri, key string, exp int64) string {
    p, err := regexp.Compile("^(rtmp://)?([^/?]+)(/[^?]*)?(\\?.*)?$")
    if err != nil {
        fmt.Println(err)
        return ""
    }
    m := p.FindStringSubmatch(uri)
    var scheme, host, path, args string
    if len(m) == 5 {
        scheme, host, path, args = m[1], m[2], m[3], m[4]
    } else {
        scheme, host, path, args = "rtmp://", "", "/", ""
    }
    rand := "0" // "0" by default, other value is ok
    uid := "0"  // "0" by default, other value is ok
    sstring := fmt.Sprintf("%s-%d-%s-%s-%s", path, exp, rand, uid, key)
    hashvalue := md5sum(sstring)
    auth_key := fmt.Sprintf("%d-%s-%s-%s", exp, rand, uid, hashvalue)
    if len(args) != 0 {
        return fmt.Sprintf("%s%s%s%s&auth_key=%s", scheme, host, path, args, auth_key)
    } else {
        return fmt.Sprintf("%s%s%s%s?auth_key=%s", scheme, host, path, args, auth_key)
    }
}

func main() {
    // 待加密的推/播流地址，example.aliyundoc.com为推/播流域名，liveApp为AppName，liveStream为StreamName
    // 推流和播流URL采用同样的加密方法
    // AppName或StreamName不超过256字符，支持数字、大小写字母、短划线（-）、下划线（_）、等号（=）。
    uri := "rtmp://example.aliyundoc.com/liveApp/liveStream" 
    // 鉴权Key，推流地址使用推流域名URL鉴权Key，播流地址使用播流域名URL鉴权Key
    key := "<input private key>"     
    // exp值为UNIX时间戳，单位秒，最终失效时间由该值加上域名URL鉴权有效时长决定
    // 比如您在此处设置exp为：当前时间+3600秒，那最终失效时间为：当前时间+3600秒+域名URL鉴权有效时长。如果设置exp为：当前时间，那最终失效时间为：当前时间+域名URL鉴权有效时长   
    exp := time.Now().Unix() + 3600                                    
    authuri := a_auth(uri, key, exp)                                       
    fmt.Printf("URL : %s\nAUTH: %s", uri, authuri)
}

<?php
function a_auth($uri, $key, $exp) {
    preg_match("/^(rtmp:\/\/)?([^\/?]+)?(\/[^?]*)?(\\?.*)?$/", $uri, $matches);
    $scheme = $matches[1];
    $host = $matches[2];
    $path = $matches[3];
    $args = $matches[4];
    if  (empty($args)) {
        $args ="";
    }
    if  (empty($scheme)) {
        $scheme ="rtmp://";
    }
    if  (empty($path)) {
        $path ="/";
    }
    $rand = "0";
    // "0" by default, other value is ok
    $uid = "0";
    // "0" by default, other value is ok
    $sstring = sprintf("%s-%u-%s-%s-%s", $path, $exp, $rand, $uid, $key);
    $hashvalue = md5($sstring);
    $auth_key = sprintf("%u-%s-%s-%s", $exp, $rand, $uid, $hashvalue);
    if ($args) {
        return sprintf("%s%s%s%s&auth_key=%s", $scheme, $host, $path, $args, $auth_key);
    } else {
        return sprintf("%s%s%s%s?auth_key=%s", $scheme, $host, $path, $args, $auth_key);
    }
}
// 待加密的推/播流地址，example.aliyundoc.com为推/播流域名，liveApp为AppName，liveStream为StreamName
// 推流和播流URL采用同样的加密方法
// AppName或StreamName不超过256字符，支持数字、大小写字母、短划线（-）、下划线（_）、等号（=）。
$uri = "rtmp://example.aliyundoc.com/liveApp/liveStream";
// 鉴权Key，推流地址使用推流域名URL鉴权Key，播流地址使用播流域名URL鉴权Key
$key = "<input private key>";
// exp值为UNIX时间戳，单位秒，最终失效时间由该值加上域名URL鉴权有效时长决定
// 比如您在此处设置exp为：当前时间+3600秒，那最终失效时间为：当前时间+3600秒+域名URL鉴权有效时长。如果设置exp为：当前时间，那最终失效时间为：当前时间+域名URL鉴权有效时长
$exp = time() + 3600;
$authuri = a_auth($uri, $key, $exp);
echo "URL :" . $uri;
echo PHP_EOL;
echo "AUTH:" . $authuri;
?>

using System;
using System.Text.RegularExpressions;
using System.Security.Cryptography;
using System.Text;
public class Test
{
    public static void Main()
    {
        // 待加密的推/播流地址，example.aliyundoc.com为推/播流域名，liveApp为AppName，liveStream为StreamName
        // 推流和播流URL采用同样的加密方法
        // AppName或StreamName不超过256字符，支持数字、大小写字母、短划线（-）、下划线（_）、等号（=）。
        string uri= "rtmp://example.aliyundoc.com/liveApp/liveStream";  
        // 鉴权Key，推流地址使用推流域名URL鉴权Key，播流地址使用播流域名URL鉴权Key
        string key= "<input private key>";                           
        DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
        // exp值为UNIX时间戳，单位秒，最终失效时间由该值加上域名URL鉴权有效时长决定
        // 比如您在此处设置exp为：当前时间+3600秒，那最终失效时间为：当前时间+3600秒+域名URL鉴权有效时长。如果设置exp为：当前时间，那最终失效时间为：当前时间+域名URL鉴权有效时长
        string exp  = Convert.ToInt64((DateTime.Now - dateStart).TotalSeconds+3600).ToString(); 
        string authUri = aAuth(uri, key, exp);
        Console.WriteLine (String.Format("URL :{0}",uri));
        Console.WriteLine (String.Format("AUTH :{0}",authUri));
    }
    public static string aAuth(string uri, string key, string exp)
    {
        Regex regex = new Regex("^(rtmp://)?([^/?]+)(/[^?]*)?(\\\\?.*)?$");
        Match m = regex.Match(uri);
        string scheme = "rtmp://", host = "", path = "/", args = "";
        if (m.Success)
        {
            scheme=m.Groups[1].Value;
            host=m.Groups[2].Value;
            path=m.Groups[3].Value;
            args=m.Groups[4].Value;
        }else{
            Console.WriteLine ("NO MATCH");
        }
        string rand = "0";  // "0" by default, other value is ok
        string uid = "0";   // "0" by default, other value is ok
        string u = String.Format("{0}-{1}-{2}-{3}-{4}",  path, exp, rand, uid, key);
        string hashValue  = Md5(u);
        string authKey = String.Format("{0}-{1}-{2}-{3}", exp, rand, uid, hashValue);
        if (args=="")
        {
            return String.Format("{0}{1}{2}{3}?auth_key={4}", scheme, host, path, args, authKey);
        } else
        {
            return String.Format("{0}{1}{2}{3}&auth_key={4}", scheme, host, path, args, authKey);
        }
    }
    public static string Md5(string value)
    {
        MD5CryptoServiceProvider md5 = new MD5CryptoServiceProvider();
        byte[] bytes = Encoding.ASCII.GetBytes(value);
        byte[] encoded = md5.ComputeHash(bytes);
        StringBuilder sb = new StringBuilder();
        for(int i=0; i<encoded.Length; ++i)
        {
            sb.Append(encoded[i].ToString("x2"));
        }
        return sb.ToString();
   }
}