包简介

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

README 文档

README

定时优先级任务处理

背景

设计开发这个系统的初衷是为了满足实际业务中对各种异步延时任务的处理需求：

定时
任务可以在指定的时间自动执行
重试
任务执行失败时，需要根据指定的规则在特定的时间间隔后重试，直到执行成功或规则结束为止
时间要求是秒级

架构

使用

加载
1. 执行 composer require out001a/tasque，或者将依赖添加到项目的composer.json文件中，
```
{
    "require": {
        "out001a/tasque": "1.*"
    }
}
```
  然后执行 composer install 或 composer update
2. 在代码中添加
```
require 'vendor/autoload.php';
```
示例
- tests/bin/test.php是创建任务并入队的例子
- tests/bin/monitor.php是后台进程分发并处理任务的例子

简介

包含三个相对独立的组件：进程、任务和优先级队列。

进程

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

用法如下：

// 初始化，自定义一些参数
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();

任务

在src/Task目录下，实现了一个抽象的基础任务类和任务需要重试时应抛出的异常。业务开发时应该基于抽象类实现自己的任务处理逻辑。
优先级队列

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

单元测试

./vendor/bin/phpunit

TODO

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

out001a/tasque 适用场景与选型建议

out001a/tasque 是一款基于 PHP 开发的 Composer 扩展包，目前已累计 9 次下载、GitHub Stars 达 0，最近一次更新时间为 2018 年 03 月 03 日，在 PHP 生态内属于活跃度较高的组件。

它主要适用于以下技术方向：「redis」「task」「background」「job」「delay」「tasque」等业务场景。在实际项目中，围绕这些方向常见需要落地的问题包括：接口对接、性能调优、并发安全、与既有框架（Laravel / ThinkPHP / Yii / Webman 等）的兼容适配，以及生产环境的日志埋点与稳定性保障。

我们在过去多个企业项目中使用过 out001a/tasque 或与其功能相近的方案，如果你在选型或落地过程中遇到问题，例如 版本兼容、二次改造、私有化封装、与内部系统对接、生产 BUG 排查，欢迎联系我们协助评估。

围绕 out001a/tasque 我们能提供哪些服务？

定制开发 / 二次开发

基于 out001a/tasque 在你已有业务上做功能扩展、字段裁剪、UI 适配、与内部账号 / 权限 / 日志系统的深度对接。

BUG 修复 & 性能优化

线上偶发问题、内存泄漏、慢查询、并发异常等排查修复；针对高流量场景做缓存、队列、索引层面的调优。

项目外包 & 长期维护

承接完整的项目从需求 → 设计 → 开发 → 上线 → 长期运维；也可按月提供技术保姆服务。

yvsm@zunyunkeji.com QQ：316430983 微信：yvsm316 西安尊云信息科技 · 专注 PHP / Go / 分布式系统研发