Форумы портала PHP.SU

Нужно настроить правильно сокеты и протокол на мониторинге cs.
<?PHP 
// отключение предупреждений
error_reporting(0);
 
$host = "127.0.0.1";  // localhost
$user = "user";     // root
$database = "db_name";
$password = "pass";
 
 
 
// Соединяемся c базой данных
$db = mysql_connect($host, $user, $password) or die("Не подключились к базе данных: " . mysql_error());
print ("Подключились к базе данных<br><br>");
 
mysql_query("set character_set_client   ='utf8'"); // utf8 cp1251
mysql_query("set character_set_results  ='utf8'"); // utf8 cp1251
mysql_query("set collation_connection   ='utf8_general_ci'"); // utf8_general_ci cp1251_general_ci
 
// Выбор нужной базы данных
mysql_select_db($database) or die ("Не могу найти базу данных");
 
 
echo "
<html>
<head>
<title>Обновление статистики серверов</title>
<meta http-equiv='Content-Type' content='text/html; charset=utf-8'>
</head>
<body>";
 
 
// число строк в таблице и полей в строке
$q = mysql_query("SELECT * FROM md5_cs_servers");
echo "В таблице md5_cs_servers ".mysql_num_rows($q)." записей<br>";
echo "В таблице md5_cs_servers ".mysql_num_fields($q)." полей<br><br>";
 
 
//@session_start();
 
 
function recheck()
{
        global $db;
         // обновляем данные в таблице
                $query="SELECT id, ip, port, name 
                        FROM md5_cs_servers";
                $result = mysql_query($query) or die("Ошибка : " . mysql_error());
                
                while ($serv = mysql_fetch_array($result, MYSQL_ASSOC)) {
        
                //}
                
                
                
                //foreach($result as $serv)
                //{
                        global $db;
        $id = $serv['id'];      
        $server = $serv['ip'];
        $port = $serv['port'];
        
        $active = 1;
        $map = '';
        $fp = fsockopen ("udp://".$server,$port);
        stream_set_timeout($fp, 2);     
        if (!$fp)
        { //если нет коннекта - сервер выключен
                $active = 0;
        }
        else
        { // возможно что-то удастся прочитать
        //
        //"\xFF\xFF\xFF\xFF\x54\x53\x6F\x75\x72\x63\x65\x20\x45\x6E\x67\x69\x6E\x65\x20\x51\x75\x65\x72\x79\x00".chr(10)  родной
        //"\xFF\xFF\xFF\xFF\x54Source Engine Query\x00");
        
            fwrite($fp,"\xFF\xFF\xFF\xFFTSource Engine Query\x00");
                $start=time();
                socket_set_timeout($fp, 1);
                $st=fread($fp, 1);
                $r=socket_get_status($fp);
                $r=$r["unread_bytes"];
                $st.=fread($fp,$r);
                fclose($fp);
                $st=substr($st,5);
                $address=SubStr($st,0,StrPos($st,chr(0)));
                $address=str_replace(chr(0),"|",$address);
                
                $st=SubStr($st,StrPos($st,chr(0))+1);
                $name=SubStr($st,0,StrPos($st,chr(0)));
                
                $st=SubStr($st,StrPos($st,chr(0))+1);
                $map=SubStr($st,0,StrPos($st,chr(0)));
                
                $st=SubStr($st,StrPos($st,chr(0))+1);
                $st=SubStr($st,StrPos($st,chr(0))+1);
                $st=SubStr($st,StrPos($st,chr(0))+1);
                $current=ord(SubStr($st,0,1));
                
                $max=ord(SubStr($st,1,1));
        }
 
        
        //WHERE id='{$serv['id']}'
        if ($active AND $map)
        { // если есть ответ - обновляем инфу
         //$format = r;
        $date = date(U);
        $time = date( "H:i:s" );
        //для отладки
        //echo "<i>".$time." (сервер обновлён)</i> Карта: [".$map."] Игроки: [".$current."/".$max."] IP:PORT: [".$serv['ip'].":".$serv['port']."] Имя: [".$name."] ID: [".$id."]<br>";
                //$query=
                mysql_query("UPDATE md5_cs_servers 
                            SET name='{$name}', map='{$map}', current='{$current}', max='{$max}', up_date='{$date}' 
                                WHERE id='{$id}' 
                            LIMIT 1");
                //$db -> mysql_query($query) or die("Ошибка : " . mysql_error());       
                            
        }
        else
        { // иначе сервер выключен
        //для отладки
        //echo "<i>".$time." (сервер не ответил)</i> IP:PORT [".$serv['ip'].":".$serv['port']."] ID: [".$id."]<br>";
                //$query=
                mysql_query("UPDATE md5_cs_servers 
                        SET map='', current='0', max='0', up_date='{$date}' 
                WHERE id='{$id}' 
                                LIMIT 1");
                //$db -> mysql_query($query) or die("Ошибка : " . mysql_error());       
                                
        }
        
 
                }
                // обновляем дату последней проверки
                //$db->query('UPDATE ?_last_check SET last_check = ?', time());
        
}
 
 
 
 
echo "</body></html>";
 
 
 
// Закрываем соединение с бд 
//mysql_close($db);
 
 
//function check_server($serv)
//{
        
//}
 
?>
 
 
PHP.SU

udp пакеты
