Nginx模块之———— RTMP 模块的在线统计功能 stat 数据流数据的获取（不同节点则获取的方式不同）

 public function getStreamByIp($outerIP, $streamName)
    {
        //查询录像模块的ＩＰ地址外网，根据这个可以查看到相应的流
        $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;
    }

 public function getStreamByIp($outerIP, $streamName)
    {
        //查询录像模块的ＩＰ地址外网，根据这个可以查看到相应的流
        $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;
    }

    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;
    }