-
Notifications
You must be signed in to change notification settings - Fork 1
/
startWSS.php
54 lines (45 loc) · 1.55 KB
/
startWSS.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
<?
//Ratchet Chat WSS server
use ChessServer\Socket;
use Ratchet\Http\HttpServer;
use Ratchet\Server\IoServer;
use Ratchet\WebSocket\WsServer;
use React\EventLoop\Factory;
use React\Socket\Server;
use React\Socket\SecureServer;
use MyApp\Desc;
use MyApp\MySQL;
use MyApp\Init;
require 'vendor/autoload.php';
$loop = Factory::create();
$server = new Server('0.0.0.0:2040', $loop);
$secureServer = new SecureServer($server, $loop, [
'local_cert' => '/url.crt',
'local_pk' => '/url.key',
'verify_peer' => false,
]);
$socket = new Desc();
$httpServer = new HttpServer(new WsServer( $socket ));
$ioServer = new IoServer($httpServer, $secureServer, $loop);
//When the wss connection is active, start a timer to check and send commands to the station
$ioServer->loop->addPeriodicTimer(5, function () use ($socket)
{
foreach($socket->clients as $client)
{
$init = new Init();
$send = $init->SetCommand($socket->ReturnidTag($client));
if($send)
{
if ($send['idTag'] === $socket->ReturnidTag($client))
{
$init->UpUserCommand($socket->ReturnidTag($client), $send['user_id']);
echo 'CS - user_id - '.$send['user_id'].' - '.$socket->ReturnidTag($client).' '.date('H:i:s').' '.$send['text'].PHP_EOL.PHP_EOL;
//$socket->onMessageTimer($client, $send['text']);
$client->send($send['text']);
$init->up_command($send['text'], $socket->ReturnidTag($client));
}
}
}
});
//When the wss connection is active, start a timer to check and send commands to the station
$ioServer->run();