foreach ($sockets as $socket) {
if ($socket == $this->master) {
socket_accept($this->master);
self::connect($client);
continue;
}
} else {
$bytes = @socket_recv($socket, $buffer, 2048, 0);
if ($bytes < 9) {
$recv_msg = $this->disconnect($socket);
} else {
// 如果此客户端还未握手,执行握手逻辑
if (!$this->sockets[(int)$socket]['handshake']) {
self::handShake($socket, $buffer);
continue;
} else {
$recv_msg = self::parse($buffer);
}
}
$this->broadcast($msg);
}
}
}