Laravel中如何使用消息队列-创新互联
本篇文章给大家分享的是有关Laravel中如何使用消息队列，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。
一、执行失败重试次数设置
一定要设置任务执行失败重试次数，避免无限失败重试，超过重试次数 Laravel 会默认写到失败任务表中，也可以自己写执行失败后续处理逻辑。
php artisan queue:work redis --tries=3
需要先执行以下命令创建数据表：
php artisan queue:failed-table php artisan migrate
二、程序异常的处理
有时候程序执行过程会发生异常，比如依赖其他接口，请求 HTTP 接口超时等等，如果不捕捉异常，那么当前这个队列就会中断不能继续运行下去，比如给 10000 个用户推送内容，需要依赖接口推送，如果中间的请求挂了就会影响到后面的推送。
这里的异常是指程序执行过程中发生的异常，不是指常驻进程挂掉，程序异常不一定导致常驻进程中断，况且进程中断有 Supervisor 监控并重启。
如捕获异常代码片段：
try {
$r = $client->request('POST', '', [
'query' => [
'client_name' => 'filemail',
'client_version' => '1.0',
'client_sequence' => 0,
'uid' => 692934013,//119481237
'r' => 1508312484,
],
'body' => \GuzzleHttp\json_encode($body),
]);
$result = $r->getBody()->getContents();
$result = json_decode($result, true);
if ($result['result'] == 0) {
info("sendMail fail:" . json_encode($result));
$this->pushLog($task['id'], $task['mail_id'], implode(',', $userIds), json_encode($result), 0);
} else {
Log::warning("sendMail fail:" . json_encode($result));
$this->pushLog($task['id'], $task['mail_id'], implode(',', $userIds), json_encode($result), $result['result']);
}
} catch (RequestException $e) {
Log::warning('RequestException' . $e->getMessage());
} catch (Exception $e) {
Log::emergency('Exception' . $e->getMessage());
}三、修改代码记得重启 Supervisor
最后一点，修改了处理队列的程序，记得要重启 Supervisor，否则脚本不会生效。
Laravel 往 Redis 写队列的数据结构
队列用 list 类型存储，如图：
value 内容如下：
{
"job": "Illuminate\\Queue\\CallQueuedHandler@call",
"data": {
"commandName": "App\\Jobs\\SendFile",
"command": "O:17:\"App\\Jobs\\SendFile\":5:{s:23:\"\u0000App\\Jobs\\SendFile\u0000task\";a:8:{s:5:\"title\";s:4:\"1111\";s:4:\"note\";s:2:\"11\";s:6:\"reward\";s:0:\"\";s:7:\"mail_id\";s:5:\"66681\";s:4:\"nums\";i:20;s:8:\"uid_file\";s:33:\"uidfile\/file-66681-1513058185.txt\";s:5:\"gcids\";s:40:\"1B9DD95645AAE8119F7DA9B9FF738D52BC8A1BD5\";s:2:\"id\";i:29;}s:6:\"\u0000*\u0000job\";N;s:10:\"connection\";N;s:5:\"queue\";s:8:\"sendfile\";s:5:\"delay\";N;}"
},
"id": "l0mjsUthbxm4TgIJNUH13km9N8DIpErK",
"attempts": 1
}以上就是Laravel中如何使用消息队列，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联行业资讯频道。
网页题目：Laravel中如何使用消息队列-创新互联
转载来源：http://abwzjs.com/article/ghpes.html
