阿里云直播服务 sdk demo php

时间：2022-05-27 22:11:22
[php]
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: Administrator
  5. * Date: 2016/12/8 0008
  6. * Time: 11:05
  7. */
  8. class Aliyun{
  9. private $accessKeyId = "";          //密钥ID
  10. private $accessKeySecret = "";      //密钥
  11. public  $version = "2014-11-11";    //API版本号
  12. public  $format = "JSON";           //返回值类型
  13. private $domainParameters = "";
  14. public  $video_host='';                //推流域名
  15. public  $appName="test";            //应用名
  16. public  $privateKey="";             //鉴权
  17. public  $vhost="";                  //加速域名
  18. public  $msg;
  19. /**
  20. * 访问阿ali接口进行请求并返回ali返回值
  21. * @param array $apiParams 接口自定义参数
  22. * @param string $credential 传值方式默认get
  23. * @param string $domain 请求地址
  24. */
  25. public function aliApi($apiParams,$credential="GET", $domain="cdn.aliyuncs.com")
  26. {
  27. date_default_timezone_set("GMT");
  28. $apiParams['Format'] = $this->format;
  29. $apiParams['SignatureMethod'] = "HMAC-SHA1";//签名算法
  30. $apiParams['SignatureNonce'] = rand(100000,999999);//随机数
  31. $apiParams['SignatureVersion'] = '1.0';//签名算法版本
  32. $apiParams['TimeStamp'] =date('Y-m-d\TH:i:s\Z');//请求时间
  33. $apiParams['Version'] = $this->version;
  34. $apiParams["AccessKeyId"]=$this->accessKeyId;
  35. $accessSecret = $this->accessKeySecret;
  36. $apiParams["Signature"] = $this->computeSignature($credential,$apiParams,$accessSecret);
  37. if($credential == "POST") {
  38. $requestUrl = "https://". $domain . "/";
  39. foreach ($apiParams as $apiParamKey => $apiParamValue)
  40. {
  41. $this->putDomainParameters($apiParamKey,$apiParamValue);
  42. }
  43. $url= $requestUrl;
  44. }
  45. else {
  46. $requestUrl = "http://". $domain . "/?";
  47. foreach ($apiParams as $apiParamKey => $apiParamValue)
  48. {
  49. $requestUrl .= "$apiParamKey=" . urlencode($apiParamValue) . "&";
  50. }
  51. $url= substr($requestUrl, 0, -1);
  52. }
  53. $ch = curl_init();
  54. curl_setopt($ch, CURLOPT_URL, $url);
  55. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER,false); //处理http证书问题
  56. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  57. $ret = curl_exec($ch);
  58. if (false === $ret) {
  59. $ret =  curl_errno($ch);
  60. $this->message = 'curl方法出错，错误号：'.$ret;
  61. return false;
  62. }
  63. curl_close($ch);
  64. if( $this->format == "JSON")
  65. return json_decode($ret,true);
  66. elseif($this->format =="XML"){
  67. return $this->xmlToArray($ret);
  68. }else
  69. return $ret;
  70. }
  71. /**
  72. * 计算签名
  73. * @param $credential
  74. * @param $parameters
  75. * @param $accessKeySecret
  76. * @return string
  77. */
  78. private function computeSignature($credential,$parameters, $accessKeySecret)
  79. {
  80. ksort($parameters);
  81. $canonicalizedQueryString = '';
  82. foreach($parameters as $key => $value)
  83. {
  84. $canonicalizedQueryString .= '&' . $this->percentEncode($key). '=' . $this->percentEncode($value);
  85. }
  86. $stringToSign = $credential.'&%2F&' . $this->percentencode(substr($canonicalizedQueryString, 1));
  87. $signature = $this->signString($stringToSign, $accessKeySecret."&");
  88. return $signature;
  89. }
  90. /**
  91. * url编码
  92. * @param $str
  93. * @return mixed|string
  94. */
  95. protected function percentEncode($str)
  96. {
  97. $res = urlencode($str);
  98. $res = preg_replace('/\+/', '%20', $res);
  99. $res = preg_replace('/\*/', '%2A', $res);
  100. $res = preg_replace('/%7E/', '~', $res);
  101. return $res;
  102. }
  103. /**
  104. * get请求时无用没看
  105. * @param $name
  106. * @param $value
  107. */
  108. public function putDomainParameters($name, $value)
  109. {
  110. $this->domainParameters[$name] = $value;
  111. }
  112. /**
  113. * 对待加密字符串加密
  114. * @param $source
  115. * @param $accessSecret
  116. * @return string
  117. */
  118. public function signString($source, $accessSecret)
  119. {
  120. return  base64_encode(hash_hmac('sha1', $source, $accessSecret, true));
  121. }
  122. /**
  123. * xml转成数组
  124. * @param $xml
  125. * @return mixed
  126. */
  127. function xmlToArray($xml){
  128. //禁止引用外部xml实体
  129. libxml_disable_entity_loader(true);
  130. $xmlstring = simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA);
  131. $val = json_decode(json_encode($xmlstring),true);
  132. return $val;
  133. }
  134. }

