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的升级操作。

好了，以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对我们的支持。

赞 (0)

相关推荐

  • Laravel中任务调度console使用方法小结

    适用场景:分析数据(日志) php artisan make:console 你的命令类名 示例: php artisan make:console Check 在\app\Console\Commands目录下已生成一个Check.php文件 <?php namespace App\Console\Commands; use Illuminate\Console\Command; class Check extends Command { /** * The name and signatur

  • laravel异步监控定时调度器实例详解

    laravel异步监控定时调度器实例详解

    定时调度器是什么 laravel默认提供了一个命令定时任务的功能,在其他的php框架下面,没有这个定时任务,我们要跑一些异步脚本怎么操作呢,只能依赖我们系统提供的crontab来做,这就导致我们每次发版本新增定时任务都要去服务器更改crontab代码,获取更新这个配置. 执行命令是php artisan schedule:run 来执行,那放在哪里执行呢,没错这个调起还是需要依赖我们crontab来执行,但是只需要配置一次,后续所有定时任务都在我们业务代码进行控制 场景 我们有一个导入数据的定时

  • AngularJS中的拦截器实例详解

    AngularJS中的拦截器实例详解 异步操作 有时候需要在拦截器中做一些异步操作.幸运的是, AngularJS 允许我们返回一个 promise 延后处理.它将会在请求拦截器中延迟发送请求或者在响应拦截器中推迟响应. 下面是项目中用到的代码. ZbtjxcApp.factory('myHttpInterceptor', ['$q', '$window','$location', function($q, $window,$location) { return { // 全局响应 'respo

  • vue3.0中的watch侦听器实例详解

    vue3.0中的watch侦听器实例详解

    目录 前言 侦听器和计算属性的区别 vue3如何使用watch呢? 基本使用 监听多个响应式数据 侦听reactive定义的响应式数据 监听reactive定义的响应式数据的某一个属性 配置选项用法 总结 前言 虽然计算属性在大多数情况下更合适,但有时也需要一个自定义的侦听器.这就是为什么 Vue 通过watch选项提供了一个更通用的方法,来响应数据的变化.当需要在数据变化时执行异步或开销较大的操作时,这个方式是最有用的. 侦听器和计算属性的区别 计算属性里不可以做异步操作,侦听器可以做异步操作

  • React为什么需要Scheduler调度器原理详解

    React为什么需要Scheduler调度器原理详解

    目录 正文 我们为什么需要Scheduler(调度器) Scheduler如何进行工作 总结 正文 最近在重学React,由于近两年没使用React突然重学发现一些很有意思的概念,首先便是React的Scheduler(调度器) 由于我对React的概念还停留在React 15之前(就是那个没有hooks的年代),所以接触Scheduler(调度器) 让我感觉很有意思: 在我印象中React的架构分为两层(React 16 之前) Reconciler(协调器)—— 负责找出变化的组件 Rend

  • PHP laravel中的多对多关系实例详解

    PHP laravel中的多对多关系实例详解

    数据表之间是纵横交叉.相互关联的,laravel的一对一,一对多比较好理解,官网介绍滴很详细了,在此我就不赘述啦,重点我记下多对多的关系 一种常见的关联关系是多对多,即表A的某条记录通过中间表C与表B的多条记录关联,反之亦然.比如一个用户有多种角色,反之一个角色对应多个用户. 为了测试该关联关系,我们沿用官网的用户角色示例: 需要三张数据表:users.roles 和 role_user,role_user 表按照关联模型名的字母顺序命名(这里role_user是中间表),并且包含 user_i

  • laravel下trait的使用代码实例详解

    laravel下trait的使用代码实例详解

    前言 今天在整理laravel的练习项目时,发现自己的代码结构中有很多重复的代码.于是搜索了一下laravel框架的代码复用机制.知道了Trait的存在,于是学习使用了一下. 关于Trait的理解 Trait是PHP5.4引入的新概念,定义方式和class的定义方式类似.但是并不具备class的完整性.Trait看上去更像是一个class的一部分.它使不相关的两个class能够具有类似的行为. Trait的简单使用 新建一个Trait 本人由于数据库操作上使用了eloquent模型,在多表查询时

  • Java 8 的异步编程利器 CompletableFuture的实例详解

    Java 8 的异步编程利器 CompletableFuture的实例详解

    目录 一个例子回顾Future 一个例子走进CompletableFuture CompletableFuture使用场景 创建异步任务 supplyAsync方法 runAsync方法 任务异步回调 1.thenRun/thenRunAsync 2.thenAccept/thenAcceptAsync 3.thenApply/thenApplyAsync 4.exceptionally 5.whenComplete方法 6.handle方法 多个任务组合处理 AND组合关系 OR组合的关系 区

  • laravel的数据表填充器使用详解

    laravel的数据表填充器使用详解

    目录 一.数据表填充器 1.1 填充器(种子文件)的创建与编写 1.1.2.创建填充器 1.1.3.[重点]编写填充器代码 1.2 执行填充器文件 一.数据表填充器 填充操作就是往数据表中写测试数据的操作(增加操作),在开发阶段是很实用的功能. 1.1 填充器(种子文件)的创建与编写 1.1.1.填充器默认的所在目录 1.1.2.创建填充器 php artisan make:seeder 填充器名称 [约定俗成的写法,大写表名 + TableSeeder] 例:以paper为例,则名称应该为Pa

  • Android开发之电话拨号器实例详解

    Android开发之电话拨号器实例详解

    本文实例分析了Android开发之电话拨号器的用法.分享给大家供大家参考,具体如下: 1.新建一个名为javacallPhone的安卓项目,并在cn.csdn.hr.activity包下建一个CallPhoneActivity.java类 2.打开res下的Layout下的main.xml进行布局,设置布局方式为水平布局,再从左侧分别拖入textview,text files下的Phone,和button按钮,通过new String后效果如下: 3.打开CallPhoneActivity.ja

  • python 自定义装饰器实例详解

    本文实例讲述了python 自定义装饰器.分享给大家供大家参考,具体如下: 先看一个例子 def deco(func): print("before myfunc() called.") func() print("after myfunc() called.") return func @deco def myfunc(): print("myfunc() called.") # myfunc = deco(myfunc) # 与上面的@dec

随机推荐