[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('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();

 

 

 

執行客戶端

 

 

 能夠在瀏覽器直接實時輸出