香雨站

 找回密码
 立即注册
搜索
热搜: 活动 交友 discuz
查看: 68|回复: 0

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

[复制链接]

2

主题

3

帖子

7

积分

新手上路

Rank: 1

积分
7
发表于 2023-6-2 15:49:02 | 显示全部楼层 |阅读模式
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
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

Archiver|手机版|小黑屋|香雨站

GMT+8, 2025-3-15 02:40 , Processed in 0.091065 second(s), 18 queries .

Powered by Discuz! X3.4

© 2001-2013 Comsenz Inc.. 技术支持 by 巅峰设计

快速回复 返回顶部 返回列表