在线免费网站排名优化,站长工具无吗经典,杭州省建设厅网站,装修公司排名 装饰设计前景需求#xff1a;在我们用队列的时候发现maxtries的个数时255次#xff0c;这个太影响其他队列任务
我目前使用的thinkphp版本是6.1
第一部定义一个新的类
CustomDataBase#xff08;我用的mysql数据库存放的队列#xff09;
重写__make 和createPlainPayload方法
…前景需求在我们用队列的时候发现maxtries的个数时255次这个太影响其他队列任务
我目前使用的thinkphp版本是6.1
第一部定义一个新的类
CustomDataBase我用的mysql数据库存放的队列
重写__make 和createPlainPayload方法
?php
namespace app;use think\Db;
use think\queue\connector\Database;class CustomDataBase extends Database
{
// 此方法必须有具体原因自己看源码吧public static function __make(Db $db, $config){$connection $db-connect($config[connection] ?? null);return new self($connection, $config[table], $config[queue], $config[retry_after] ?? 60);}protected function createPlainPayload($job, $data){return [job $job,maxTries 22,timeout null,data $data,];}
}第二步修改queue.php文件的配置 为什么要重写类自己要点Queue::push(),查看源码因为我的项目通篇用的都是用的类名最简单的是重写当然你也可以自己在push的时候写对象对象里面定义属性$tries10;
Queue::push(EmailJob::class, $email-id);
