0

我制作了一个 cron 文件，它异步调用不同的作业，并最终调用了 sleeper 异步。sleeper 休眠 1 分钟，然后异步调用 cron 脚本等。

但我想重建系统以将最后一个“文件指针”存储在文件中，并稍后使用它来停止进程。那是可以制造的吗？

代码示例：

卧铺.php

sleep(60);
call($_SERVER['HTTP_HOST'], dirname($_SERVER['REQUEST_URI']).'/cron.php', ( DEBUG ? 'write_log' : '' ) );

cron.php

foreach ($jobs as $job)
{
    $job = parse_url($job);
    call(dispatch_generic_job($job['port'], $job['path'], $job['port'], ( LOG_JOBS ? 'write_job' : '' ) );
}

call($_SERVER['HTTP_HOST'], dirname($_SERVER['REQUEST_URI']).'/sleeper.php', ( DEBUG ? 'write_log' : '' ) );

对象.php：

function call($server, $url, $port = 80, $log)
{
    @set_time_limit(0);

    $timeout = 10;
    $rw_timeout = 86400;
    $error_number = '';
    $error_string = '';

    $con = @fsockopen($server, $port, $error_number, $error_string, $timeout);
    if (!$con)
    {
       $log($error_string.' ('.$error_number.') Ref: '.$server.':'.$port.$url);
       return false;
    }
    $qry = 'GET '.$url.' HTTP/1.1'."\r\n";
    $qry .= 'Host: '.$server."\r\n";
    $qry .= 'User-Agent: test'."\r\n";
    $qry .= 'Connection: Close'."\r\n\r\n";

    stream_set_blocking($con, false);
    stream_set_timeout($con, $rw_timeout);
    fwrite($con, $qry);

    if ( $log )
    {
        while ( !feof($con) )
        {
            $line = fgets($con, 128);
            if ( !empty($line) )
            {
                $log('Status: '.rtrim($line).' Ref: '.$server.':'.$port.$url);
                break;
            }
        }
    }

    return True;
}

*更新*** 通常你在使用完一个持久连接后关闭它。但是因为我使用异步（stream_set_blocking）持久连接（fsockopen）而不关闭，所以脚本可以在没有父级的情况下继续每分钟循环。（Cron.php 调用 Slepper.php 调用 Cron.php 等）

我想重建我的脚本来存储最后一个“文件指针”，以便以后可以使用它来关闭持久连接。

我读了很多，但还没有找到方法。 PHP：socket_import_stream - 手册

例子：

对象.php

function call($server, $url, $port = 80, $log)
{
    ......

    $con = @fsockopen($server, $port, $error_number, $error_string, $timeout);
    if (!$con)
    {
       $log($error_string.' ('.$error_number.') Ref: '.$server.':'.$port.$url);
       return false;
    }

    file_put_contents(__DIR__.'/steam', $con); // Obviously can not be performed

    ......
}

停止.php

$lats_con = file_get_contents(__DIR__.'/steam');
fclose($lats_con);
echo 'Cron is stopped';

PHP：资源类型列表 - 手册

PHP：持久数据库连接 - 手册

4

0 回答 0