Inotify.class.php

<?php
define('DIRWATCHER_CHANGED', IN_MODIFY | IN_CLOSE_WRITE | IN_MOVE | IN_CREATE | IN_DELETE);
define('DIRWATCHER_DEBUG', true);
class Inotify
{
    private $_callbacks = array();
    private $_directories = array();
    private $_inotify = array();
    private $watch_descriptor =array();
    private $all_events =array();
    private $pathArray=array();
    private $md5path = array();
    private $wd_constants = array(
        1 => array('IN_ACCESS','File was accessed (read)'),
        2 => array('IN_MODIFY','File was modified'),
        4 => array('IN_ATTRIB','Metadata changed (e.g. permissions, mtime, etc.)'),
        8 => array('IN_CLOSE_WRITE','File opened for writing was closed'),
        16 => array('IN_CLOSE_NOWRITE','File not opened for writing was closed'),
        32 => array('IN_OPEN','File was opened'),
        128 => array('IN_MOVED_TO','File moved into watched directory'),
        64 => array('IN_MOVED_FROM','File moved out of watched directory'),
        256 => array('IN_CREATE','File or directory created in watched directory'),
        512 => array('IN_DELETE','File or directory deleted in watched directory'),
        1024 => array('IN_DELETE_SELF','Watched file or directory was deleted'),
        2048 => array('IN_MOVE_SELF','Watch file or directory was moved'),
        24 => array('IN_CLOSE','Equals to IN_CLOSE_WRITE | IN_CLOSE_NOWRITE'),
        192 => array('IN_MOVE','Equals to IN_MOVED_FROM | IN_MOVED_TO'),
        4095 => array('IN_ALL_EVENTS','Bitmask of all the above constants'),
        8192 => array('IN_UNMOUNT','File system containing watched object was unmounted'),
        16384 => array('IN_Q_OVERFLOW','Event queue overflowed (wd is -1 for this event)'),
        32768 => array('IN_IGNORED','Watch was removed (explicitly by inotify_rm_watch() or because file was removed or filesystem unmounted'),
        1073741824 => array('IN_ISDIR','Subject of this event is a directory'),
        1073741840 => array('IN_CLOSE_NOWRITE','High-bit: File not opened for writing was closed'),
        1073741856 => array('IN_OPEN','High-bit: File was opened'),
        1073742080 => array('IN_CREATE','High-bit: File or directory created in watched directory'),
        1073742336 => array('IN_DELETE','High-bit: File or directory deleted in watched directory'),
        16777216 => array('IN_ONLYDIR','Only watch pathname if it is a directory (Since Linux 2.6.15)'),
        33554432 => array('IN_DONT_FOLLOW','Do not dereference pathname if it is a symlink (Since Linux 2.6.15)'),
        536870912 => array('IN_MASK_ADD','Add events to watch mask for this pathname if it already exists (instead of replacing mask).'),
        2147483648 => array('IN_ONESHOT','Monitor pathname for one event, then remove from watch list.')
    );
    private $change_file_array = array();
    private $callBack_func = array();
    public function __construct($path)
    {

        $this->pathArray = $this->scandirRec($path);
        $this->pathArray[]=$path;
        echo '开始监听目录:';
        var_export($this->pathArray);
        echo "\n";
        foreach($this->pathArray as $val){
            $this->_init($val);
        }
    }
    public function _init($path){
        $md5 = md5($path);
        $this->md5path[$md5]=$path;
        $this->_inotify[$md5] = inotify_init();
//        var_dump($this->_inotify[$md5]);
        stream_set_blocking($this->_inotify[$md5], 0);
    }
    public function addWatch($path){
        $md5 = md5($path);
        $this->watch_descriptor[$md5] = inotify_add_watch($this->_inotify[$md5], $path, IN_ALL_EVENTS);
    }
    public function readWatch($path){
        $md5 = md5($path);
        return  inotify_read($this->_inotify[$md5]);
    }
    public function addAll(){
        foreach($this->pathArray as $path){
            $this->addWatch($path);
        }
    }
    public function getPathByMd5($md5){
        return $this->md5path[$md5];
    }
    public function startWatch(){
        $this->addAll();
        while(true){
            foreach ($this->md5path as $path){
                $events = $this->readWatch($path);
                if ($events) {
                    foreach ($events as $event){
                        $change_file = $path.DIRECTORY_SEPARATOR.$event['name'];
                        $change_event = $this->wd_constants[$event['mask']][0];
                        echo "Object: {$change_file}: {$change_event} (".$this->wd_constants[$event['mask']][1].")\n";
                        //如果是添加事件，加入新监控。
                        $this->change_file_array[] =$change_file;
                        if($change_event =='IN_CREATE') {
                            echo "Create file:{$change_file}\n";
                            if(is_dir($change_file)){
                                $this->_init($change_file);
                                $this->addWatch($change_file);
                            }
                        }else if($change_event =='IN_DELETE_SELF'){
                            echo "Delete Path:{$change_file}";
                            $this->removeWatch($change_file);
                        }
                        foreach ($this->callBack_func as $func){
                            call_user_func($func,$event);
                        }


                    }
                }
            }
        }
    }
    public function getChangeFile(){
        return $this->change_file_array;
    }
    public function addCallBack(callable $func){
        $this->callBack_func[]=$func;
    }
    /*
     * 递归扫描目录，不借助scandir(此函数可能会被禁用)
     * */
    public function scandirRec($dir)
    {
        static $result = array();
        if ($handle = opendir($dir)) {
            while (false !== ($file = readdir($handle))) {
                if ($file == '.' || $file == '..') {
                    continue;
                }
                $file = $dir . DIRECTORY_SEPARATOR . $file;
                if (is_dir($file)) {
                    $this->scandirRec($file);
                    $result[] = $file;
                }
            }
            closedir($handle);
        }
        return $result;
    }
    public function removeWatch($path){
        echo "remove file watch:{$path}".PHP_EOL;
        fclose($this->_inotify[md5($path)]);
    }
    public function __destruct()
    {
        foreach ($this->md5path as $val){
            $this->removeWatch($val);
        }
    }
}
/*
function prt($array){
    echo "======{$array['name']}======";
}
$obj = new Inotify('.');
$obj->addCallBack('prt');
$obj ->startWatch();
*/