| ... | ... | @@ -69,59 +69,59 @@ function start(){ | 
|  |  | },true); | 
|  |  |  | 
|  |  | // 启动一个同步内容的进程 | 
|  |  | $pm->add(function (Process\Pool $pool, int $worker_id){ | 
|  |  |  | 
|  |  | swoole_set_process_name('php-email-sync-body-'.$worker_id); | 
|  |  |  | 
|  |  | include_once __DIR__."/../vendor/autoload.php"; | 
|  |  |  | 
|  |  | _echo("业务进程({$worker_id})启动成功,body"); | 
|  |  | $run_timer  = time(); | 
|  |  | // 循环阻塞 | 
|  |  | while (true){ | 
|  |  | // 运行超过1天的 停止 | 
|  |  | if($run_timer < (time()-21600)){ | 
|  |  | break; | 
|  |  | } | 
|  |  | // 需要同步的id | 
|  |  | $id = redis()->lPop('sync_email_body'); | 
|  |  |  | 
|  |  | if(!$id){ | 
|  |  | co::sleep(1); | 
|  |  | }else{ | 
|  |  | // 占用当前的id,占用2小时 | 
|  |  | if(redis()->add('just_sync_body_'.$id['lists_id'],time(),600)){ | 
|  |  | // 启动一个协程 | 
|  |  | go(function () use ($id){ | 
|  |  |  | 
|  |  | // 开始同步 | 
|  |  | try { | 
|  |  | sync_body($id); | 
|  |  | }catch (\Throwable $e){ | 
|  |  | //                            _echo($e->getMessage()); | 
|  |  | logs( | 
|  |  | $e->getMessage().PHP_EOL.$e->getTraceAsString(), | 
|  |  | LOG_PATH.'/'.$id['email_id'].'.log' | 
|  |  | ); | 
|  |  | } | 
|  |  |  | 
|  |  | // 协程完成后执行的函数 | 
|  |  | co::defer(function () use ($id){ | 
|  |  | //                        _echo('正常关闭进程('.$worker_id.')下的协程('.co::getCid().')'); | 
|  |  | // 消除占用 | 
|  |  | redis()->delete('just_sync_body_'.$id['lists_id']); | 
|  |  | // 写入日志 | 
|  |  | \Lib\Log::getInstance()->write(); | 
|  |  |  | 
|  |  | }); | 
|  |  |  | 
|  |  | }); | 
|  |  | } | 
|  |  | } | 
|  |  |  | 
|  |  | } | 
|  |  |  | 
|  |  | },true); | 
|  |  | //    $pm->add(function (Process\Pool $pool, int $worker_id){ | 
|  |  | // | 
|  |  | //        swoole_set_process_name('php-email-sync-body-'.$worker_id); | 
|  |  | // | 
|  |  | //        include_once __DIR__."/../vendor/autoload.php"; | 
|  |  | // | 
|  |  | //        _echo("业务进程({$worker_id})启动成功,body"); | 
|  |  | //        $run_timer  = time(); | 
|  |  | //        // 循环阻塞 | 
|  |  | //        while (true){ | 
|  |  | //            // 运行超过1天的 停止 | 
|  |  | //            if($run_timer < (time()-21600)){ | 
|  |  | //                break; | 
|  |  | //            } | 
|  |  | //            // 需要同步的id | 
|  |  | //            $id = redis()->lPop('sync_email_body'); | 
|  |  | // | 
|  |  | //            if(!$id){ | 
|  |  | //                co::sleep(1); | 
|  |  | //            }else{ | 
|  |  | //                // 占用当前的id,占用2小时 | 
|  |  | //                if(redis()->add('just_sync_body_'.$id['lists_id'],time(),600)){ | 
|  |  | //                    // 启动一个协程 | 
|  |  | //                    go(function () use ($id){ | 
|  |  | // | 
|  |  | //                        // 开始同步 | 
|  |  | //                        try { | 
|  |  | //                            sync_body($id); | 
|  |  | //                        }catch (\Throwable $e){ | 
|  |  | ////                            _echo($e->getMessage()); | 
|  |  | //                            logs( | 
|  |  | //                                $e->getMessage().PHP_EOL.$e->getTraceAsString(), | 
|  |  | //                                LOG_PATH.'/'.$id['email_id'].'.log' | 
|  |  | //                            ); | 
|  |  | //                        } | 
|  |  | // | 
|  |  | //                        // 协程完成后执行的函数 | 
|  |  | //                        co::defer(function () use ($id){ | 
|  |  | ////                        _echo('正常关闭进程('.$worker_id.')下的协程('.co::getCid().')'); | 
|  |  | //                            // 消除占用 | 
|  |  | //                            redis()->delete('just_sync_body_'.$id['lists_id']); | 
|  |  | //                            // 写入日志 | 
|  |  | //                            \Lib\Log::getInstance()->write(); | 
|  |  | // | 
|  |  | //                        }); | 
|  |  | // | 
|  |  | //                    }); | 
|  |  | //                } | 
|  |  | //            } | 
|  |  | // | 
|  |  | //        } | 
|  |  | // | 
|  |  | //    },true); | 
|  |  |  | 
|  |  | // 启动管理器 | 
|  |  | $pm->start(); | 
... | ... |  |