[PHP] php作为websocket的客户端实时读取推送日志文件

首先要使用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 
<?PHP
require();

use WebSocket\Client;

if(2 != count($argv)){
    fwrite(
        STDERR,调用格式错误！使用格式 ./xxx filename.PHP_EOL
    );  
    return 1;
}

$file_name      = $argv[];
define(MAX_SHOW",8192);

$file_size      = 0;
$file_size_new  = ;
$add_size       = ;
$ignore_size    = ;
$fp = fopen($file_name,1)">r);
$client = new Client(ws://10.xx.2.xx:9501/while(){
    clearstatcache();
    $file_size_new  = filesize($file_name);
    $add_size       = $file_size_new - $file_size;
    if($add_size > ){ 
        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,1)">$request)use($fds) {
    echo "server: handshake success with fd{$request->fd}\n";
});

$server->on('message',1)">$frame)echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
    foreach($server->connections as $fd){
        $server->push($fd,1)">$frame->data);
    }
});

$server->on('close',1)">function ($ser,1)">echo "client {$fd} closed\n"$server->start();

执行客户端

可以在浏览器直接实时输出

[PHP] php作为websocket的客户端实时读取推送日志文件

猜你在找的PHP相关文章