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

[Ru}{eeZ]

Помогите разобраться с многопоточностью в 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';
?>

прошу непонимающих не лезть со ссылками

[Ctacok]

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;
"!help" под '', у меня вызывает краш.
"Всё самое сложное, самое простое" - (c) HZ.
Проверь корректность всего кода.

[Ru}{eeZ]

"!help" под '', у меня вызывает краш.
"Всё самое сложное, самое простое" - (c) HZ.
Проверь корректность всего кода.

я не просил проверять код, сервер написан под одного клиента, а нужно, чтобы его могли использовать несколько человек сразу.
Зачем лезть (в данном случае флудить), если не разбираешься? (вопрос, не нуждающийся в ответе)

[FireFenix]

я не просил проверять код, сервер написан под одного клиента, а нужно, чтобы его могли использовать несколько человек сразу.
Зачем лезть (в данном случае флудить), если не разбираешься? (вопрос, не нуждающийся в ответе)
http://php.net/manual/en/ref.pcntl.php
http://habrahabr.ru/blogs/php/40245/ - пример с сокетами

[diehard]

блин подобная тема поднимается на форуме каждые несколько месяцев, ТС пользуйся поиском

[Gifts]

Ru}{eeZ http://ru2.php.net/manual/ru/sockets.examples.php - пример из мануала, нумер 1, ретранслирует текст, принимает команды.

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

[nerezus]

НАхрена это делать на пхп? о_О

[scrat]

php не тот язык для реализации конкретной задачи.

[DDoSька]

ТОже самое сказал ему в асике, я бы препочёл PERL для этой задачи

[Ru}{eeZ]

Ru}{eeZ http://ru2.php.net/manual/ru/sockets.examples.php - пример из мануала, нумер 1, ретранслирует текст, принимает команды.

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

так там такое же сервер, как и у меня, он всех клиентов в очередь ставит

[Gifts]

Ru}{eeZ Хм, ну да, я вас обманул, помню что брал пример с php.net в свое время, но из другого топика. Вот скрипт (из комментов к функции socket_select)

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

$port = 9050;

// create a streaming socket, of type TCP/IP
$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

// set the option to reuse the port
socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);

// "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($sock, 0, $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 = NULL, 0) < 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_sock, 1024, PHP_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);
?>