当前位置:首页 > PHP教程 > php高级应用 > 列表

PHP简单实现定时监控nginx日志文件功能示例

发布:smiling 来源: PHP粉丝网  添加日期:2018-10-19 11:07:21 浏览: 评论:0 

本文实例讲述了PHP简单实现定时监控nginx日志文件功能。分享给大家供大家参考,具体如下:

此功能是为了实现,定时监控nginx生成的日志数据,并将新增的数据提交到一个接口(比如大数据的接口,让大数据来进行分析)。

  1. define("MAX_SHOW", 8192*5); //新增数据提交阈值 
  2. define("LOG_NAME"""); //读取的日志文件 
  3. define("LOG_SIZE"""); //保留上次读取的位置 
  4. define("LOG_URL"""); //日志提交地址 
  5. //运行时log文件原始大小 
  6. $log_size    = get_filesize(); 
  7. $file_size     = filesize(LOG_NAME); 
  8. if(emptyempty($log_size)){//没有记录上次位置,则从当前位置开始 
  9.   $file_size = $file_size
  10. }else if($log_size > $file_size){ //说明是第二天的日志文件,指针放到文件头 
  11.   $file_size = 0; 
  12. }else//从上次记录的位置开始 
  13.   $file_size = $log_size
  14. $file_size_new   = 0; 
  15. $add_size     = 0; 
  16. $ignore_size   = 0; 
  17. $fp = fopen(LOG_NAME, "r"); 
  18. while(1){ 
  19.   clearstatcache(); 
  20.   $read_num = 0; 
  21.   $file_size_new = filesize(LOG_NAME); 
  22.   $add_size = $file_size_new - $file_size
  23.   $add_data = array(); 
  24.   $add_log = ''
  25.   if($add_size > 0){ 
  26.     //大于一个阈值提交数据 
  27.     if($add_size > MAX_SHOW){ 
  28.       fseek($fp$file_size); 
  29.       //当增加量超过8192,需要分页读取增加量 
  30.       $page = ceil($add_size/8192); 
  31.       for($i=1; $i<=$page$i++){ 
  32.         if($i == $page){//最后一页 
  33.           $end_add = $add_size - ($page -1) * 8192; 
  34.           $add_log .= fread($fp$end_add); 
  35.         }else
  36.           $add_log .= fread($fp, 8192); 
  37.           $file_size_step = $file_size + $i * 8192; 
  38.           fseek($fp$file_size_step); 
  39.         } 
  40.       } 
  41.       $add_data['add_log'] = $add_log
  42.       $add_data['add_log'] = base64_encode($add_data['add_log']); 
  43.       http_post(LOG_URL, $add_data); 
  44.       $file_size = $file_size_new
  45.       //记录当前位置 
  46.       save_filesize($file_size); 
  47.     } 
  48.   }else if($add_size < 0){ //第二天从头部开始 
  49.     $file_size = 0; 
  50.   } 
  51.   sleep(2); 
  52. fclose($fp); 
  53. /** 
  54.  * 每次启动时获取上次打开文件位置 
  55.  */ 
  56. function get_filesize(){ 
  57.   $size = file_get_contents(LOG_SIZE); 
  58.   return $size
  59. /** 
  60.  * 每次提交后保存这次读取文件的位置 
  61.  */ 
  62. function save_filesize($size){ 
  63.   return file_put_contents(LOG_SIZE, $size); 
  64. /** 
  65.  * http请求 
  66.  * @param array $data 
  67.  * @return boolean 
  68.  */ 
  69. function http_post($url = ''$data = array()) 
  70.   if(emptyempty($url)){ 
  71.     return FALSE; 
  72.   } 
  73.   if($data){ 
  74.     $data = http_build_query($data); 
  75.   } 
  76.   $ch = curl_init (); 
  77.   curl_setopt ( $ch, CURLOPT_URL, $url ); 
  78.   curl_setopt ( $ch, CURLOPT_POST, 1 ); 
  79.   curl_setopt ( $ch, CURLOPT_HEADER, 0 ); 
  80.   curl_setopt ( $ch, CURLOPT_TIMEOUT, 5 ); 
  81.   curl_setopt ( $ch, CURLOPT_RETURNTRANSFER, 1 ); 
  82.   curl_setopt ( $ch, CURLOPT_POSTFIELDS, $data ); 
  83.   $return = curl_exec ( $ch ); 
  84.   curl_close ( $ch );//phpfensi.com 
  85.   return $return

备注:由于日志文件过了凌晨会切割,所以需要做一下判断,判断是第二天的日志需要从日志文件头部进行读取。

需要优化的逻辑:当中间进程挂了,停了一段时间,再启动时,从上次的位置重新读取,提交的数据会比较大,可能会超过提交数据大小的限制。

Tags: 示例 功能 文件

分享到: