commit | author | age
|
39aea3
|
1 |
<?php |
FÁ |
2 |
require './vendor/autoload.php'; |
|
3 |
|
|
4 |
$loop = React\EventLoop\Factory::create(); |
|
5 |
$pusher = new WS\Pusher; |
|
6 |
$client = new Predis\Async\Client('tcp://127.0.0.1:6379', $loop); |
|
7 |
|
|
8 |
$client->connect(function ($client) use ($pusher) { |
|
9 |
/** @var Predis\Async\Client $client */ |
|
10 |
$client->pubSubLoop('overlay', function ($event, $pubsub) use ($pusher) { |
|
11 |
$pusher->broadcast($event->payload); |
|
12 |
var_dump($event->payload); |
|
13 |
}); |
|
14 |
}); |
|
15 |
|
|
16 |
if (!$client->isConnected()) |
|
17 |
{ |
|
18 |
die("Fatal error: TCP connection to redis-server is closed\n"); |
|
19 |
} |
|
20 |
|
|
21 |
$webSock = new React\Socket\Server('127.0.0.1:8000', $loop); |
|
22 |
$webServer = new Ratchet\Server\IoServer( |
|
23 |
new \Ratchet\Http\HttpServer( |
|
24 |
new \Ratchet\WebSocket\WsServer( |
|
25 |
$pusher |
|
26 |
) |
|
27 |
), $webSock); |
|
28 |
|
|
29 |
$loop->run(); |