12345678910111213141516171819202122232425262728293031 |
- <?php
- namespace app\common\job;
- use think\queue\Job;
- class OrderJob
- {
- public function fire(Job $job, $data)
- {
- //....这里执行具体的任务
- var_dump($data);
- echo '任务执行成功!' . PHP_EOL;
- if ($job->attempts() > 3) {
- //通过这个方法可以检查这个任务已经重试了几次了
- }
- //如果任务执行成功后 记得删除任务,不然这个任务会重复执行,直到达到最大重试次数后失败后,执行failed方法
- $job->delete();
- // 也可以重新发布这个任务
- // $job->release($delay); //$delay为延迟时间
- }
- public function failed($data)
- {
- // ...任务达到最大重试次数后,失败了
- echo '任务执行失败!' . PHP_EOL;
- }
- }
|