一、前言

  1. 在前面的文章 Lumen实例讲解:第一部分 中,简单的介绍了 Lumen定时任务系统 的项目结构以及接口数据结构。将会在后面的文章陆续地讲解接口的实现逻辑
  2. 我们先来重温一下整个 定时任务系统 的核心模块:

Lumen实例讲解:第二部分 - 图1

  1. 是的,初识 Lumen 的读者肯定被这么多的文件吓到了,实际上无论 Laravel 还是 Lumen,其开发风格就是 先繁后简:高度拆分业务,不同的类有不同的职责,极大地降低后期代码维护成本

    二、开始

  2. 最先要给各位讲解的是,此项目最为重要的模块 Task Module。本模块实现的功能如下:
    ```

  • 添加定时任务 => api/task/add => TaskService.addOne() => 普通管理员
  • 查询定时任务 => api/task/seek => TaskService.seekOne() => 普通管理员|超级管理员
  • 定时任务列表 => api/task/all => TaskService.listAll() => 普通管理员|超级管理员
  • 删除定时任务 => api/task/del => TaskService.delOne() => 超级管理员 ```
  1. 看起来貌似只是单纯的 CURD 操作?实际上在本项目,应该说在 Lumen 框架下,有一些问题任然值得我们重视:
    • Q:《 Lumen 开箱的队列功能,当队列中的 Job被消费之后,会移除所有数据
    • A:在本项目中的解决思路是:通过自定义的 TaskDispatch,在 TaskDispatch.__destruct() 魔术方法中备份队列中任务数据到 tb_jobs 表中,同时更新对应的 tb_tasks 表的 tb_job_id 字段 ```php <?php

$queueId = app(Dispatcher::class)->dispatch($this->job); $queue = DB::table(config(‘queue.connections.database.table’))->where(‘id’, $queueId)->first();

$this->job->getJobInstance()->update([‘payload’ => $queue->payload, ‘queue’ => $queue->queue]); $this->job->getTaskInstance()->update([‘tb_job_id’ => $this->job->getJobInstance()->job_id]);

  1. - Q:《从 `tb_tasks` 表设计中不难得知,在记录定时任务数据的同时,需要同时保存 `tb_jobs` 表的主键ID `tb_users` 表的主键ID
  2. - A:在前一个问题中其实已经解决了 `tb_job_id` 字段的来源。同时在 **Task Module** 中的 `TaskJob` `TaskJob.setTaskInstance()` 方法,初始化 `TaskModel` 时就已经指定了 `tb_user_id` 字段数据
  3. ```php
  4. <?php
  5. $taskContent = json_encode(Arr::except($this->taskData, ['task_title']));
  6. $filled = [
  7. 'task_uuid' => md5($taskContent . time()),
  8. 'task_content' => $taskContent,
  9. 'task_title' => $this->taskData['task_title'],
  10. 'tb_user_id' => $this->taskData['tb_user_id']
  11. ];
  12. $this->taskInstance = (new TaskModel)->createOne($filled);
  1. Task Module 息息相关的 Job Module 就非常简单了,仅仅只有 JobModel 一个文件,该模块存在的意义就是 备份所有进入队列消费的任务信息 作为一种日志形式保留在数据库中
  2. 诚然,单纯的通过上述的代码片段,肯定还是无法理解意图。所以在本文最后,强烈建议新手读者可以去查看框架中以下文件的源码:

    1. \Illuminate\Contracts\Bus\Dispatcher => 框架发布Job到队列的类
    2. \Illuminate\Contracts\Queue\Job => 实现Job接口的有DatabaseJobRedisJob
  3. 剩下的模块将会在后续文章中一一讲解。给出最新完整项目的 代码仓库

    三、结语

  4. 本教程面向新手,整个系列包含 Lumen实例讲解:第一部分 以及会在近期推出的 Lumen实例讲解:第三部分

  5. 随着系统升级,软件更新,以后的配置可能有所变化,在下会第一时间测试并且更新教程;
  6. 欢迎联系在下,讨论建议都可以,之后会发布其它的教程。
  7. 后面紧锣密鼓地将会推出 Laravel业务篇 系列的教程,敬请期待。