while($conn = stream_socket_accept($socket)) {
while (strlen($data=fread($conn,1024)) > 0) {
$result .= $data;
}
fclose($conn);
$save=new Db($result);
fclose($socket);
}$socket = stream_socket_server("tcp://localhost:15689", $errno, $errstr);
stream_set_blocking($socket,0);
stream_set_timeout($socket,0);
set_time_limit(0);
if (!$socket) {
echo "$errstr ($errno)<br />\n";
} else {
while ($conn = stream_socket_accept($socket)) {
$data=fread($conn,1024);
$save=new Db($data);
fclose($conn);
}
fclose($socket);
}
class Db{
public $host;
public $root;
public $password;
public $database;
public $data;
public function __construct($data)
{
$this->data=$data;
$this->host='localhost';
$this->root='root';
$this->password='12345';
$this->database = 'db';
$this->connect();
}
public function connect(){
$link=mysqli_connect($this->host, $this->root, $this->password, $this->database)
or die("Ошибка " . mysqli_error($link));
$this->insert($link);
}
public function insert($link){
$sql = mysqli_query($link,"INSERT INTO `time_load` (`text`) VALUES ('$this->data')");
$this->closeConnection($link);
}
public function closeConnection($link){
mysqli_close($link);
}
}
var socket = new WebSocket('ws://localhost:8080');//помните про порт: он должен совпадать с тем, который использовался при запуске серверной части
socket.onopen = function(e) {
socket.send('{"idUser":'+yiiConfig["idUser"]+'}'); //часть моего кода. Сюда вставлять любой валидный json.
};
socket.onmessage = function(e) {
console.log(e.data);
};