php调用Workerman管理定时任务详解

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

useWorkerman\Worker;

useWorkerman\Timer;

require_once__DIR__ .'/vendor/autoload.php';

$worker=newWorker();

// Worker 进程启动时注册定时任务

$worker->onWorkerStart =function($worker) {

// 启动一个每秒执行的定时任务

$timerId= Timer::add(1,function() {

echo"Running task at ".date('Y-m-d H:i:s') ."\n";

});

// 保存定时器 ID（用于后续操作）

$worker->timerId =$timerId;

};

Worker::runAll();

1

2

3

4

5

6

7

8

9

10

11

12

13

14

// 停止单个定时任务

$timerId= Timer::add(2,function() {/* ... */});

Timer::del($timerId);

// 停止所有定时任务

Timer::delAll();// 慎用！会停止当前进程所有定时器

动态停止示例

$worker->onMessage =function($connection,$data)use($worker) {

// 收到特定指令时停止定时任务

if($data==='stop') {

Timer::del($worker->timerId);

$connection->send("定时任务已停止");

}

};

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

// 假设 $oldTimerId 是已存在的定时器 ID

$newTimerId= Timer::add(5,function() {/* 新任务逻辑 */});

Timer::del($oldTimerId);// 停止旧任务

// 或通过闭包动态更新

$worker->onWorkerStart =function($worker) {

$worker->timerId = Timer::add(1,function()use($worker) {

static$count= 0;

$count++;

echo"执行次数: $count\n";

// 达到条件后重启任务（例如修改间隔时间）

if($count>= 5) {

Timer::del($worker->timerId);

$worker->timerId = Timer::add(2,function() {

echo"重启后的任务\n";

});

}

});

};

1

2

3

4

5

$worker->onWorkerStart =function($worker) {

if($worker->id === 0) {// 仅第一个进程执行

Timer::add(1,function() {/* ... */});

}

};

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

$httpWorker=newWorker('http://0.0.0.0:8080');

$httpWorker->onMessage =function($connection,$request) {

$action=$request->get('action');

switch($action) {

case'start':

$timerId= Timer::add(1,function() {/* ... */});

$connection->send("定时任务 ID: $timerId");

break;

case'stop':

$timerId=$request->get('timer_id');

Timer::del($timerId);

$connection->send("已停止任务");

break;

}

};

1

2

3

4

5

6

// 注册自定义信号

Worker::$onMasterReload=function() {

// 收到 SIGUSR1 信号时重启某个任务

Timer::del($oldTimerId);

$newTimerId= Timer::add(3,function() {/* ... */});

};