task-schedule-php是一个php任务调度框架，开发者可以使用这个框架来设置周期任务/一次性的延时任务后期异步执行。
动机：异步/不阻塞：用户操作的时候，服务器端除了和用户交互外，还会通知一些用户感知不到的外部系统，调用这些外部系统比较耗时，无法实时响应。因为这些任务不是主流程。可以将这些任务暂时存储起来，并将任务按照优先级（一般是任务预期执行的时间）进行排序，然后后期顺序执行这些任务，不阻塞主流程。
重复/周期：有些任务任务不仅仅只执行一次，会多次重复性地执行。例如：外部系统的状态发生变化，但是外部系统不会主动地回调/推送通知我们（或者是外部系统主动推送的信道不良），我们会周期性地主动轮询外部系统的状态。
延时处理。
典型的应用场景：乘客发起一次打车请求，服务器端可以先记录下乘客的打车请求，告知用户打车请求已经受理。服务器端后期想办法逐步将乘客的打车请求通知到周围的司机。
支付系统在收到银行的支付成功回调通知后，先保证将支付状态写入数据库的主流程。然后想办法调用比较耗时的外部系统，将支付成功的消息推送到用户端App。
用户在商户收银台生成一笔支付单后，如果没有在某个时间间隔之内收到银行的支付回调，收银台定期去银行轮询支付结果，直到知道用户在银行已经支付或者是超过最大轮询次数为止。
用户在司机结束行程后，如果在30分钟内没有支付，服务端自动发起一次微信代扣请求。
运行环境PHP最低版本:5.3.3.
Redis环境：php需要安装PhpRedis扩展。
Beanstalkd环境：需要beanstalkd的php客户端代码Pheanstalk，Pheanstalk代码已经内置包含在Libs-ThirdParty目录下。
例子例子程序可以在demo目录下找到。
直接执行php./demo/startRedis.php
或者php./demo/startBeanstalkd.php
或者php./demo/startPhp.php即可。
使用在目录Core/Handlers目录下编写任务处理函数。function helloWorld(){ echo "\n\nhello world\n\n"; return true;}实例化任务调度对象$redisIp = '10.10.9.77';$redisPort = '6379';$redisTimeout = 2;$redisClient = new \TaskSchedule\Libs\RedisWithReConnect($redisIp, $redisPort, $redisTimeout);$scheduler = new \TaskSchedule\Core\TaskScheduler\RedisTaskSchedulerWithTransaction($redisClient);$tasks = new \TaskSchedule\Core\Tasks\RedisTasks($redisClient);$runner = new \TaskSchedule\Core\TaskRunner($taskResult);$timeEvent = new \TaskSchedule\Core\TimeEvent\TimeEvent($scheduler, $tasks, $runner);生产者将该任务添加到计划中。$timeSpace = 2;$type = \TaskSchedule\Core\Tasks\TasksInterface::RUN_REPEATED;$func = 'helloWorld';//注意，在add任务之前，先初始化下maxTaskId。$timeEvent->add($timeSpace, $type, $func, $args = null);消费者获取到任务并执行。$runTimeLen = 5; $timeEvent->loop($runTimeLen);
评论