【PHP+阿里云】阿里云直播生成推流和播流地址类

1、阿里云直播官方文档：https://help.aliyun.com/document_detail/87396.html?spm=a2c4g.11186623.6.609.19d83dd2Uejwx7

     在线调试api工具：https://help.aliyun.com/document_detail/48207.html?spm=a2c4g.11186623.6.689.39f830f63Otms9

2、引入alibaba sdk for php SDK，git：https://github.com/aliyun/openapi-sdk-php

3、官方直播文档，有句话很重要：https://help.aliyun.com/document_detail/87396.html?spm=a2c4g.11186623.6.609.19d83dd2Uejwx7

 

 这句话什么意思？【就是说，你按步骤先配置域名、鉴权，直播地址随便你怎么生成都是有效的，直接拿到能录制直播和观看直播的组件中进行使用就可以了。测试推荐：OBS推工具和LVS播工具】

 

4、自定义阿里云直播 操作类（实现生成推流和播流地址、暂停直播、恢复直播、直播间人数显示等功能），不废话：

<?php

namespace App\Service;

use AlibabaCloud\Client\AlibabaCloud;
use AlibabaCloud\Client\Exception\ClientException;
use AlibabaCloud\Client\Exception\ServerException;

class AliyunLive
{
    private $error;
    const DOMAIN_NAME=\'alive.i***h.cn\';　　//你的加速域名，和推流域名一致。
    const REGION_ID=\'cn-shanghai\';　　　　　　//区域
    const ACCESS_KEY_ID=\'LTAI4*****ibc\';　　//阿里云秘钥
    const ACCESS_KEY_SECRET=\'HPg2*****gnNOK\';　　//阿里云秘钥
    const LIVE_HOST=\'live.aliyuncs.com\';　　//写死，阿里云直播CDN域名
    const ALIVE_URL=\'alive.i***h.cn\';　　　　//推域名
    const ALIVE_KEY=\'oR11sd***\';        //推流鉴权KEY，后台拿
    const TLIVE_URL=\'tlive.i***h.cn\';　　　　//关联的播域名
    const TLIVE_KEY=\'jdU1d***op\';    //播流鉴权KEY，后台拿
    
    /**
     * 创建签名
     * @param $path 播放地址 域名后面所有
     * @param $exp //结束时间
     * @param $key
     * @return string
     */
    private static function createSign($path,$exp,$key)
    {
        $rand=0;
        $uid=0;
        $str=sprintf("%s-%s-%s-%s-%s",$path,(string)$exp,(string)$rand,(string)$uid,$key);
        $hashValue=md5($str);
        $authKey=sprintf("%s-%s-%s-%s",(string)$exp,(string)$rand,(string)$uid,$hashValue);
        return "auth_key=$authKey";
    }
    
    /**
     * 创建是直播地址
     * @param $appName 应用名称 ，自定义
     * @param $streamName 房间名称，自定义，该应用下唯一
     * @param $endTime 结束时间
     * @return array|bool  播放流（观看者）：alive_url，推流（直播者）：tlive_url
     */
    public static function createdLive($appName,$streamName,$endTime)
    {
        if(!$appName || !$streamName || !$endTime || $endTime < time()){
            return false;
        }
        //创建播流
        $path="/$appName/$streamName";
        $aliveUrl=\'rtmp://\'.self::ALIVE_URL."$path?".self::createSign($path,$endTime,self::ALIVE_KEY);
    
        //创建推流
        $tliveUrlRTMP= \'rtmp://\'.self::TLIVE_URL."$path?".self::createSign($path,$endTime,self::TLIVE_KEY);
        // $tliveUrlFLV =\'http://\'.self::TLIVE_URL."$path.flv?".self::createSign($path,$endTime,self::TLIVE_KEY);
        // $tliveUrlM3U8=\'http://\'.self::TLIVE_URL."$path.m3u8?".self::createSign($path,$endTime,self::TLIVE_KEY);
        
        return [
            \'alive_url\'=>$aliveUrl,
            \'tlive_url\'=>$tliveUrlRTMP,
        ];
    }
    //停止直播
    public static function stopLive($appName,$streamName)
    {
    
        $query=[
            \'RegionId\' => self::REGION_ID,
            \'AppName\' => $appName,
            \'StreamName\' => $streamName,
            \'LiveStreamType\' => "publisher",
            \'DomainName\' => self::DOMAIN_NAME,
            // \'ResumeTime\'=>\'\',
        ];
        $_this=new static();
        $result=$_this->request(\'ForbidLiveStream\',$query);
        return true;
    }
    //恢复直播
    public static function resumeLive($appName,$streamName)
    {
        $query=[
            \'RegionId\' => self::REGION_ID,
            \'LiveStreamType\' => "publisher",
            \'AppName\' => $appName,
            \'StreamName\' => $streamName,
            \'DomainName\' => self::DOMAIN_NAME,
        ];
        $_this=new static();
        $result=$_this->request(\'ResumeLiveStream\',$query);
        return true;
    }
    
    //获取直播在线人数
    public static function getOnlineUserNum($appName,$streamNma)
    {
        
        $query=[
            \'RegionId\' => self::REGION_ID,
            \'DomainName\' => self::DOMAIN_NAME,
            \'AppName\'=>$appName,
            \'StreamName\' =>$streamNma,
        ];
        $_this=new static();
        $result=$_this->request(\'DescribeLiveStreamOnlineUserNum\',$query);
        return $result;
    }
    
    
    
    //日志
    public function log($msg,$info=\'info\')
    {
        $msg=\'直播接口：\'.$msg.($info !=\'info\'?var_export($info,1):\'\');
        log_write($msg);
    }
    //获取错误
    public static function getError()
    {
        return (new static())->error;
    }
    //请求
    private function request($action,Array $query)
    {
        AlibabaCloud::accessKeyClient(self::ACCESS_KEY_ID, self::ACCESS_KEY_SECRET)
            ->regionId(self::REGION_ID)
            ->asDefaultClient();
        try {
            $result = AlibabaCloud::rpc()
                ->product(\'live\')
                // ->scheme(\'https\') // https | http
                ->version(\'2016-11-01\')
                ->action($action)
                ->method(\'POST\')
                ->host(self::LIVE_HOST)
                ->options([
                    \'query\' => $query,
                ])
                ->request();
            return $result->toArray();
        } catch (ClientException $e) {
            $this->error=$e->getMessage();
            return false;
        } catch (ServerException $e) {
            $this->error=$e->getMessage();
            return false;
        }
    }
}