【发布时间】：2020-11-05 08:35:07
【问题描述】：
我创建了一个应用程序来向多个用户发送电子邮件，但在处理大量收件人时遇到了问题。
错误出现在failed_jobs 表中
Illuminate\Queue\MaxAttemptsExceededException: App\Jobs\ESender has been attempted too many times or run too long. The job may have previously timed out. in D:\EmailSender\vendor\laravel\framework\src\Illuminate\Queue\Worker.php:649
这是payload 在failed_jobs 表中
{"uuid":"ff988083-c1da-4d20-a2e3-c2a10e154c79","timeout":9000,"id":"j2Lz0Ro0bkJpqwxKWTxC3Tiii71iE6Cm","data":{"command":"O:16:\"App\\Jobs\\ESender\":13:{s:7:\"timeout\";i:9000;s:12:\"receiver_obj\";O:45:\"Illuminate\\Contracts\\Database\\ModelIdentifier\":4:{s:5:\"class\";s:12:\"App\\Receiver\";s:2:\"id\";i:6;s:9:\"relations\";a:0:{}s:10:\"connection\";s:5:\"mysql\";}s:16:\"sender_all_hosts\";O:45:\"Illuminate\\Contracts\\Database\\ModelIdentifier\":4:{s:5:\"class\";s:15:\"App\\SenderHosts\";s:2:\"id\";a:4:{i:0;i:1;i:1;i:2;i:2;i:3;i:3;i:4;}s:9:\"relations\";a:0:{}s:10:\"connection\";s:5:\"mysql\";}s:11:\"message_obj\";O:45:\"Illuminate\\Contracts\\Database\\ModelIdentifier\":4:{s:5:\"class\";s:12:\"App\\Messages\";s:2:\"id\";i:36;s:9:\"relations\";a:0:{}s:10:\"connection\";s:5:\"mysql\";}s:7:\"counter\";i:1;s:3:\"job\";N;s:10:\"connection\";N;s:5:\"queue\";N;s:15:\"chainConnection\";N;s:10:\"chainQueue\";N;s:5:\"delay\";N;s:10:\"middleware\";a:0:{}s:7:\"chained\";a:0:{}}","commandName":"App\\Jobs\\ESender"},"displayName":"App\\Jobs\\ESender","timeoutAt":1594841911,"maxExceptions":null,"maxTries":null,"job":"Illuminate\\Queue\\CallQueuedHandler@call","delay":null,"attempts":1}
部分代码：
#1
class ESender implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/**
* The number of times the job may be attempted.
*
* @var int
*/
public $tries = 100;
/**
* The number of seconds the job can run before timing out.
*
* @var int
*/
public $timeout = 9999999;
...more code...
}
#2
public function handle(){
Redis::throttle('key')->allow(1)->every(20)->then(function () {
//send email
..... more code .....
}, function () {
// Could not obtain lock...
return $this->release(10);
});
}
这是我的配置：
queue.php:
'redis' => [
'driver' => 'redis',
'connection' => 'default',
'queue' => env('REDIS_QUEUE', 'default'),
'retry_after' => 9000,
'block_for' => null,
],
.env
BROADCAST_DRIVER=log
CACHE_DRIVER=file
QUEUE_CONNECTION=database
SESSION_DRIVER=file
SESSION_LIFETIME=300
REDIS_CLIENT = predis
REDIS_HOST=127.0.0.1
REDIS_PASSWORD=null
REDIS_PORT=6379
QUEUE_DRIVER=database
【问题讨论】：
-
您能否添加一个队列试图调用的命令。您的脚本出现问题，我们需要了解更多信息来帮助您。
-
@VladVladimirHercules 它在队列数量（起初是）的情况下工作正常。但随后出现了这些错误。您可以查看上面的图片。
-
我更新的是在你的 failed_jobs 表中如何调用命令。您发送给我们的是一个错误，我在实际命令调用之后。此外，该错误是否包含任何其他信息？
-
超时和尝试是为单个作业设置的，因此当您的作业排队时，根据您的代码，该作业有 100 次尝试执行。
-
@VladVladimirHercules 该问题已在有效负载部分更新，请检查
标签： php laravel redis queue predis