同步

@@ -4,37 +4,58 @@
 
 use Swoole\Process;
 
-include_once __DIR__."/../vendor/autoload.php";
-swoole_set_process_name('php-email-sync-list');
+
 
 function start(){
-    // 需要同步的id
-    $id = redis()->lPop('sync_email_lists');
-
-    if($id && is_numeric($id)){
-        // 占用当前的id,占用2小时
-        if(redis()->add('just_sync_'.$id,time(),600)){
-            go(function () use ($id){
-                echo \Swlib\SaberGM::get('http://mail-serve.hagro.cn/v3/sync?id='.$id,['timeout'=>60])->getBody()->getContents();
-            });
+
+// 删除停止运行的值
+//    redis()->delete(SYNC_RUNNING_REDIS_KEY,'email_sync_stop_num');
+
+    // 进程管理器
+    $pm = new Process\Manager();
+
+    // 启动业务进程
+    $pm->addBatch(10,function (Process\Pool $pool, int $worker_id){
+
+        swoole_set_process_name('php-email-sync-list-'.$worker_id);
+
+        include_once __DIR__."/../vendor/autoload.php";
+        _echo("业务进程（{$worker_id}）启动成功");
+
+        // 循环阻塞
+        while (true){
+
+            // 需要同步的id
+            $id = redis()->lPop('sync_email_lists');
+
+            if($id && is_numeric($id)){
+                // 占用当前的id,占用2小时
+                if(redis()->add('just_sync_'.$id,time(),600)){
+                    // 启动一个协程
+                    go(function () use ($id){
+                        echo file_get_contents('http://mail-serve.hagro.cn/v3/sync?id='.$id);
+                    });
+
+                }
+            }else{
+                co::sleep(1);
+            }
+            //每次都暂停1秒，防止同一时间启动太多的任务
+            co::sleep(0.5);
         }
-    }else{
-        co::sleep(1);
-    }
-    //每次都暂停1秒，防止同一时间启动太多的任务
-    co::sleep(0.5);
+
+    },true);
+
+
+    // 启动管理器
+    $pm->start();
 
 }
 
 
 
-\Co\run(function (){
-    // 循环阻塞
-    while (true) {
-        start();
-    }
-});
 
+start();
 
 
 

@@ -35,7 +35,6 @@ class Home extends Base {
      * @time 2023/8/2 16:19
      */
     public function sync(){
-        header("content-type:text/html; charset=utf-8");
         $id = app()->request('id');
         if($id && is_numeric($id)){
             (new SyncMail($id))->sync();