fork download
copy 
  1. <?php
  2.  
  3. if ( !$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) ) {
  4.     throw new Exception('socket_create failed: ' . socket_strerror(socket_last_error()) );
  5. }
  6. if (!$sb = socket_bind($server, '0.0.0.0', 8081) ) {
  7.     throw new Exception('socket_bind failed: ' . socket_strerror(socket_last_error()) );
  8. }
  9. if (!$sl = socket_listen($server, 128)) {
  10.     throw new Exception('socket_listen failed: ' . socket_strerror(socket_last_error()));
  11. }
  12.  
  13. $read = array($server);
  14. $write = $except = $clients = $readBuffer = $writeBuffer = array();
  15.  
  16. while (true) {
  17.     socket_select($read, $write, $except, null);
  18.     if (in_array($server, $read)) {
  19.         if ( ($conn = socket_accept($server)) < 0 ) {
  20.             throw new Exception('socket_accept() failed: '
  21.                 . socket_strerror(socket_last_error()) );
  22.         }
  23.         socket_set_nonblock($conn);
  24.         $clients[intval($conn)] = $conn;
  25.         $readBuffer[intval($conn)] = "";
  26.         $writeBuffer[intval($conn)] = 0;
  27.     }
  28.     foreach ($read as $r) {
  29.         if ($r == $server) continue;
  30.         if (false === ($data = socket_read($r, 1024)) ) {
  31.             /*throw new Exception( 'socket_read failed: '
  32.                 . socket_strerror(socket_last_error()) );*/
  33.             /* То ли клиент отсоединился, то ли ошибка */
  34.             unset(
  35.                 $readBuffer[intval($r)],
  36.                 $writeBuffer[intval($r)],
  37.                 $clients[intval($r)]
  38.             );
  39.         } elseif (feof($r)) {
  40.             foreach ($clients as $client) {
  41.                 if ($client === $r) continue;
  42.                 $written = socket_write($client, "user " . intval($r) . ": "
  43.                     . substr($readBuffer[intval($r)], $writeBuffer[intval($client)]) );
  44.                 $writeBuffer[intval($client)] += $written;
  45.             }
  46.         } else {
  47.             $readBuffer[intval($r)] .= $data;
  48.         }
  49.     }
  50.     $read = $clients;
  51.     $write = $clients;
  52.     $read[] = $server;
  53. }
Time limit exceeded #stdin #stdout 5s 61632KB
comments (?)
stdin
copy 
Standard input is empty
stdout
copy 
Standard output is empty
https://ideone.com/tCDrGE
language:
PHP (php 7.3.5)
created:
9 years ago
visibility:
public

Share or Embed source code

Discover > Sphere Engine API

The brand new service which powers Ideone!

Discover > IDE Widget

Widget for compiling and running the source code in a web browser!