用PHP的Socket建立自己的聊天室服务器

/**
* set debug mode
*
* @access public
* @param mixed $debug [text|htmlfalse]
* @param string $dest destination of debug message (stdout to output or filename if log should be written)
*/
function setDebugMode( $debug, $dest = "stdout" ){
   if( $debug === false ){
    $this->debug = false;
    return true;
   }

   $this->debug   = true;
   $this->debugMode = $debug;
   $this->debugDest = $dest;
}

/**
* start the server
*
* @access public
* @param int $maxClients
*/
function start(){
   $this->initFD = @socket_create( AF_INET, SOCK_STREAM, 0 );
   if( !$this->initFD )
    die( "patServer: Could not create socket." );

   // adress may be reused
   socket_setopt( $this->initFD, SOL_SOCKET, SO_REUSEADDR, 1 );

   // bind the socket
   if(!@socket_bind( $this->initFD, $this->domain, $this->port ) ){
    @socket_close( $this->initFD );
    die( "patServer: Could not bind socket to ".$this->domain." on port ".$this->port." ( ".$this->getLastSocketError( $this->initFd )." )." );
   }

   // listen on selected port
   if(!@socket_listen( $this->initFD, $this->maxQueue ) )
    die( "patServer: Could not listen ( ".$this->getLastSocketError( $this->initFd )." )." );

   $this->sendDebugMessage( "Listening on port ".$this->port.". Server started at ".date( "H:i:s", time() ) );

   // this allows the shutdown function to check whether the server is already shut down
   $GLOBALS["_patServerStatus"] = "running";
   // this ensures that the server will be sutdown correctly
   register_shutdown_function( array( $this, "shutdown" ) );

   if( method_exists( $this, "onStart" ) )
    $this->onStart();

   $this->serverInfo["started"] = time();
   $this->serverInfo["status"]   = "running";

   while( true ){
    $readFDs = array();
    array_push( $readFDs, $this->initFD );

    // fetch all clients that are awaiting connections
    for( $i = 0; $i < count( $this->clientFD ); $i++ )
     if( isset( $this->clientFD[$i] ) )
      array_push( $readFDs, $this->clientFD[$i] );

    // block and wait for data or new connection
    $ready = @socket_select( $readFDs, $this->null, $this->null, NULL );

    if( $ready === false ){
     $this->sendDebugMessage( "socket_select failed." );
     $this->shutdown();
    }

    // check for new connection
    if( in_array( $this->initFD, $readFDs ) ){
     $newClient = $this->

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!