Multi Thread PHP Port listener script.

Hi...

 this is simple echo-reply asynchronous TCP server. It uses select insted of forking or multithreading. There are some drawbacks in this code but it is good example. You can test it using telnet or PuTTy or some other client providing raw socket connection.

 I hope this helps you...fell free to ask any related questions.

-fetak

And here is the source:
<?php

     // we want to see all errors
     error_reporting(E_ALL);
     
     // no time limit
     set_time_limit(0);
     
     // loading socket extension
     dl('php_sockets.dll');     // this was tested on win32

     // input, output, error streams "re"defs when we use
     // PHP version lower than 4.3.0
     if (version_compare(phpversion(), '4.3.0RC1', '<')) {
          define('STDIN', fopen("php://stdin","r"));
          define('STDOUT', fopen("php://stout","w"));
          define('STDERR', fopen("php://sterr","w"));
     }
     
     // server properties definition {{{
     // server address
     define('ADDR', '127.0.0.1');
     // server port
     define('PORT', 6666);
     // max clients in queue
     define('MAX_CLIENTS', 10);
     // }}}

     // create new AF_INET, SOCK_STREAM server
     @$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
     if (!$sock) {
          die(socket_strerror($sock)."\n");
     }

     // bind socket to appropriate address and port
     @$binded = socket_bind($sock, ADDR, PORT);
     if (!$binded) {
          die(socket_strerror($sock)."\n");
     }
     
     // make socket listening to incomming connections
     @$listening = socket_listen($sock, MAX_CLIENTS);
     if (!$listening) {
          die(socket_strerror($sock)."\n");
     }
     
     // non-blocking mode
     socket_set_nonblock($sock);
     
     // if true server will shutdown
     $stop_server = false;
     
     // list of active sockets
     $active_sockets = array(ADDR.':'.PORT => $sock);
     
     while (!$stop_server) {
          $r = $w = $e = $active_sockets;
          socket_select($r, $w, $e, 1);
         
          while (list($i, $curr_sock) = each($r)) {
               if ($curr_sock === $sock) {
                    fwrite(STDOUT, 'Accepting new connection...');
                    @$socket_accepted = socket_accept($sock);

                    if (!$socket_accepted) {
                         fwrite(STDOUT, "failed!\n");
                         break;
                    } else {
                         $c_addr = $c_port = 0;
                         socket_getpeername($socket_accepted, $c_addr, $c_port);
                         $active_sockets["$c_addr:$c_port"] = $socket_accepted;
                         fwrite(STDOUT, "accepted from $c_addr:$c_port($socket_accepted)\n");
                    }
               } else {
                    // read something here
                    @$data = trim(socket_read($curr_sock, 1024));
                    if ($data === '') {
                         $c_port = $c_addr = 0;
                         socket_getpeername($curr_sock, $c_addr, $c_port);
                         fwrite(STDOUT, "Client $c_addr:$c_port disconnected.\n");
                         socket_close($active_sockets["$c_addr:$c_port"]);
                         unset($active_sockets["$c_addr:$c_port"]);
                    } elseif ($data === '!stop') {
                         fwrite(STDOUT, "Server shutdown...");
                         $stop_server = true;
                    } else {
                         socket_write($curr_sock, "You wrote: $data\r\n");
                    }
               }
          }
     }
     
     fwrite(STDOUT, "done\n");
?>