看socket 好多东西不明白
网上下了个html5 发socket 给php.server
php.server里面有些地方不明白呀
部分代码
function __construct ($address, $port) {
error_reporting (E_ALL);
set_time_limit (0);
ob_implicit_flush ();
// Socket creation
$this->master = socket_create (AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create() failed");
socket_set_option ($this->master, SOL_SOCKET, SO_REUSEADDR, 1) or die("socket_option() failed");
socket_bind ($this->master, $address, $port) or die("socket_bind() failed");
socket_listen ($this->master, 20) or die("socket_listen() failed");
$this->sockets[] = $this->master;
$this->say ("Server Started : " . date ('Y-m-d H:i:s'));
$this->say ("Listening on : {$address} {$port}");
$this->say ("Master socket : {$this->master}\n");
// Main loop
while (true) {
$changed = $this->sockets;
socket_select ($changed, $write = NULL, $except = NULL, NULL);
foreach ($changed as $socket) {
if ($socket == $this->master) {
$client = socket_accept ($this->master);
if ($client < 0) {
$this->log ("socket_accept() failed");
continue;
}
else {
// Connects the socket
$this->connect ($client);
}
}
else {
$bytes = @socket_recv ($socket, $buffer, 2048, 0);
if ($bytes == 0) {
// On socket.close ();
$this->disconnect ($socket);
}
else {
// Retrieve the user from his socket
$user = $this->getuserbysocket ($socket);
if (!$user->handshake) {
$this->dohandshake ($user, $buffer);
}
else {
$this->process ($user, $this->decode ($buffer));
}
}
}
}
}
}
socket_accept()是阻塞型的,当出现新的连接,这个函数才会结束。
程序至所以这么写,是为了改善现有的这种阻塞式机制。想想看,如果没有新连接,socket_accept()将永远不会结束。而如果用 socket_select()限时监听,程序就可以腾出空去做其它事