首页 / 消息队列 / Laravel使用消息队列需要注意的一些问题_php实例

Laravel使用消息队列需要注意的一些问题_php实例

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Laravel使用消息队列需要注意的一些问题_php实例，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3735字，纯文字阅读大概需要6分钟。

内容图文

这篇文章主要给大家介绍了关于Laravel使用消息队列需要注意的一些问题，文中通过Laravel示例代码介绍的非常详细，对大家的学习Laravel具有一定的参考学习价值，需要的朋友们下面随着小编来一起看看吧。

前言

消息队列对于大型的Web项目来说是必不可少的一个模块，通过消息队列可以解决大并发和多种语言通信接口等问题。对于大并发的问题，可以将耗时的任务或者不能同时大量并行的任务封装起来传输到消息队列中，由处理程序不断从消息队列中提取消息并进行处理，这样通过消息队列的缓冲可以使得在大并发情况下不再阻塞，如果性能不够用还可以添加多个处理任务从消息队列中获取消息进行处理。比如数据库的操作，当对数据库的读、写操作过多时就会存在锁表等问题，读的问题可以通过缓存等方案解决，写的问题就需要消息队列来解决。而且，在大型的Web项目开发中，很多情况下不可能通过一种语言实现，需要发挥不同语言的优势，比如PHP，虽然在理论意义上它可以做Web开发中的所有事情，但是有些问题用它解决效率将会非常低，比如实时socket连接和分布式事务处理等。

使用 Laravel 的消息队列处理异步任务，Redis 作为队列数据库，Supervisor 监控脚本异常中断并自动重启，这是 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 类型存储，如图：

Laravel使用消息队列需要注意的一些问题_php实例 - 文章图片

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 官方文档 Queue 队列：

https://laravel.com/docs/5.5/queues

以上就是本文的所有内容了，希望对同学们学习Laravel提供到帮助！！

相关推荐：

关于Laravel使用消息队列需要注意哪些？

Laravel 进行微信支付开发实例

laravel查询构造器Query Builder叠加链式调用的方法教程

以上就是Laravel使用消息队列需要注意的一些问题_php实例的详细内容，更多请关注Gxl网其它相关文章！

内容总结

以上是互联网集市为您收集整理的Laravel使用消息队列需要注意的一些问题_php实例全部内容，希望文章能够帮你解决Laravel使用消息队列需要注意的一些问题_php实例所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/140779.html

来源：【匿名】