Fsockopen - test otvoreného portu – PHP – Fórum – Programujte.com

Potrebujem [podtrzene]rýchlo[/podtrzene] otestovať či sú porty na daných ip otvorené. Zatiaľ cyklicky volám cca toto (iné riešenie som ani inde nenašiel):

$timeout = 2;  // 2 sec na otestovanie

$status = ST_UNKNOWN;



if ($f = @fsockopen($ip,$port,$errno,$errstr,$timeout))

{

  fclose($f); $status = ST_ONLINE; // zapnuty

} else $status = ST_OFFLINE; // vypnuty

Jou, takže existuje spôsob s priamym použitím socketov. http://www.php.net/manual/en/ref.sockets.php Tie umožňujú socket_set_nonblock, takže môžem odpáliť všetky testy naraz. Problém je, že to na mojom PHP nebeží (nutné zapnúť podporu socketov pri kompilácii PHP). Ide hlavne o to, že to robím ako open projekt, tak chcem minimum závislostí, takže ani nechecm zapínať.

Tak som začal rozmýšlať, ako to urobiť multi-threadovo, tak, aby sa tie testy mohli vykonávať naraz aj s použitím fsockopen(). PHP s vláknami asi veľmi nevie (aspoň som nenašiel), tak som to riešil volaním externých scriptov.

script portcheck.php:

#!/usr/bin/php

<?php



  if ($f=@fsockopen($argv[1],$argv[2],$errno,$errstr,$argv[3]))

  {

    fclose($f);

    exit("ONLINE\n");

  }

  exit("OFFLINE\n");



?>

Uf, tak som rád, že nie som sám, kto to riešil... tretí deň googlenia priniesol svoje ovocie :-)

http://netevil.org/blog/2005/may/guru-multiplexing

[podtrzene]Využíva[/podtrzene]: stream_socket_client s flagom STREAM_CLIENT_ASYNC_CONNECT a stream_select, čo umožnuje pracovať so stream-ami rovnako ako so socketmi, aj keď sockety nie su dostupné. Dokonca sa to dá jednoducho skombinovať (potom bude vyžadovať PHP5 alebo PHP4+ext/sockets).

www.php.net/stream_socket_client
http://www.php.net/stream_select


EDIT:

Takže tu je vysledná funkcia, ktora testuje dostupnosť viacerých služieb naraz (vyžaduje PHP5):

Vstypy:
$services = pole stringov "host:port"
$timeout = čas v sekundách (aj float)

Výstup
= pole(rovnaké indexy ako $services) s hodnotami:
null - chyba
false - nedostupný (timeout)
true - zapnuty

  function check_services($services,$timeout=1)

  {



    $time_start = microtime(true);



    $socket = Array();

    $status = Array();

    $error  = Array();



    foreach ($services as $id => $service)

    {

      $status[$id] = null;

      if($s = stream_socket_client($service, $errno, $errstr, $timeout, STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT)) $socket[$id] = $s;

    }



    while(count($socket))

    {

      $write = $socket; $e = null;

      if (($timeout_remaining=$time_start+$timeout-microtime(true))>0 && stream_select($e, $write, $e, $timeout_remaining))

      {

        foreach($write as $w)

        {

          $id = array_search($w, $socket);

          $status[$id] = true;

          fclose($w);

          unset($socket[$id]);

        }

      } else {

        foreach($socket as $id => $s) 

        {

          $status[$id] = false;

          fclose($socket[$id]);

          unset($socket[$id]);

        }

        break;

      }

    }

    return $status;

  }

  $services = Array(

                    'localhost:21',

                    'localhost:25',

                    'localhost:80',

                    'localhost:110',

                    'programujte.com:80');



  print_r(check_services($services));