如何开发打点统计系统-阿里云开发者社区

如何开发打点统计系统

2018-01-07 2512

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介：

最近做了一个打点统计系统，统计系统肯定各个公司都有做过，至于怎么做就不好说了。我见过最多的就是使用php开发一个打点接口，然后在打点接口中做数据点击，这种方法最差的就是每次打点都往数据库中操作，另外一种就是往一个文件中增加数据。对于后一种，我就很奇怪了，你既然php是等于要往日志文件中增加一条记录，那干啥不用web服务器的自身的日志呢？所以我这次就果断使用分析nginx日志的方法来做打点（这个方法也是大多公司统计系统采用的方法吧）。
至于storm，hadoop啥的，太高大上了。没用

nginx日志打点第一个使用什么打点接口，当然可以自己放一个文件在服务器，然后访问这个文件。但是实际上nginx有个empty_gif的模块，它把图片存放在nginx的内存中，所以它的访问速度比静态文件的访问速度还快，所以果断选择这个。因此我的配置文件如下：

server {
        listen       80;
        server_name ares.test.com;
        access_log /home/web/ares/log/ares.test.com.access.log;
        access_log /home/web/ares/log/ares.test.com.static.log;
        error_log /home/web/ares/log/ares.test.com.error.log notice;

        root /home/web/test/www/;
        index index.php;

        location = /ares.gif {
            empty_gif;
        }
}

这里我把access_log写两份，目的是希望我一份做存留，一份做分析。

我设计的访问接口是http://ares.test.com/ares.gif?p=a&i=b

这里的p和i是统计的项目和统计项。

然后日志写完了之后，就需要进行日志切割了，日志切割怎么搞都行，我就搬起了php最快上搞，就是这里要注意下切割完日志以后要给nginx发送一个信号，让它修改下日志的fd。

       @rename($srcLog, $disLog);

        // 发送信号给nginx
        $pidFile = Yii::app()->params->nginxPid;
        $command = "kill -USR1 `cat ${pidFile}`";

        @system($command);

然后这个脚本我设置每1分钟跑一次，将当前的日志用分钟来重命名

下面就是分析日志的过程。

分析日志一定会是多个进程的环境。为什么，因为，一个进程，太慢。那多进程的环境，就需要有多个进程同时读取一个文件的情况，分析日志的时候就需要注意下使用文件锁。

            $disLogs = glob(Yii::app()->params->logFolder . "ares_*.log");

            foreach ($disLogs as $log) {
                $fp = fopen ($log , "rw+");

                // 如果获取到锁
                if (flock($fp , LOCK_EX)) {
                    while(!feof($fp)) {
                        $line = fgets($fp, 4096);
                        // DO SOMETHING
                    }

                    ftruncate($fp, 0);
                    fflush($fp);
                    flock($fp, LOCK_UN);
                    unlink($log);

                    echo "logfile {$log} ok" . PHP_EOL;
                }

                fclose ($fp);
            }