問題描述

需要3秒請求一次 API接口，不管3秒內(nèi)是否請求到，必須在上一次請求的3秒后再次發(fā)出請求。

理想結(jié)果

第1次請求--------2024-06-03 01:32:28
第2次請求--------2024-06-03 01:32:31
第3次請求--------2024-06-03 01:32:34
第4次請求--------2024-06-03 01:32:37
。
。
。

為此你搜索到了哪些方案及不適用的原因

目前使用的是Crontab結(jié)合異步請求。
疑問：請問大佬們，這種方案會出現(xiàn)什么異常，如：連接過多或者跑滿內(nèi)存等問題？

代碼1如下

<?php
use Workerman\Worker;
require __DIR__ . '/vendor/autoload.php';

use Workerman\Crontab\Crontab;
$worker = new Worker();

// 設(shè)置時區(qū)，避免運行結(jié)果與預期不一致
date_default_timezone_set('PRC');

$worker->onWorkerStart = function () {
    // 每分鐘的第1秒執(zhí)行.
    $http = new Workerman\Http\Client();

    new Crontab('*/3 * * * * *', function() use ($http){
        $http->request('http://www.wtbis.cn', [
            'method' => 'POST',
            'version' => '1.1',
            'headers' => ['content-type' => 'application/json','Connection' => 'keep-alive'],
            'data' => json_encode(['detail' => true]),
            'success' => function ($response) {
                $result = $response->getBody();
                $result = json_decode($response->getBody(),true);
                    echo date('Y-m-d H:i:s')."\n";
            },
            'error' => function ($exception) {
                echo $exception;
            }
        ]);
    });
};

Worker::runAll();

代碼2如下

<?php
use Workerman\Worker;
use Workerman\Timer;
require_once __DIR__ . '/vendor/autoload.php';

//發(fā)送請求
function request($http)
{

    $http->request('http://www.wtbis.cn/', [
            'method' => 'POST',
            'version' => '1.1',
            'headers' => ['content-type' => 'application/json','Connection' => 'keep-alive'],
            'data' => json_encode(['detail' => true]),
            'success' => function ($response) {
                $result = $response->getBody();
                $result = json_decode($response->getBody(),true);
            },
            'error' => function ($exception) {
                echo $exception;
            }
        ]);
}

$task = new Worker();
// 開啟多少個進程運行定時任務，注意業(yè)務是否在多進程有并發(fā)問題
$task->count = 1;
$task->onWorkerStart = function(Worker $task)
{
    $http = new Workerman\Http\Client();
    Timer::add(3, 'request',[$http],true);
};

// 運行worker
Worker::runAll();