sync_my.php 1.6 KB
<?php




class SyncEmailMy{

    static $maxGo = 0;

    public static function sync(){
        while (1){

//            if(self::$maxGo >= 50){
//                co::sleep(1);
//                continue;
//            }

            $id = redis()->lPop('sync_email_lists_my');
            // _echo('读取到'.$id);
            if($id && is_numeric($id)){
                // 占用当前的id,占用2小时
                if(redis()->add('just_sync_'.$id,time(),600)){

                    self::go($id);

                }
//                co::sleep(0.2);
            }else{
                sleep(1);
            }

        }
    }

    public static function go($id){
//        go(function ($id){
//            self::$maxGo++;
            try{
                // 开始同步
                (new \Service\SyncMail($id))->isUidAfter(2)->sync();
            }catch (Throwable $e){
                _echo($e->getMessage());
            }

//            co::defer(function () use ($id){
//                self::$maxGo--;
                // 30秒后 消除占用
                redis()->expire('just_sync_'.$id,30);

                \Lib\Log::getInstance()->write();

//                db()->close();
//            });
//        },$id);
    }

}


// 进程管理器
$pm = new \Swoole\Process\Manager();

// 启动业务进程
$pm->addBatch(100,function (\Swoole\Process\Pool $pool, int $worker_id){
    //error_reporting();
    include_once __DIR__."/../vendor/autoload.php";

    _echo('子进程重新启动了==>'.$worker_id);

    \Lib\DbPool::$clientNumber = 60;

    SyncEmailMy::sync();

},false);

$pm->start();