Эмуляция многопоточности в php

Discussion in 'PHP' started by Ru}{eeZ, 9 Jun 2009.

  1. Ru}{eeZ

    Ru}{eeZ Elder - Старейшина

    Joined:
    19 Feb 2008
    Messages:
    454
    Likes Received:
    73
    Reputations:
    -5
    Помогите разобраться с многопоточностью в php. Написал сервер, но как вы уже догадались, он работает только с одним человеком. Я с этим уже заебался...
    PHP:
    <?php
    $addr 
    '127.0.0.1';
    $port 4941;
    $password 987654321;
    $icq 595778;
    $email 'm-comp@mail.ru';
    set_time_limit(0);
    if(!
    $socket socket_create(AF_INET,SOCK_STREAM,SOL_TCP)) socket_strerror(socket_last_error()) && die;
    @
    socket_bind($socket,$addr,$port) or die;
    socket_listen($socket,10) or socket_strerror(socket_last_error()) && die;
    for(;;) {
      if(!
    $accept socket_accept($socket)) socket_strerror(socket_last_error()) && die;
      
    socket_write($accept,'Welcome to the RuXeeZ server! Please enter "!help" for view more information.'."\r\n\r\n") or socket_strerror(socket_last_error()) && die;
      for(;;) {
        if(!
    $read socket_read($accept,256,PHP_NORMAL_READ)) break;
        
    $read trim($read);
        if(
    $read == '!close') break;
        else if(
    strstr($read,'!stop') && ltrim(substr($read,5)) == $password) {
          
    socket_close($accept);
          break 
    2;
        }
        else if(
    $read == '!help') {
        
    $say '   --System functions--
    !close - close this connection
    !help - view more information
    !contacts - contact to administration'
    ."\r\n".'
       --Other functions---
    !base64e text - encode text in base64 hash
    !base64d text - decode base64 hash in text
    !md5 text - encode text in md5 hash
    !sha1 text - encode text in sha1 hash
    !rot13 text - encode text in rot13 hash'
    ."\r\n";
        } else if(
    $read == '!contacts'$say 'ICQ: '.$icq."\r\n".'E-mail: '.$email;
        else if(
    strstr($read,'!base64e')) $say base64_encode(ltrim(substr($read,8)));
        else if(
    strstr($read,'!base64d')) $say base64_decode(ltrim(substr($read,8)));
        else if(
    strstr($read,'!md5')) $say md5(ltrim(substr($read,4)));
        else if(
    strstr($read,'!sha1')) $say sha1(ltrim(substr($read,5)));
        else if(
    strstr($read,'!rot13')) $say str_rot13(ltrim(substr($read,6)));
        else 
    $say 'Not correct command';
        
    socket_write($accept,$say."\r\n\r\n") or socket_strerror(socket_last_error()) && die;
      }
      
    socket_close($accept);
    }
    socket_close($socket);
    //echo 'Server is stoped';
    ?>
    прошу непонимающих не лезть со ссылками
     
    #1 Ru}{eeZ, 9 Jun 2009
    Last edited: 9 Jun 2009
  2. Ctacok

    Ctacok Banned

    Joined:
    19 Dec 2008
    Messages:
    732
    Likes Received:
    646
    Reputations:
    251
    "!help" под '', у меня вызывает краш.
    "Всё самое сложное, самое простое" - (c) HZ.
    Проверь корректность всего кода.
     
  3. Ru}{eeZ

    Ru}{eeZ Elder - Старейшина

    Joined:
    19 Feb 2008
    Messages:
    454
    Likes Received:
    73
    Reputations:
    -5
    я не просил проверять код, сервер написан под одного клиента, а нужно, чтобы его могли использовать несколько человек сразу.
    Зачем лезть (в данном случае флудить), если не разбираешься? (вопрос, не нуждающийся в ответе)
     
  4. FireFenix

    FireFenix Elder - Старейшина

    Joined:
    3 Jun 2009
    Messages:
    390
    Likes Received:
    115
    Reputations:
    23
    http://php.net/manual/en/ref.pcntl.php
    http://habrahabr.ru/blogs/php/40245/ - пример с сокетами
     
    1 person likes this.
  5. diehard

    diehard Elder - Старейшина

    Joined:
    30 Sep 2007
    Messages:
    442
    Likes Received:
    266
    Reputations:
    15
    блин подобная тема поднимается на форуме каждые несколько месяцев, ТС пользуйся поиском
     
  6. Gifts

    Gifts Green member

    Joined:
    25 Apr 2008
    Messages:
    2,494
    Likes Received:
    807
    Reputations:
    614
    Ru}{eeZ http://ru2.php.net/manual/ru/sockets.examples.php - пример из мануала, нумер 1, ретранслирует текст, принимает команды.

    З.Ы нафига маны читать?
     
    _________________________
  7. nerezus

    nerezus Banned

    Joined:
    12 Aug 2004
    Messages:
    3,191
    Likes Received:
    727
    Reputations:
    266
    НАхрена это делать на пхп? о_О
     
  8. scrat

    scrat кодер

    Joined:
    8 Apr 2007
    Messages:
    625
    Likes Received:
    541
    Reputations:
    3
    php не тот язык для реализации конкретной задачи.
     
  9. DDoSька

    DDoSька Elder - Старейшина

    Joined:
    5 May 2008
    Messages:
    317
    Likes Received:
    352
    Reputations:
    18
    ТОже самое сказал ему в асике, я бы препочёл PERL для этой задачи
     
  10. Ru}{eeZ

    Ru}{eeZ Elder - Старейшина

    Joined:
    19 Feb 2008
    Messages:
    454
    Likes Received:
    73
    Reputations:
    -5
    так там такое же сервер, как и у меня, он всех клиентов в очередь ставит
     
  11. Gifts

    Gifts Green member

    Joined:
    25 Apr 2008
    Messages:
    2,494
    Likes Received:
    807
    Reputations:
    614
    Ru}{eeZ Хм, ну да, я вас обманул, помню что брал пример с php.net в свое время, но из другого топика. Вот скрипт (из комментов к функции socket_select)

    PHP:
    #!/usr/local/bin/php
    <?php

        $port 
    9050;
       
        
    // create a streaming socket, of type TCP/IP
        
    $sock socket_create(AF_INETSOCK_STREAMSOL_TCP);
       
        
    // set the option to reuse the port
        
    socket_set_option($sockSOL_SOCKETSO_REUSEADDR1);
       
        
    // "bind" the socket to the address to "localhost", on port $port
        // so this means that all connections on this port are now our resposibility to send/recv data, disconnect, etc..
        
    socket_bind($sock0$port);
       
        
    // start listen for connections
        
    socket_listen($sock);

        
    // create a list of all the clients that will be connected to us..
        // add the listening socket to this list
        
    $clients = array($sock);
       
        while (
    true) {
            
    // create a copy, so $clients doesn't get modified by socket_select()
            
    $read $clients;
           
            
    // get a list of all the clients that have data to be read from
            // if there are no clients with data, go to next iteration
            
    if (socket_select($read$write NULL$except NULL0) < 1)
                continue;
           
            
    // check if there is a client trying to connect
            
    if (in_array($sock$read)) {
                
    // accept the client, and add him to the $clients array
                
    $clients[] = $newsock socket_accept($sock);
               
                
    // send the client a welcome message
                
    socket_write($newsock"no noobs, but ill make an exception :)\n".
                
    "There are ".(count($clients) - 1)." client(s) connected to the server\n");
               
                
    socket_getpeername($newsock$ip);
                echo 
    "New client connected: {$ip}\n";
               
                
    // remove the listening socket from the clients-with-data array
                
    $key array_search($sock$read);
                unset(
    $read[$key]);
            }
           
            
    // loop through all the clients that have data to read from
            
    foreach ($read as $read_sock) {
                
    // read until newline or 1024 bytes
                // socket_read while show errors when the client is disconnected, so silence the error messages
                
    $data = @socket_read($read_sock1024PHP_NORMAL_READ);
               
                
    // check if the client is disconnected
                
    if ($data === false) {
                    
    // remove client for $clients array
                    
    $key array_search($read_sock$clients);
                    unset(
    $clients[$key]);
                    echo 
    "client disconnected.\n";
                    
    // continue to the next client to read from, if any
                    
    continue;
                }
               
                
    // trim off the trailing/beginning white spaces
                
    $data trim($data);
               
                
    // check if there is any data after trimming off the spaces
                
    if (!empty($data)) {
               
                    
    // send this to all the clients in the $clients array (except the first one, which is a listening socket)
                    
    foreach ($clients as $send_sock) {
                   
                        
    // if its the listening sock or the client that we got the message from, go to the next one in the list
                        
    if ($send_sock == $sock || $send_sock == $read_sock)
                            continue;
                       
                        
    // write the message to the client -- add a newline character to the end of the message
                        
    socket_write($send_sock$data."\n");
                       
                    } 
    // end of broadcast foreach
                   
                
    }
               
            } 
    // end of reading foreach
        
    }

        
    // close the listening socket
        
    socket_close($sock);
    ?>
     
    _________________________