taskPHP基于原生态php开发的定时计划任务框架,利用多进程实现任务的分配和运行,利用原生态php内存共享实现进程间通信,支持linux和windows。有较好的伸缩性、扩展性、健壮稳定性而被多家公司使用,同时也希望开源爱好者一起贡献。
github地址: https://github.com/qq8044023/taskPHP
oschina地址: http://git.oschina.net/cqcqphper/taskPHP
这两个地址都会同步更新。
如感兴趣请加QQ群 一起探讨、完善。越多人支持,就越有动力去更新,喜欢记得右上角star哈。
taskPHP ①群:375841535(空)
框架目录结构:
taskPHP 根目录
|-- core 框架系统目录
| |-- lib 框架核心文件目录
| | |-- .... 众多的框架核心类库文件
| |-- guide.php 框架引导文件
| |-- distribute_listen.php 任务派发进程入口
| |-- worker_listen.php 任务执行进程入口
|-- logs 日志目录
|-- tasks 用户任务目录
| |-- demo demo任务
| | |-- Lib demo任务的扩展目录
| | |-- demoTask.php demo任务类文件
| | |-- config.php demo任务配置文件
| | ... 更多任务
| |-- config.php 全局配置文件
|-- main.php 框架入口文件
|-- windows_single.cmd windows快速启动文件
框架说明
- linux下子进程执行任务,修改脚本无需重启后台服务立即生效,windows下修改任务脚本后需重启后台脚本 但往系统添加执行不受影响
- 使用内存共享实现进程通信,堵塞式消息队列,整个框架的运行无需第三方扩展。
- 任务派发及具体任务执行不在同个进程[distribute_listen.php]和[worker_listen.php],windows和linux下启用入口文件[main.php],windows下可运行[windows_single.cmd]快速启动
- 执行时间语法跟crontab类似实现crontab的运行规则,并有辅助工具在Utils类,且支持秒设置.
- 添加任务简单,只需继承Task基类,实现任务入口run方法
- 由于任务存在派发时间,所以任务运行的时间可能会有1-2秒的误差。
- windows下执行任务在循环里,编写任务有问题或调用exit将导致后台脚本停止,linux下无此问题。
- Fatal error: Call to undefined function shmop_open() windows 打开php.ini 去掉extension=php_shmop.dll 前面的 ;符号
* * * * * * * //格式 :秒 分 时 天 月 年 周
10 * * * * * * //表示每一分钟的第10秒运行
/10 * * * * * * //表示每10秒运行
mian.php [start] 启动 可不带参数
mian.php close 结束
main.php reload 重新加载任务
main.php delete demo 删除任务
main.php select 查看任务列表
<?php
//系统配置
return array(
'core_user' =>'nobody',//指定用户 nobody www
'runer_limit' =>true, //运行多少次后重启,设置true,将不用子进程执行任务[效率高点,但设置任务将需要重启服务],默认为1 每次都使用子进程执行任务[设置任务立即生效]
'memory_limit' =>512, //指定任务进程最大内存
/**
* 任务列表
*/
'task_list'=>array(
//demo任务
'demo'=>array(
'class_name'=>true, //class名称,设置true代表tasks目录里面的任务会自动找到该任务的class名称,非tasks目录里面的任务则填写完整的class名称core\lib\xxxx
'timer' =>'/5 * * * * * *', //crontad格式 :秒 分 时 天 月 年 周
),
),
/**
* 数据库配置
* */
'DB'=>array(
'db_type' =>'MYSQL',//数据库类型
'db_host' =>'127.0.0.1',//地址
'db_username' =>'root',//账户
'db_password' =>'',//密码
'db_prot' =>'3306',//端口
'db_name' =>'dbname'//选中的数据库
),
);
composer require taskphp/taskphp
D:\phpStudy\wwwroot\ostaskphp>php main.php
------------------------- taskPHP ------------------------------
taskPHP version:1.0 PHP version:5.6.1
------------------------- taskPHP PROCESS ----------------------
listen processes status
distribute N [OK]
worker N [OK]
----------------------------------------------------------------
D:\phpStudy\wwwroot\ostaskphp>php main.php close
runing:no
close ok
D:\phpStudy\wwwroot\ostaskphp>php ./main.php reload
taskPHP:demo task load complete
taskPHP is running..............
task reload ok
D:\phpStudy\wwwroot\ostaskphp>php ./main.php delete demo
taskPHP:demo task load complete
taskPHP is running..............
task reload ok
D:\phpStudy\wwwroot\ostaskphp>php ./main.php select
task_name:demo
run_time:1 * * * * * *
next_time:2017-04-06 10:08:01
[root@FX-DEBUG taskphps]# php ./main.php start
------------------------- taskPHP ------------------------------
taskPHP version:1.0 PHP version:5.6.9
------------------------- taskPHP PROCESS ----------------------
listen processes status
distribute N [OK]
worker N [OK]
----------------------------------------------------------------
taskPHP:demo task load complete
taskPHP is running..............
[root@FX-DEBUG taskphps]# php ./main.php start &
------------------------- taskPHP ------------------------------
taskPHP version:1.0 PHP version:5.6.9
------------------------- taskPHP PROCESS ----------------------
listen processes status
distribute N [OK]
worker N [OK]
----------------------------------------------------------------
taskPHP:demo task load complete
taskPHP is running..............
[root@FX-DEBUG taskphps]# php ./main.php close
runing:no
close ok
[root@FX-DEBUG taskphps]# php ./main.php reload
taskPHP:demo task load complete
taskPHP is running..............
task reload ok
[root@FX-DEBUG taskphps]# php ./main.php delete demo
taskPHP:demo task load complete
taskPHP is running..............
task reload ok
[root@FX-DEBUG taskphps]# php ./main.php select
task_name:demo
run_time:1 * * * * * *
next_time:2017-04-06 10:08:01
<?php
namespace tasks\demo;
use core\lib\Task;
use core\lib\Config;
use core\lib\Db;
/**
* 测试任务
*/
class demoTask extends Task{
public function run(){
$db=Db::setConfig(Config::get('DB'));
$data=array(
"player_id"=>1,
"item_id"=>2,
"rows"=>3
);
$db->table("表名")->add($data);
}
}
<?php
namespace tasks\demo;
use core\lib\Task;
use core\lib\Config;
use core\lib\Db;
/**
* 测试任务
*/
class demoTask extends Task{
public function run(){
$db=Db::setConfig(Config::get('DB'));
$res=$db->table("表名")->where("id=1")->delete();
var_dump($res);
}
}
<?php
namespace tasks\demo;
use core\lib\Task;
use core\lib\Config;
use core\lib\Db;
/**
* 测试任务
*/
class demoTask extends Task{
public function run(){
$db=Db::setConfig(Config::get('DB'));
$db->table("表名")->where(array("room_id"=>1))->save(array("status"=>1));
}
}
<?php
namespace tasks\demo;
use core\lib\Task;
use core\lib\Config;
use core\lib\Db;
/**
* 测试任务
*/
class demoTask extends Task{
public function run(){
$db=Db::setConfig(Config::get('DB'));
$res=$db->table("表名")->find();
var_dump($res);
}
}
<?php
namespace tasks\demo;
use core\lib\Task;
use core\lib\Config;
use core\lib\Db;
/**
* 测试任务
*/
class demoTask extends Task{
public function run(){
$db=Db::setConfig(Config::get('DB'));
$res=$db->table("表名")->where("id=1")->select();
var_dump($res);
}
}
<?php
namespace tasks\demo;
use core\lib\Task;
use core\lib\Config;
use core\lib\Db;
/**
* 测试任务
*/
class demoTask extends Task{
public function run(){
$db=Db::setConfig(Config::get('DB'));
$res=$db->table("表名")->where("id=1")->find();
//或者
$res=$db->table("表名")->where(array("id"=>1))->find();
var_dump($res);
}
}
<?php
namespace tasks\demo;
use core\lib\Task;
use core\lib\Config;
use core\lib\Db;
/**
* 测试任务
*/
class demoTask extends Task{
public function run(){
$db=Db::setConfig(Config::get('DB'));
$db->table("表名")->where(array("room_id"=>1))->group("status")->select();
}
}
<?php
namespace tasks\demo;
use core\lib\Task;
use core\lib\Config;
use core\lib\Db;
/**
* 测试任务
*/
class demoTask extends Task{
public function run(){
$db=Db::setConfig(Config::get('DB'));
$res=$db->table("表名")->model()->select("id")->from("表名")->row();
var_dump($res);
}
}