Nginx模塊之———— RTMP 模塊的在線統計功能 stat 數據流數據的獲取(不同節點則獲取的方式不同)


一、目前只有一個Live節點存在 

單節點獲取方式如下:

 public function getStreamByIp($outerIP, $streamName)
    {
        //查詢錄像模塊的IP地址外網,根據這個可以查看到相應的流
        $url = $outerIP . "/rtmp/stat";
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_HEADER, 0);
        $output = curl_exec($ch);
        curl_close($ch);
        //所有流的信息,解析Xml
        $outputs = $this->FromXml($output);
//        $streamInfo = $outputs['server']['application']['live']['stream'];
        $streamInfo = $outputs['server']['application']['live']['stream'];

        if (array_key_exists("name", $streamInfo)) {
            //判斷該設備是否在這個數組中,真:獲取這個設備的所有打流信息
            if ($streamName == $streamInfo['name']) {
                $totalInfo['status'] = 200;
                $totalInfo['message'] = 'The server is normal and is currently streaming';
                $totalInfo['dataList']['name'] = $streamInfo['name'];
                $totalInfo['dataList']['bw_in'] = $streamInfo['bw_in'];
                $totalInfo['dataList']['bw_out'] = $streamInfo['bw_out'];

            } else {
                $totalInfo['status'] = 500;
                $totalInfo['message'] = 'The server has a problem or is not currently streaming information 1';
                $totalInfo['dataList']['name'] = $streamName;
                $totalInfo['dataList']['bw_in'] = 0;
                $totalInfo['dataList']['bw_out'] = 0;
            }
        } else {
            //存放所有的設備號到一個數組中
            foreach ($streamInfo as $key => $val) {
                $deviceInfo[] = $val['name'];
            }
            //判斷該設備是否在這個數組中,真:獲取這個設備的所有打流信息
            if (in_array($streamName, $deviceInfo)) {
                $totalInfo['status'] = 200;
                $totalInfo['message'] = 'The server is normal and is currently streaming';
                foreach ($streamInfo as $val) {
                    if ($val['name'] == $streamName) {
                        $totalInfo['dataList']['name'] = $val['name'];
                        $totalInfo['dataList']['bw_in'] = $val['bw_in'];
                        $totalInfo['dataList']['bw_out'] = $val['bw_out'];
                    }
                }
            } else {
                $totalInfo['status'] = 500;
                $totalInfo['message'] = 'The server has a problem or is not currently streaming information 2';
                $totalInfo['dataList']['name'] = $streamName;
                $totalInfo['dataList']['bw_in'] = 0;
                $totalInfo['dataList']['bw_out'] = 0;
            }
        }
        return $totalInfo;
    }

二、目前有兩個節點Live節點和Live2節點存在 

 多節點獲取方式如下:

 public function getStreamByIp($outerIP, $streamName)
    {
        //查詢錄像模塊的IP地址外網,根據這個可以查看到相應的流
        $url = $outerIP . "/rtmp/stat";
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_HEADER, 0);
        $output = curl_exec($ch);
        curl_close($ch);
        //所有流的信息,解析Xml
        $outputs = $this->FromXml($output);
        $streamInfo = $outputs['server']['application'][0]['live']['stream'];  //主要看這里哦!!!!!!!!!!!!!!!!這里獲取的時候是一個二維數組 if (array_key_exists("name", $streamInfo)) {
            //判斷該設備是否在這個數組中,真:獲取這個設備的所有打流信息
            if ($streamName == $streamInfo['name']) {
                $totalInfo['status'] = 200;
                $totalInfo['message'] = 'The server is normal and is currently streaming';
                $totalInfo['dataList']['name'] = $streamInfo['name'];
                $totalInfo['dataList']['bw_in'] = $streamInfo['bw_in'];
                $totalInfo['dataList']['bw_out'] = $streamInfo['bw_out'];

            } else {
                $totalInfo['status'] = 500;
                $totalInfo['message'] = 'The server has a problem or is not currently streaming information 1';
                $totalInfo['dataList']['name'] = $streamName;
                $totalInfo['dataList']['bw_in'] = 0;
                $totalInfo['dataList']['bw_out'] = 0;
            }
        } else {
            //存放所有的設備號到一個數組中
            foreach ($streamInfo as $key => $val) {
                $deviceInfo[] = $val['name'];
            }
            //判斷該設備是否在這個數組中,真:獲取這個設備的所有打流信息
            if (in_array($streamName, $deviceInfo)) {
                $totalInfo['status'] = 200;
                $totalInfo['message'] = 'The server is normal and is currently streaming';
                foreach ($streamInfo as $val) {
                    if ($val['name'] == $streamName) {
                        $totalInfo['dataList']['name'] = $val['name'];
                        $totalInfo['dataList']['bw_in'] = $val['bw_in'];
                        $totalInfo['dataList']['bw_out'] = $val['bw_out'];
                    }
                }
            } else {
                $totalInfo['status'] = 500;
                $totalInfo['message'] = 'The server has a problem or is not currently streaming information 2';
                $totalInfo['dataList']['name'] = $streamName;
                $totalInfo['dataList']['bw_in'] = 0;
                $totalInfo['dataList']['bw_out'] = 0;
            }
        }
        return $totalInfo;
    }

三、解析Xml

    public function FromXml($xml)
    {
        if (!$xml) {
            $totalInfo['status'] = 500;
            $totalInfo['message'] = '沒有該設備的相應信息';
            $totalInfo['dataList'] = null;
            return $totalInfo;
        }
        //將XML轉為array
        $values = json_decode(json_encode(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA)), true);
        return $values;
    }

以上為在錄像時候遇到問題,已經解決!

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM