2017 © Pedro Peláez
 

library tasque

Redis based library for creating background tasks and processing them later.

image

out001a/tasque

Redis based library for creating background tasks and processing them later.

  • Monday, March 12, 2018
  • by out001a
  • Repository
  • 1 Watchers
  • 0 Stars
  • 5 Installations
  • PHP
  • 0 Dependents
  • 0 Suggesters
  • 0 Forks
  • 0 Open issues
  • 5 Versions
  • 0 % Grown

The README.md

tasque Build Status

定时优先级任务处理

背景

设计开发这个系统的初衷是为了满足实际业务中对各种异步延时任务的处理需求: 1. 定时
任务可以在指定的时间自动执行 2. 重试
任务执行失败时,需要根据指定的规则在特定的时间间隔后重试,直到执行成功或规则结束为止 3. 时间要求是秒级, (*1)

架构

Architecture, (*2)

使用

  • 加载, (*3)

    1. 执行 composer require out001a/tasque, 或者将依赖添加到项目的composer.json文件中,, (*4)

      {
          "require": {
              "out001a/tasque": "1.*"
          }
      }
      

      然后执行 composer installcomposer update, (*5)

    2. 在代码中添加, (*6)

      require 'vendor/autoload.php';
      
  • 示例, (*7)

    • tests/bin/test.php是创建任务并入队的例子
    • tests/bin/monitor.php是后台进程分发并处理任务的例子

简介

包含三个相对独立的组件:进程、任务和优先级队列。, (*8)

  1. 进程, (*9)

    进程组件在src/Process目录下,在我之前的一个小项目php-process的基础上做了些改进,可以满足在生产环境中使用。, (*10)

    用法如下:, (*11)

    // 初始化,自定义一些参数
    Process::init(消息队列对象, 同时存在的最大子进程数, fork子进程的时间间隔);
    Process::register('taskCount', function () {
        // 返回待处理的任务数(随便写个数也可以😄)
        return 1;
    });
    Process::register('dispatch', function() {
        // 分发待处理的任务列表,需要返回array
        return array();
    });
    Process::register('worker',  function() {
        // 注册work进程的业务逻辑
        return do_work();
    });
    // 执行
    Process::handle();
    
  2. 任务, (*12)

    src/Task目录下,实现了一个抽象的基础任务类和任务需要重试时应抛出的异常。业务开发时应该基于抽象类实现自己的任务处理逻辑。, (*13)

  3. 优先级队列, (*14)

    src/Tasque.php,基于redis实现了入队、出队等操作。出队按照队列元素的score值从小到大进行。, (*15)

单元测试

./vendor/bin/phpunit

TODO

  1. redis断线重连处理
  2. 支持平滑重启
  3. inotify监控指定文件的变化并自动重启进程
  4. 加入日志组件
  5. 使用环境变量控制各种参数
  6. Web控制台

The Versions

12/03 2018

dev-master

9999999-dev http://www.github.com/out001a/tasque/

Redis based library for creating background tasks and processing them later.

  Sources   Download

MIT

The Requires

  • php >=7.0
  • ext-pcntl *
  • ext-sysvmsg *
  • ext-redis >=3.1.0

 

The Development Requires

by shanhuanming

task redis job background delay tasque

12/03 2018

dev-dev

dev-dev http://www.github.com/out001a/tasque/

Redis based library for creating background tasks and processing them later.

  Sources   Download

MIT

The Requires

  • php >=7.0
  • ext-pcntl *
  • ext-sysvmsg *
  • ext-redis >=3.1.0

 

The Development Requires

by shanhuanming

task redis job background delay tasque

12/03 2018

1.0.1

1.0.1.0 http://www.github.com/out001a/tasque/

Redis based library for creating background tasks and processing them later.

  Sources   Download

MIT

The Requires

  • php >=7.0
  • ext-pcntl *
  • ext-sysvmsg *
  • ext-redis >=3.1.0

 

The Development Requires

by shanhuanming

task redis job background delay tasque

04/03 2018

1.0

1.0.0.0 http://www.github.com/out001a/tasque/

Redis based library for creating background tasks and processing them later.

  Sources   Download

MIT

The Requires

  • php >=7.0
  • ext-pcntl *
  • ext-sysvmsg *
  • ext-redis >=3.1.0

 

The Development Requires

by shanhuanming

task redis job background delay tasque

22/02 2018

dev-old

dev-old

  Sources   Download

The Requires

  • php >=7.0
  • ext-redis >=3.1.0
  • ext-pcntl *

 

The Development Requires