首先要使用composer來下載一個第三方擴展就可以實現php的websocket客戶端,直接在當前目錄生成下composer.json文件就可以了。

composer require textalk/websocket

require('vendor/autoload.php'); use WebSocketClient; $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 <?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);

服務端的代碼使用swoole作為服務端,并且在收到消息后給所有的連接廣播,執行服務端

<?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();

執行客戶端

可以在瀏覽器直接實時輸出

以上內容希望幫助到大家，很多PHPer在進階的時候總會遇到一些問題和瓶頸，業務代碼寫多了沒有方向感，不知道該從那里入手去提升，對此我整理了一些資料，包括但不限于：分布式架構、高可擴展、高性能、高并發、服務器性能調優、TP6，laravel，YII2，Redis，Swoole、Swoft、Kafka、Mysql優化、shell腳本、Docker、微服務、Nginx等多個知識點高級進階干貨需要的可以免費分享給大家，需要

PHP進階架構師>>>視頻、面試文檔免費獲取?shimo.im

或 者關注咱們下面的知乎專欄

PHP架構師圈子?zhuanlan.zhihu.com 與50位技術專家面對面20年技術見證，附贈技術全景圖

總結

以上是生活随笔為你收集整理的日志读取_php作为websocket的客户端实时读取推送日志文件的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。