fork download 
  1. <?php
  2.  
  3. if ( !$s = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) ) {
  4.     throw new Exception('socket_create failed: ' . socket_strerror(socket_last_error()) );
  5. }
  6.  
  7. // $ip = gethostbyname('ya.ru');
  8. $ip = '127.0.0.1';
  9. $port = 8123;
  10. $useNoBlock = in_array('--no-block', $argv);
  11. $isFailtTest = in_array('--fail', $argv);
  12.  
  13. if ($isFailtTest) {
  14.     $ip = gethostbyname('ya.ru');
  15.     $port = 80;
  16.     echo "Please disconnect LAN after connect\n";
  17. }
  18.  
  19. echo "Connect to $ip:$port\n";
  20.  
  21. if ($useNoBlock) {
  22.     socket_set_nonblock($s);
  23. }
  24.  
  25. if ( !socket_connect($s, $ip, $port) ) {
  26.     if (!canIgnoreError($useNoBlock)) {
  27.         throw new Exception('failed: ' . socket_strerror(socket_last_error()) );
  28.     } else {
  29.         printf("connect: Ignore error %s\n", socket_last_error());
  30.     }
  31. }
  32.  
  33. while (true) {
  34.  
  35.     if ($useNoBlock) {
  36.         waitFor($s);
  37.     }
  38.  
  39.     usleep(100000);
  40.  
  41.     $data = socket_read($s, 1000);
  42.     if ($data === false) {
  43.         if (!canIgnoreError($useNoBlock)) {
  44.             throw new \Exception("read: " . socket_strerror(socket_last_error()));
  45.         } else {
  46.             echo "read: Ignore error " . socket_last_error() . "\n";
  47.             continue;
  48.         }
  49.     }
  50.     printf("Read %d bytes\n", strlen($data));
  51.     echo "> " . $data . "\n";
  52. }
  53.  
  54. echo "EOF or error\n";
  55. exit;
  56.  
  57. function waitFor($s)
  58. {
  59.     $read = [$s];
  60.     $write = [$s];
  61.     $except = [$s];
  62.  
  63.     echo "Wait ...\n";
  64.     $r = socket_select($read, $write, $except, null);
  65.     assert($r !== false);
  66.     if ($read) {
  67.         echo "Read event\n";
  68.     }
  69.     if ($write) {
  70.         echo "Write event\n";
  71.     }
  72.     if ($except) {
  73.         echo "Except event\n";
  74.     }
  75. }
  76.  
  77. /**
  78.  * Можно ли игнорировать ошибку вроде SOCKET_EWOULDBLOCK
  79.  */
  80. function canIgnoreError($useNoBlock)
  81. {
  82.     if (!$useNoBlock) {
  83.         return;
  84.     }    
  85.  
  86.     $e = socket_last_error();
  87.     if (defined('SOCKET_EAGAIN') && $e == SOCKET_EAGAIN) {
  88.         return true;
  89.     }
  90.  
  91.     return in_array($e, [SOCKET_EWOULDBLOCK, SOCKET_EINPROGRESS]);
  92. }
  93.  
  94.  
  95.  
  96.  
Runtime error #stdin #stdout #stderr 0.02s 52472KB
comments (?)
stdin 
Standard input is empty
stdout 
Connect to 127.0.0.1:8123
stderr 
PHP Warning:  socket_connect(): unable to connect [101]: Network is unreachable in /home/Uy7Ovi/prog.php on line 25
PHP Fatal error:  Uncaught exception 'Exception' with message 'failed: Network is unreachable' in /home/Uy7Ovi/prog.php:27
Stack trace:
#0 {main}
  thrown in /home/Uy7Ovi/prog.php on line 27
https://ideone.com/83LJxm
language:
PHP (php 7.3.5)
created:
8 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!