PHP实现tail命令并推送给websocket服务

小古

php守护进程,获取最新添加的文件内容,推送给服务
composer require textalk/websocket
<?php
require('vendor/autoload.php');

use WebSocket\Client;

if(3 > count($argv)){
    fwrite(
        STDERR,
        '调用格式错误！使用格式 "tail.php 文件路径 服务地址 -d"'.PHP_EOL
    );  
    return 1;
}

define("MAX_SHOW", 8192);

$file_name      = $argv[1];
$server      = $argv[2];

if(isset($argv[3])&&$argv[3]=='-d'){
    umask(0);
    if (pcntl_fork() != 0){
            exit();
    }      
    if (pcntl_fork() != 0){
            exit();
    }      
    chdir("/");
}

$file_size      = 0;
$file_size_new  = 0;
$add_size       = 0;
$ignore_size    = 0;
$sendData='';
$ss = exec('/sbin/ifconfig eth0 | sed -n \'s/^ *.*addr:\\([0-9.]\\{7,\\}\\) .*$/\\1/p\'',$arr);      
$ip=$arr[0];
if(!file_exists($file_name)){
    //echo "{$file_name} not exist".PHP_EOL;
    return 1;
}
$fp = fopen($file_name, "r");
$client = new Client("ws://".$server);
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,$ignore_size,$file_size);
        }   
        $sendData.=fread($fp, $add_size);
        while(!empty($sendData)){
            try{
                $lines=explode("\n",$sendData);
                foreach($lines as $line){
                    if (!empty($line)) $client->send("[{$ip}] ".$line);
                }
                $res=$client->receive();
                if(!empty($res)) $sendData='';
                break;
            }catch(Exception $e){
                //echo "connect to {$server} failed".PHP_EOL;
                $client = new Client("ws://".$server);
                sleep(1);
            }
        }
        $file_size  = $file_size_new;
    }
    usleep(50000);
}
fclose($fp);以上内容希望帮助到大家，很多PHPer在进阶的时候总会遇到一些问题和瓶颈，业务代码写多了没有方向感，不知道该从那里入手去提升，对此我整理了一些资料，包括但不限于：分布式架构、高可扩展、高性能、高并发、服务器性能调优、TP6，laravel，YII2，Redis，Swoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、微服务、Nginx等多个知识点高级进阶干货需要的可以免费分享给大家，需要
或者关注咱们下面的专栏
来源：https://www.cnblogs.com/taoshihan/articles/12158059.html