laravel异步日志(laravel异步监控定时调度器实例详解)
laravel异步日志
laravel异步监控定时调度器实例详解定时调度器是什么
laravel默认提供了一个命令定时任务的功能,在其他的php框架下面,没有这个定时任务,我们要跑一些异步脚本怎么操作呢,只能依赖我们系统提供的crontab来做,这就导致我们每次发版本新增定时任务都要去服务器更改crontab代码,获取更新这个配置。
执行命令是php artisan schedule:run
来执行,那放在哪里执行呢,没错这个调起还是需要依赖我们crontab来执行,但是只需要配置一次,后续所有定时任务都在我们业务代码进行控制
场景
我们有一个导入数据的定时任务
|
//每分钟导入库数据 $schedule ->command(self::signature)->withoutoverlapping()->everyminute()->runinbackground(); |
这里导入长时间最好使用runinbackground(),表示异步执行,其实就是在shell脚本的末尾加上 & 符号,在linux上完全依赖系统的方式完成。
这里使用了withoutoverlapping() 表示在同一时刻只能有一个任务执行,主要逻辑使用的是排它锁实现,依赖于我们cache的driver,我这里使用的是redis,后面作为锁的过期直接redis提供的key过期来做。
出现问题
这个任务在正常情况下都是非常完美的,因为同一时刻只有一个再跑,跑完就可以,但是一个场景出现
有一天我们的qa同学刚部署环境后,我们服务端就在默默的导入库了,因为使用withoutoverlapping($expire_at=1440)
这个时候在redis就有一个锁产生了,这个默认带参数是锁的过期时间,默认是一天,然后因为我们docker环境需要更改参数然后进行后端server服务的重启,我们重启也是比较暴力,就是直接发送kill的信号,导致所有在里面跑的进程瞬间kill,而这时候我们的redis的锁缺还存在,而且是1440分钟左右,那当我们server再启动后,发现锁一直存在,没办法进行后续的操作了,只能等着。
解决
那我把锁的时间减少行不行,原来1天,我改成30分钟,没问题,开始第一版方案我们也是这样做,官方也是可以这样做的。
后来我们一想,能否做到一个监控程序呢,进程退出后立马监控到过期呢,这样就不用固定一个时间,这当然是所有软件开发者理想状态:要你开你就开,我挂了锁也就去掉了,不论正常与否。
解决方案
说明:
- 这里命令启动时候,获取进程的pid,然后fork子进程,可以将这个pid传递给子进程。
- 子进程每隔10s进行一个探活,获取父进程的id与传入的pid是否一致,这里普及一个知识点,如果父进程异常退出,这个子进程未退出就会被init进程(pid=1)接管,那么这就是一个孤儿进程。
- 同时子进程每次探活的时候就会更改redis的锁的过期时间,如果探活时间间隔是10s,那么我们的过期时间设置就是14s,多冗余一点时间。
代码实现
代码实现总是那么苍白无力哈,这里就写一个laravel的扩展来做,好处就是不影响我们主体的任何代码就完成了,我们的laravel可以随意升级。
github地址:github.com/zzh78727258…
composer地址:packagist.org/packages/ze…
总结
整体实现没有使用判断进程是否存在的ps grep等命令,因为我们docker环境不一定支持这些命令,只是用简单的pid与parent_id做对比。
laravel的在命令开始于结束都进行钩子方式,我们在listener下面进行监听即可
|
public function subscribe( $events ) { $events ->listen( [ commandstarting:: class , // 命令开始的时候 ], __class__ . '@handle' ); } |
整体代码是基于laravel扩展化的,不会影响laravel的升级操作。
好了,以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对开心学习网的支持。
原文链接:https://juejin.im/post/5d0b40946fb9a07f04204e57
- laravel判断变量为空(Laravel模糊查询区分大小写的实例)
- laravel消息机制(laravel框架中间件 except 和 only 的用法示例)
- laravel5.5以下自定义日志(Laravel timestamps 设置为unix时间戳的方法)
- laravel提取数据库的字段(Laravel创建数据库表结构的例子)
- laravel关闭错误提示(解决laravel session失效的问题)
- laravel模型获取表名(Laravel 对某一列进行筛选然后求和sum的例子)
- laravel图文分离(laravel实现前后台路由分离的方法)
- laravel架构设置(Laravel框架查询构造器 CURD操作示例)
- laravel事务状态(laravel dingo API返回自定义错误信息的实例)
- laravel查询条件数组写法(解决Laravel 使用insert插入数据,字段created_at为0000的问题)
- laravel查询构建器原理和使用(阿里对象存储OSS在laravel框架中的使用方法)
- laravel 验证规则(Laravel中正确地返回HTTP状态码方法示例)
- laravel框架网站搭建教程(Laravel框架实现文件上传的方法分析)
- laravel自动分解大任务(Laravel如何实现自动加载类)
- laravel验证码依赖(laravel5.2表单验证,并显示错误信息的实例)
- laravel新增数据表(laravel 多图上传及图片的存储例子)
- 《庆余年2》新消息,原班人马,肖战特别出演,这才是最好的安排(庆余年2新消息原班人马)
- 宁夏灵武恐龙化石发现始末(宁夏灵武恐龙化石发现始末)
- 到了岁末 临门一脚 节点,天台综合督评会目标直指 全年红(到了岁末临门一脚)
- 寒假余额不满24小时,不如来一场说走就走的亲子阅读之旅(寒假余额不满24小时)
- 省委书记出席的交流会,十位县委书记同场发言,代表公文材料的高水平(省委书记出席的交流会)
- 《刘老根3》热播,去世15年的她却再次被 伤害(去世15年的她却再次被)
热门推荐
- 国外虚拟主机怎么样(海外虚拟主机怎么挑选?)
- 云服务器用什么配置(如何选择云服务器 云服务器配置怎么搭配)
- sqlserver索引策略(SQLServer性能优化--间接实现函数索引或者Hash索引)
- JS动态操作select的option
- 怎么创建dhcp服务器(DHCP服务器与Web服务器的搭建教程)
- 云服务器最低配置可以吗(云服务器内存怎么选择?)
- html5手机字体怎么设置(html5给汉字加拼音加进度条的实现代码)
- iis应用程序池自动回收
- html5 webrtc技术详解(Html5 webRTC简单实现视频调用的示例代码)
- vue-cli请求数据的方式(vue-cli配置使用Vuex的全过程记录)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9