require('vendor/autoload.php');
use WebSocketClient;
$client = new Client("ws://echo.websocket.org/");
$client->send("Hello WebSocket.org!");
echo $client->receive();

#!/usr/bin/env php
<?php
require('vendor/autoload.php');use WebSocketClient;if(2 != count($argv)){fwrite(STDERR,"调用格式错误！使用格式 ./xxx filename".PHP_EOL);  return 1;
}$file_name      = $argv[1];
define("MAX_SHOW", 8192);$file_size      = 0;
$file_size_new  = 0;
$add_size       = 0;
$ignore_size    = 0;
$fp = fopen($file_name, "r");
$client = new Client("ws://10.xx.2.xx:9501/");
while(1){clearstatcache();$file_size_new  = filesize($file_name);$add_size       = $file_size_new - $file_size;if($add_size > 0){ if($add_size > MAX_SHOW){$ignore_size    = $add_size - MAX_SHOW;$add_size       = MAX_SHOW;fseek($fp, $file_size + $ignore_size);}   //直接输出内容// fwrite(//     STDOUT,//     fread($fp, $add_size)// );  $client->send(fread($fp, $add_size));$file_size  = $file_size_new;}usleep(50000);
}fclose($fp);

<?php
$server = new SwooleWebSocketServer("0.0.0.0", 9501);
$server->on('open', function (SwooleWebSocketServer $server, $request)use($fds) {echo "server: handshake success with fd{$request->fd}n";
});$server->on('message', function (SwooleWebSocketServer $server, $frame)use($fds) {echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}n";foreach($server->connections as $fd){$server->push($fd, $frame->data);}
});$server->on('close', function ($ser, $fd) {echo "client {$fd} closedn";
});$server->start();