### 前言
在PHP中，现在有swoole实现了支持毫秒级的定时器，非常不错，如果您的PHP是用的PHP7版本，那么建议你使用swoole的定时器。
那如果我们的PHP是5.3.3+版本的呢，我们能不能自己用原生实现一个定时器呢？答案是可以的。

### 技术点分析
原生PHP系统自带了两个扩展，我们可以使用这两个扩展实现秒级的定时器代码：

1、Pcntl - 多进程扩展 :
主要就是让PHP可以同时开启多个子进程，并行的去处理一些任务。

2、Spl - SplMinHeap基类 - 小顶堆
一个小顶堆数据结构，在实现定时器的时候，采用这种结构效率还是不错的，插入、删除的时间复杂度都是 `O(logN)`，像 `libevent` 的定时器也在 1.4 版本以后采用了这种数据结构之前用的是 `rbtree`，如果要是使用链表或者固定的数组，每次插入、删除可能都需要重新遍历或者排序，还是有一定的性能问题的。

### 说明

1、定义定时器结构，有什么参数之类的.
2、然后全部注册进我们的定时器类 Timer.
3、调用定时器类的`monitor()`方法，开始进行监听.
4、监听过程就是一个`while`死循环，不断的去看时间堆的堆顶是否到期了，本来考虑每秒循环看一次，后来一想每秒循环看一次还是有点问题，如果正好在我们`sleep(1)`的时候定时器有到期的了，那我们就不能马上去精准执行，可能会有延时的风险，所以还是采用 `usleep(1000)` 毫秒级的去看并且也可以将进程挂起减轻 CPU 负载.

### 具体实现代码如下：
```php
<?php
class Timer extends SplMinHeap {
   
    /**
     * 比较根节点和新插入节点大小
     * @param mixed $value1
     * @param mixed $value2
     * @return int
    */
    protected function compare($value1, $value2) {
        if ($value1['timeout'] > $value2['timeout']) {
            return -1;
        }
        if ($value1['timeout'] < $value2['timeout']) {
            return 1;
        }
        return 0;
    }
    /**
     * 插入节点
     * @param mixed $value
    */
    public function insert($value) {
        $value['timeout'] = time() + $value['expire'];
        parent::insert($value);
    }
    /**
     * 监听
     * @param bool $debug
    */
    public function monitor($debug = false) {
        while (!$this->isEmpty()) {
            $this->exec($debug);
            usleep(1000);
        }
    }
    /**
     * 执行
     * @param $debug
    */
    private function exec($debug) {
        $hit = 0;
        $t1  = microtime(true);
        while (!$this->isEmpty()) {
            $node = $this->top();
            if ($node['timeout'] <= time()) {
                //出堆或入堆
                $node['repeat'] ? $this->insert($this->extract()) : $this->extract();
                $hit = 1;
                //开启子进程
                if (pcntl_fork() == 0) {
                    empty($node['action']) ? '' : call_user_func($node['action']);
                    exit(0);
                }
                //忽略子进程,子进程退出由系统自动回收
                pcntl_signal(SIGCLD, SIG_IGN);
            } else {
                break;
            }
        }
        $t2 = microtime(true);
        echo ($debug && $hit) ? '时间堆 - 调整耗时: ' . round($t2 - $t1, 3) . "秒\r\n" : '';
    }
}

$timer = new Timer();
//注册 - 3s - 重复触发
$timer->insert(array('expire' => 3, 'repeat' => true, 'action' => function(){
  echo '3秒 - 重复 - hello world' . "\r\n";
}));
//注册 - 4s - 重复触发
$timer->insert(array('expire' => 4, 'repeat' => true, 'action' => function(){
  echo '4秒 - 重复 - gogo' . "\r\n";
}));
//注册 - 6s - 只触发一次
$timer->insert(array('expire' => 6, 'repeat' => false, 'action' => function(){
  echo '6秒 - 一次 - hello xxxx' . "\r\n";
}));
//监听
$timer->monitor(false);
```

### 用法：
1、`CD`进代码所在目录
2、然后执行这段命令可以暂时启动程序，不过可以查看到`demo`输出效果，`php index.php`
3、然后执行这段命令可以在后台守护进程运行 `nohup php 代码文件 >>/dev/null 2>&1 &`

已有0条评论

添加新评论☺

如果认为本文对您有所帮助请赞助本站

支付宝扫一扫赞助

已有0条评论

添加新评论☺