php异步加载

// 示例代码：使用Redis队列管理异步任务
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

function enqueueTask($task) {
    global $redis;
    $redis->lPush('task_queue', json_encode($task));
}

function dequeueTask() {
    global $redis;
    return json_decode($redis->rPop('task_queue'), true);
}

// 生产者代码
enqueueTask(['type' => 'email', 'data' => ['to' => 'user@example.com', 'subject' => 'Hello']]);

// 消费者代码
while (true) {
    $task = dequeueTask();
    if ($task) {
        // 处理任务
        echo "Processing task: " . print_r($task, true) . "\n";
    } else {
        sleep(1); // 没有任务时休眠
    }
}

// 示例代码：使用Promise处理异步任务并捕获错误
function asyncTask() {
    return new Promise((resolve, reject) => {
        // 模拟异步操作
        setTimeout(() => {
            if (rand(0, 1)) {
                resolve('Task completed successfully');
            } else {
                reject(new Exception('Task failed'));
            }
        }, 1000);
    });
}

asyncTask()
    .then(result => {
        echo $result . "\n";
    })
    .catch(error => {
        echo 'Error: ' . $error->getMessage() . "\n";
        // 重试逻辑
        asyncTask().then(result => {
            echo $result . "\n";
        }).catch(error => {
            echo 'Retry failed: ' . $error->getMessage() . "\n";
        });
    });