本文为您介绍URL鉴权的代码示例(Python、Java、Go和PHP)，您可以根据业务需要，方便的对URL进行鉴权处理。

URL鉴权规则请参见

说明 代码示例中的key参数对应控制台中URL鉴权的主KEY或备KEY。可在在直播控制台的域名管理>直播管理>访问控制>URL鉴权页面中的鉴权URL设置模块中配置或查看。

Python代码示例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():

uri = "rtmp://video-center.alivecdn.com/test/test?vhost=xc.cdnpe.com" # original uri

key = "" # private key of authorization

exp = int(time.time()) + 1 * 3600 # expiration time: 1 hour after current itme

authuri = a_auth(uri, key, exp) # auth type:

print("URL : %s\nAUTH: %s" %(uri, authuri))

if __name__ == "__main__":

main()

Java代码示例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) {

String uri = "rtmp://play.example.com/live/test"; // original uri

String key = ""; // private key of authorization

long exp = System.currentTimeMillis() / 1000 + 1 * 3600; // expiration time: 1 hour after current time

String authUri = aAuth(uri, key, exp); // auth type:

System.out.printf("URL : %s\nAuth: %s", uri, authUri);

}

}

Go代码示例package mainimport (

"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() {

uri := "rtmp://play.example.com/live/test" // original uri

key := "" // private key of authorization

exp := time.Now().Unix() + 3600 // expiration time: 1 hour after current itme

authuri := a_auth(uri, key, exp) // auth type:

fmt.Printf("URL : %s\nAUTH: %s", uri, authuri)

}

PHP代码示例<?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);

}

}

$uri = "rtmp://play.example.com/live/test";

$key = "";

$exp = time() + 3600;

$authuri = a_auth($uri, $key, $exp);

echo "URL :" . $uri;

echo PHP_EOL;

echo "AUTH:" . $authuri;

?>