生产者a.php

//先存入到队列，然后用后台任务保存数据
if (true) {
    $data = [
        'table' => 't_startup',
        'data' => $table,
    ];
    require_once 'func/Redis.php';
    $redis = Redis::getInstance('tcp://127.0.0.1:6379');
    $client = $redis->client();
    $result = $client->lpush('list_sdk_insert', json_encode($data));
    if (!$result) {
        //插入队列失败业务处理
    }
}

消费者server.php

<?php
/**
 * 后台任务：从队列中取数据，插入mysql
 */
set_time_limit(0);

function load($param)
{
    require_once 'func/Redis.php';
    $redis = Redis::getInstance('tcp://127.0.0.1:6379');
    $client = $redis->client();

    $key = 'list_sdk_insert';
    $i = 0;
    
    while (true) {
        $i++;
        if ($i % 30 == 0) {
            sleep(0.5);
        }

        $str = $client->rpop($key);
        if ($str) {
            $obj = json_decode($str);
            $table = $obj->table;
            $data = $obj->data;
            $bus = new \ZXUN\Data\DataTable($table);
            $result = $bus->Add($data);
            if (!$result) {
                //插入失败的业务，表未定
            }
        } else {
            sleep(0.5);
        }
    }
    exit();

}