src/Chat/ServerWebSocket.php line 13

Open in your IDE?
  1. <?php
  2. namespace App\Chat;
  5. use App\Chat\Chat;
  6. use Ratchet\Http\HttpServer;
  7. use Ratchet\Server\IoServer;
  8. use Ratchet\WebSocket\WsServer;
  9. use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
  10. use Symfony\Component\Console\Input\InputInterface;
  11. use Symfony\Component\Console\Output\OutputInterface;
  13. class ServerWebSocket extends ContainerAwareCommand
  14. {
  16.     /**
  17.      * Configure a new Command Line
  18.      */
  19.     protected function configure()
  20.     {
  21.         $this
  22.             ->setName('Project:websocket:server')
  23.             ->setDescription('Start the websocket server.');
  24.     }
  26.     protected function execute(InputInterface $input, OutputInterface $output)
  27.     {
  29.        // date_default_timezone_set("America/New_York");
  30.         header("Content-Type: text/event-stream\n\n");
  31.         
  32.         $counter = rand(1, 10);
  33.         while (1) {
  34.           // Chaque seconde, envoi d’un évènement "ping".
  35.         
  36.           echo "event: ping\n";
  37.           $curDate = date(DATE_ISO8601);
  38.           echo 'data: {"time": "' . $curDate . '"}';
  39.           // Paire de sauts de ligne
  40.           echo "\n\n";
  41.         
  42.           // Envoie un message simple à des intervalles aléatoires.
  43.         
  44.           $counter--;
  45.         
  46.           if (!$counter) {
  47.             echo 'data: This is a message at time ' . $curDate . "\n\n";
  48.             $counter = rand(1, 10);
  49.           }
  50.         
  51.           ob_end_flush();
  52.           flush();
  53.           sleep(1);
  54.         }
  56.     }
  58. }