在日常项目开发中定时任务是很常见的,我们在开发电商业务中抢购秒杀,拍卖等功能模块,例如:拍下订单后在30分钟后自动取消未付款的订单同时把库存加回去。
通常我们会使用 crontab,但是 crontab 的精度不够,最小单位是每分钟。Swoole 就为我提供高精度毫秒的定时器。
PHP 本身的 pcntl_alarm 虽然也提供了类似的实现,但是 pcntl_alarm 最小单位只是秒,而 Swoole 是提供毫秒。而且 pcntl_alarm 不支持同时设定多个定时器程序,并且不支持异步IO。
接下来我们演示使用 ThinkPHP5 和 Swoole 的 swoole_timer_tick 函数来演示毫秒定时器。
创建 ThinkPHP5 自定义命令行
1.创建命令行类
-
创建application/console/Timer.php文件
~~~
<?php
namespace app\Console;
use think\console\Command;
use think\console\Input;
use think\console\Output;
class Timer extends Command
{
protected $server;
// 命令行配置函数
protected function configure()
{
// setName 设置命令行名称
// setDescription 设置命令行描述
$this->setName('timer:start')->setDescription('Start TCP(Timer) Server!');
}
// 设置命令返回信息
protected function execute(Input $input, Output $output)
{
$this->server = new \swoole_server('0.0.0.0', 9501);
$this->server->set([
'worker_num' => 4,
'daemonize' => false,
]);
$this->server->on('Start', [$this, 'onStart']);
$this->server->on('WorkerStart', [$this, 'onWorkerStart']);
$this->server->on('Connect', [$this, 'onConnect']);
$this->server->on('Receive', [$this, 'onReceive']);
$this->server->on('Close', [$this, 'onClose']);
$this->server->start();
// $output->writeln("TCP: Start.\n");
}
// 主进程启动时回调函数
public function onStart(\swoole_server $server)
{
echo "Start" . PHP_EOL;
}
// Worker 进程启动时回调函数
public function onWorkerStart(\swoole_server $server, $worker_id)
{
// 仅在第一个 Worker 进程启动时启动 Timer 定时器
if ($worker_id == 0) {
// 启动 Timer,每 1000 毫秒回调一次 onTick 函数,
swoole_timer_tick(1000, [$this, 'onTick']);
}
}
// 定时任务函数
public function onTick($timer_id, $params = null)
{
echo 'Hello' . PHP_EOL;
}
// 建立连接时回调函数
public function onConnect(\swoole_server $server, $fd, $from_id)
{
echo "Connect" . PHP_EOL;
}
// 收到信息时回调函数
public function onReceive(\swoole_server $server, $fd, $from_id, $data)
{
echo "message: {$data} form Client: {$fd}" . PHP_EOL;
// 将受到的客户端消息再返回给客户端
$server->send($fd, "Message form Server: ".$data);
}
// 关闭连时回调函数
public function onClose(\swoole_server $server, $fd, $from_id)
{
echo "Close" . PHP_EOL;
}
}
~~~
2.修改配置文件
-
文件所在 application/command.php
~~~
<?php
return [
'app\console\Timer',
];
~~~
接下来就可以通过命令行来启动毫秒定时器
$ > `php think timer:start`
我们会看到以下返回结果
![](https://box.kancloud.cn/457a2b05f65f0b692b2828b81c2a12f6_714x144.png)
当程序运行后,首次回调 onStart 函数输出 Start,之后每 1000毫秒(每秒),输出一次Hello,就完成了我们的毫秒定时器
- PHP7新特性
- 优雅的写代码
- 常见的代码优化
- 常用的工具类
- PHP原生生成EXCEL
- PHP地理位置计算
- PHP获取服务器状态
- 驼峰转下划线
- 百度地图两点坐标距离计算
- 判断是否是url
- PHP常见header头
- 邮件发送类
- 阿拉伯数字转化为大写
- 获取汉字首个拼音
- 根据身份证号获取星座
- 生成验证码类
- 生成唯一ID
- 身份证验证类
- PHP中文转拼音
- Nginx配置文件
- curl获取网页内容
- 快递查询api
- 上传图片类
- 股票类
- 找回密码类
- 字符串助手函数
- 校验数据规则
- PHP获取收集相关信息
- 字符串截取助手函数
- 网页中提取关键字
- 检测浏览器语言
- 微信相关类
- 微信获取access_token
- 获取用户基本信息
- 代码规范
- 编程规范(psr-1,2)
- 编程规范(原作者的建议)
- 经验
- 常用函数地址
- 函数集合
- 一些常识
- MYSQL相关知识
- 常用sql
- mysql事务隔离级别
- Read uncommitted
- Read committed
- Repeatable read
- Serializable
- 高性能MYSQL读书笔记
- 第一章MYSQL的架构
- mysql逻辑架构
- redis相关知识
- 1.安装redis
- 3.php操作redis
- 队列
- 悲观锁
- 乐观锁
- 发布
- 订阅
- redis实战-文章投票
- 设计模式
- 创建模型实例
- 单例模式
- 工厂模式
- AnimalInterface.php
- Chicken.php
- Factory.php
- Farm.php
- Pig
- SampleFactory.php
- Zoo
- 抽象工厂模式
- AnimalFactory
- Factory
- FarmInterface
- Income
- PandaZoo
- PeonyZoo
- PigFarm
- PlantFactory
- RiceFarm
- ZooInterface
- 原型模式
- 建造者模式
- 结构型模式实例
- 桥接模式
- 享元模式
- 外观模式
- 适配器模式
- 装饰器模式
- 组合模式
- 代理模式哦
- 过滤器模式
- 行为型模式实例
- 模板模式
- 策略模式
- 状态模式
- 观察者模式
- 责任链模式
- 访问者模式
- 解释器模式
- 空对象模式
- 中介者模式
- 迭代器模式
- 命令模式
- 备忘录模式
- 网络知识
- 互联网协议概述
- nginx简易交互过程
- HTTP知识
- LINUX相关知识
- swoole学习
- 1.初识swoole
- 2.WebSocket PHP 即时通讯开发
- 3.异步多进程的 CURL
- 4.异步非阻塞多进程的 Http 服务器
- 5.TCP 服务器
- 5.1同步 TCP 客户端
- 5.2异步 TCP 客户端
- 6.UDP 服务器
- 7.异步多任务处理
- 8.毫秒定时器
- 9.高并发投票
- ThinkPHP5学习
- 命令行操作
- 所有命令行中用到的基类
- 1.base
- 2.WorkerBase
- 3.TimeWorkerBase
- 4.CycleWorkerBase
- 5.WorkerCommandBase
- 6.WorkerHookBase
- 1.基础命令实现
- 2.建立Linux上的守护源码
- 3.发送模板消息
- 4.基于命令行实现自己的队列模式
- 5.发送定时短信
- thinkphp5使用sentry
- sentry通知,记录日志
- 高级查询
- Kafka相关
- 1.安装
- 2.为php打扩展
- 3.kafka实现
- 一些工具搭建
- sentry日志收集系统搭建
- walle搭建
- php实现定时任务
- 检测文件变化