对上面的简单调用和几个常用方法例子：

[php]
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: ForeverTime
  5. * Date: 2016/12/10
  6. * Time: 16:27
  7. */
  8. class Ali_Lite{
  9. protected  $config;
  10. protected  $aliLive;
  11. public function __construct()
  12. {
  13. include_once 'Aliyun.php';
  14. $this -> aliLive = new Aliyun();
  15. }
  16. /**
  17. * 查询在线人数
  18. * @param $domainName  直播域名
  19. * @param $appName     应用名
  20. * @param $streamName  推流名
  21. */
  22. public function describeLiveStreamOnlineUserNum($domainName,$appName,$streamName){
  23. $apiParams = array(
  24. 'Action'=>'DescribeLiveStreamOnlineUserNum',
  25. 'DomainName'=>$domainName,
  26. 'AppName'=>$appName,
  27. 'StreamName'=>$streamName,
  28. );
  29. return $this -> aliLive -> aliApi($apiParams,$credential="GET", $domain="cdn.aliyuncs.com");
  30. }
  31. /**
  32. * 获取某个域名或应用下的直播流操作记录
  33. * @param $domainName      域名
  34. * @param $appName         应用名
  35. * @param $streamName      推流名
  36. */
  37. public function describeLiveStreamsControlHistory($domainName,$appName,$startTime,$endTime){
  38. $apiParams = array(
  39. 'Action'=>'DescribeLiveStreamsControlHistory',
  40. 'DomainName'=>$domainName,
  41. 'AppName'=>$appName,
  42. 'StartTime'=>$startTime,
  43. 'EndTime'=>$endTime,
  44. );
  45. return $this -> aliLive -> aliApi($apiParams,$credential="GET", $domain="cdn.aliyuncs.com");
  46. }
  47. /**
  48. * 查看指定域名下（或者指定域名下某个应用）的所有正在推的流的信息
  49. * @param $domainName       域名
  50. * @param $appName          应用名
  51. * @return bool|int|mixed
  52. */
  53. public function describeLiveStreamsOnlineList($domainName,$appName){
  54. $apiParams = array(
  55. 'Action'=>'DescribeLiveStreamsOnlineList',
  56. 'DomainName'=>$domainName,
  57. 'AppName'=>$appName,
  58. );
  59. return $this -> aliLive -> aliApi($apiParams,$credential="GET", $domain="cdn.aliyuncs.com");
  60. }
  61. /**
  62. * 查询推流黑名单列表
  63. * @param $domainName       域名
  64. * @return bool|int|mixed
  65. */
  66. public function describeLiveStreamsBlockList($domainName){
  67. $apiParams = array(
  68. 'Action'=>'DescribeLiveStreamsBlockList',
  69. 'DomainName'=>$domainName,
  70. );
  71. return $this -> aliLive -> aliApi($apiParams,$credential="GET", $domain="cdn.aliyuncs.com");
  72. }
  73. /**
  74. * 生成推流地址
  75. * @param $streamName 用户专有名
  76. * @param $vhost 加速域名
  77. * @param $time 有效时间单位秒
  78. */
  79. public function getPushSteam($streamName,$vhost,$time=3600){
  80. $time = time()+$time;
  81. $videohost = $this->aliLive->video_host;
  82. $appName=$this->aliLive->appName;
  83. $privateKey=$this->aliLive->privateKey;
  84. if($privateKey){
  85. $auth_key =md5('/'.$appName.'/'.$streamName.'-'.$time.'-0-0-'.$privateKey);
  86. $url =$videohost.'/'.$appName.'/'.$streamName.'?vhost='.$vhost.'&auth_key='.$time.'-0-0-'.$auth_key;
  87. }else{
  88. $url = $videohost.'/'.$appName.'/'.$streamName.'?vhost='.$vhost;
  89. }
  90. return $url;
  91. }
  92. /**
  93. * 生成拉流地址
  94. * @param $streamName 用户专有名
  95. * @param $vhost 加速域名
  96. * @param $type 视频格式 支持rtmp、flv、m3u8三种格式
  97. */
  98. public function getPullSteam($streamName,$vhost,$time=3600,$type='rtmp'){
  99. $time = time()+$time;
  100. $appName=$this->aliLive->appName;
  101. $privateKey=$this->aliLive->privateKey;
  102. $url='';
  103. switch ($type){
  104. case 'rtmp':
  105. $host = 'rtmp://'.$vhost;
  106. $url = '/'.$appName.'/'.$streamName;
  107. break;
  108. case 'flv':
  109. $host = 'http://'.$vhost;
  110. $url = '/'.$appName.'/'.$streamName.'.flv';
  111. break;
  112. case 'm3u8':
  113. $host = 'http://'.$vhost;
  114. $url = '/'.$appName.'/'.$streamName.'.m3u8';
  115. break;
  116. }
  117. if($privateKey){
  118. $auth_key =md5($url.'-'.$time.'-0-0-'.$privateKey);
  119. $url = $host.$url.'?auth_key='.$time.'-0-0-'.$auth_key;
  120. }else{
  121. $url = $host.$url;
  122. }
  123. return $url;
  124. }
  125. /**
  126. * 禁止推流接口
  127. * @param $domainName        您的加速域名
  128. * @param $appName          应用名称
  129. * @param $streamName       流名称
  130. * @param $liveStareamName  用于指定主播推流还是客户端拉流, 目前支持”publisher” (主播推送)
  131. * @param $resumeTime       恢复流的时间 UTC时间 格式：2015-12-01T17:37:00Z
  132. * @return bool|int|mixed
  133. */
  134. public function forbid($streamName,$resumeTime,$domainName='www.test.com',$appName='xnl',$liveStreamType='publisher'){
  135. $apiParams = array(
  136. 'Action'=>'ForbidLiveStream',
  137. 'DomainName'=>$domainName,
  138. 'AppName'=>$appName,
  139. 'StreamName'=>$streamName,
  140. 'LiveStreamType'=>$liveStreamType,
  141. 'ResumeTime'=>$resumeTime
  142. );
  143. return $this -> aliLive -> aliApi($apiParams,$credential="GET", $domain="cdn.aliyuncs.com");
  144. }
  145. /**
  146. * 恢复直播流推送
  147. * @param $streamName              流名称
  148. * @param string $appName          应用名称
  149. * @param string $liveStreamType   用于指定主播推流还是客户端拉流, 目前支持”publisher” (主播推送)
  150. * @param string $domainName       您的加速域名
  151. */
  152. public function resumeLive($streamName,$domainName='www.test.top',$appName='xnl',$liveStreamType='publisher'){
  153. $apiParams = array(
  154. 'Action'=>'ResumeLiveStream',
  155. 'DomainName'=>$domainName,
  156. 'AppName'=>$appName,
  157. 'StreamName'=>$streamName,
  158. 'LiveStreamType'=>$liveStreamType,
  159. );
  160. return $this -> aliLive -> aliApi($apiParams,$credential="GET", $domain="cdn.aliyuncs.com");
  161. }
  162. }

相关文章