快捷導(dǎo)航

PHP簡(jiǎn)單實(shí)現(xiàn)定時(shí)監(jiān)控nginx日志文件功能示例

更新時(shí)間：2018年06月28日 14:52:25 作者：WhoAmMe

這篇文章主要介紹了PHP簡(jiǎn)單實(shí)現(xiàn)定時(shí)監(jiān)控nginx日志文件功能,涉及php定時(shí)讀取nginx服務(wù)器日志以及基于curl的數(shù)據(jù)傳輸相關(guān)操作技巧,需要的朋友可以參考下

本文實(shí)例講述了PHP簡(jiǎn)單實(shí)現(xiàn)定時(shí)監(jiān)控nginx日志文件功能。分享給大家供大家參考，具體如下：

此功能是為了實(shí)現(xiàn)，定時(shí)監(jiān)控nginx生成的日志數(shù)據(jù)，并將新增的數(shù)據(jù)提交到一個(gè)接口（比如大數(shù)據(jù)的接口，讓大數(shù)據(jù)來(lái)進(jìn)行分析）

define("MAX_SHOW", 8192*5); //新增數(shù)據(jù)提交閾值
define("LOG_NAME", ""); //讀取的日志文件
define("LOG_SIZE", ""); //保留上次讀取的位置
define("LOG_URL", ""); //日志提交地址
//運(yùn)行時(shí)log文件原始大小
$log_size    = get_filesize();
$file_size     = filesize(LOG_NAME);
if(empty($log_size)){//沒(méi)有記錄上次位置,則從當(dāng)前位置開(kāi)始
  $file_size = $file_size;
}else if($log_size > $file_size){ //說(shuō)明是第二天的日志文件，指針?lè)诺轿募^
  $file_size = 0;
}else{ //從上次記錄的位置開(kāi)始
  $file_size = $log_size;
}
$file_size_new   = 0;
$add_size     = 0;
$ignore_size   = 0;
$fp = fopen(LOG_NAME, "r");
while(1){
  clearstatcache();
  $read_num = 0;
  $file_size_new = filesize(LOG_NAME);
  $add_size = $file_size_new - $file_size;
  $add_data = array();
  $add_log = '';
  if($add_size > 0){
    //大于一個(gè)閾值提交數(shù)據(jù)
    if($add_size > MAX_SHOW){
      fseek($fp, $file_size);
      //當(dāng)增加量超過(guò)8192，需要分頁(yè)讀取增加量
      $page = ceil($add_size/8192);
      for($i=1; $i<=$page; $i++){
        if($i == $page){//最后一頁(yè)
          $end_add = $add_size - ($page -1) * 8192;
          $add_log .= fread($fp, $end_add);
        }else{
          $add_log .= fread($fp, 8192);
          $file_size_step = $file_size + $i * 8192;
          fseek($fp, $file_size_step);
        }
      }
      $add_data['add_log'] = $add_log;
      $add_data['add_log'] = base64_encode($add_data['add_log']);
      http_post(LOG_URL, $add_data);
      $file_size = $file_size_new;
      //記錄當(dāng)前位置
      save_filesize($file_size);
    }
  }else if($add_size < 0){ //第二天從頭部開(kāi)始
    $file_size = 0;
  }
  sleep(2);
}
fclose($fp);
/**
 * 每次啟動(dòng)時(shí)獲取上次打開(kāi)文件位置
 */
function get_filesize(){
  $size = file_get_contents(LOG_SIZE);
  return $size;
}
/**
 * 每次提交后保存這次讀取文件的位置
 */
function save_filesize($size){
  return file_put_contents(LOG_SIZE, $size);
}
/**
 * http請(qǐng)求
 * @param array $data
 * @return boolean
 */
function http_post($url = '', $data = array())
{
  if(empty($url)){
    return FALSE;
  }
  if($data){
    $data = http_build_query($data);
  }
  $ch = curl_init ();
  curl_setopt ( $ch, CURLOPT_URL, $url );
  curl_setopt ( $ch, CURLOPT_POST, 1 );
  curl_setopt ( $ch, CURLOPT_HEADER, 0 );
  curl_setopt ( $ch, CURLOPT_TIMEOUT, 5 );
  curl_setopt ( $ch, CURLOPT_RETURNTRANSFER, 1 );
  curl_setopt ( $ch, CURLOPT_POSTFIELDS, $data );
  $return = curl_exec ( $ch );
  curl_close ( $ch );
  return $return;
}

備注：由于日志文件過(guò)了凌晨會(huì)切割，所以需要做一下判斷，判斷是第二天的日志需要從日志文件頭部進(jìn)行讀取

需要優(yōu)化的邏輯：當(dāng)中間進(jìn)程掛了，停了一段時(shí)間，再啟動(dòng)時(shí)，從上次的位置重新讀取，提交的數(shù)據(jù)會(huì)比較大，可能會(huì)超過(guò)提交數(shù)據(jù)大小的限制

更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專(zhuān)題：《PHP日志操作技巧總結(jié)》、《php文件操作總結(jié)》、《PHP數(shù)組(Array)操作技巧大全》、《PHP基本語(yǔ)法入門(mén)教程》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫(kù)操作入門(mén)教程》及《php常見(jiàn)數(shù)據(jù)庫(kù)操作技巧匯總》

希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。

您可能感興趣的文章: