| 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(); | |
