首先要使用composer來下載一個第三方擴展就可以實作php的websocket客戶端,直接在當前目錄生成下composer.json檔案就可以了
composer require textalk/websocket
require('vendor/autoload.php');use WebSocket\Client;$client = new Client("ws://echo.websocket.org/");$client->send("Hello WebSocket.org!");echo $client->receive();
配合php的讀取檔案操作,只讀取最新的追加的內容,下面代碼為讀取日志的客戶端 , 發送給10.xx.2.xx:9501
#!/usr/bin/env php <?phprequire('vendor/autoload.php');use WebSocket\Client;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);
服務端的代碼使用swoole作為服務端,并且在收到訊息后給所有的連接廣播,執行服務端
<?php$server = new Swoole\WebSocket\Server("0.0.0.0", 9501);$server->on('open', function (Swoole\WebSocket\Server $server, $request)use($fds) { echo "server: handshake success with fd{$request->fd}\n";});$server->on('message', function (Swoole\WebSocket\Server $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} closed\n";});$server->start();
執行客戶端
可以在瀏覽器直接實時輸出
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/88069.html
標籤：PHP
下一篇：PHP 跨域之header