|
1
|
<?php
|
1
|
<?php
|
|
2
|
|
2
|
|
|
3
|
|
3
|
|
|
|
|
4
|
+// 进程管理器
|
|
|
|
5
|
+$pm = new \Swoole\Process\Manager();
|
|
4
|
|
6
|
|
|
|
|
7
|
+// 启动业务进程
|
|
|
|
8
|
+$pm->addBatch(5,function (\Swoole\Process\Pool $pool, int $worker_id){
|
|
|
|
9
|
+ //error_reporting();
|
|
|
|
10
|
+ include_once __DIR__."/../vendor/autoload.php";
|
|
5
|
|
11
|
|
|
6
|
-class SyncEmailMy{
|
12
|
+ _echo('子进程重新启动了==>'.$worker_id);
|
|
|
|
13
|
+ \Lib\DbPool::$clientNumber = 52;
|
|
|
|
14
|
+ \Lib\RedisPool::$clientNumber = 52;
|
|
|
|
15
|
+ while (1){
|
|
7
|
|
16
|
|
|
8
|
- static $maxGo = 0;
|
17
|
+ if(\Lib\SwGo::$runNumber >= 50){
|
|
|
|
18
|
+ co::sleep(1);
|
|
|
|
19
|
+ continue;
|
|
|
|
20
|
+ }
|
|
9
|
|
21
|
|
|
10
|
- public static function sync(){
|
|
|
|
11
|
- while (1){
|
22
|
+ $id = redis()->lPop('sync_email_lists_my');
|
|
|
|
23
|
+ // _echo('读取到'.$id);
|
|
|
|
24
|
+ if($id && is_numeric($id)){
|
|
|
|
25
|
+ // 占用当前的id,占用2小时
|
|
|
|
26
|
+ if(redis()->add('just_sync_'.$id,time(),600)){
|
|
12
|
|
27
|
|
|
13
|
-// if(self::$maxGo >= 50){
|
|
|
|
14
|
-// co::sleep(1);
|
|
|
|
15
|
-// continue;
|
|
|
|
16
|
-// }
|
28
|
+ \Lib\SwGo::start(function ($id){
|
|
17
|
|
29
|
|
|
18
|
- $id = redis()->lPop('sync_email_lists_my');
|
|
|
|
19
|
- // _echo('读取到'.$id);
|
|
|
|
20
|
- if($id && is_numeric($id)){
|
|
|
|
21
|
- // 占用当前的id,占用2小时
|
|
|
|
22
|
- if(redis()->add('just_sync_'.$id,time(),600)){
|
30
|
+ try{
|
|
|
|
31
|
+ // 开始同步
|
|
|
|
32
|
+ (new \Service\SyncMail($id))->isUidAfter(2)->sync();
|
|
|
|
33
|
+ }catch (Throwable $e){
|
|
|
|
34
|
+ _echo($e->getMessage());
|
|
|
|
35
|
+ }
|
|
23
|
|
36
|
|
|
24
|
- self::go($id);
|
37
|
+ redis()->expire('just_sync_'.$id,30);
|
|
|
|
38
|
+ },$id);
|
|
25
|
|
39
|
|
|
26
|
- }
|
|
|
|
27
|
-// co::sleep(0.2);
|
|
|
|
28
|
- }else{
|
|
|
|
29
|
- sleep(1);
|
|
|
|
30
|
}
|
40
|
}
|
|
31
|
-
|
41
|
+ co::sleep(0.2);
|
|
|
|
42
|
+ }else{
|
|
|
|
43
|
+ co::sleep(1);
|
|
32
|
}
|
44
|
}
|
|
33
|
- }
|
|
|
|
34
|
-
|
|
|
|
35
|
- public static function go($id){
|
|
|
|
36
|
-// go(function ($id){
|
|
|
|
37
|
-// self::$maxGo++;
|
|
|
|
38
|
- try{
|
|
|
|
39
|
- // 开始同步
|
|
|
|
40
|
- (new \Service\SyncMail($id))->isUidAfter(2)->sync();
|
|
|
|
41
|
- }catch (Throwable $e){
|
|
|
|
42
|
- _echo($e->getMessage());
|
|
|
|
43
|
- }
|
|
|
|
44
|
-
|
|
|
|
45
|
-// co::defer(function () use ($id){
|
|
|
|
46
|
-// self::$maxGo--;
|
|
|
|
47
|
- // 30秒后 消除占用
|
|
|
|
48
|
- redis()->expire('just_sync_'.$id,30);
|
|
|
|
49
|
-
|
|
|
|
50
|
- \Lib\Log::getInstance()->write();
|
|
|
|
51
|
|
45
|
|
|
52
|
-// db()->close();
|
|
|
|
53
|
-// });
|
|
|
|
54
|
-// },$id);
|
|
|
|
55
|
}
|
46
|
}
|
|
56
|
|
47
|
|
|
57
|
-}
|
|
|
|
58
|
-
|
|
|
|
59
|
-
|
|
|
|
60
|
-// 进程管理器
|
|
|
|
61
|
-$pm = new \Swoole\Process\Manager();
|
|
|
|
62
|
-
|
|
|
|
63
|
-// 启动业务进程
|
|
|
|
64
|
-$pm->addBatch(100,function (\Swoole\Process\Pool $pool, int $worker_id){
|
|
|
|
65
|
- //error_reporting();
|
|
|
|
66
|
- include_once __DIR__."/../vendor/autoload.php";
|
|
|
|
67
|
-
|
|
|
|
68
|
- _echo('子进程重新启动了==>'.$worker_id);
|
|
|
|
69
|
-
|
|
|
|
70
|
- \Lib\DbPool::$clientNumber = 60;
|
|
|
|
71
|
-
|
|
|
|
72
|
- SyncEmailMy::sync();
|
|
|
|
73
|
-
|
|
|
|
74
|
-},false);
|
48
|
+},true);
|
|
75
|
|
49
|
|
|
76
|
$pm->start();
|
50
|
$pm->start();
|
|
77
|
|
51
|
|
