send($data); $job->delete(); if($res){ $job->delete(); }else{ if($job->attempts()>3){ // 第1种处理方式:重新发布任务,该任务延迟10秒后再执行 //$job->release(10); // 第2种处理方式:原任务的基础上1分钟执行一次并增加尝试次数 //$job->failed(); // 第3种处理方式:删除任务 $job->delete(); } } } /** * 保存图片逻辑 * @param type $data */ public function send($data){ $res = file_put_contents($data['mubiao'], file_get_contents($data['yum'])); if($res){ return true; }else{ return false; } } }