PHP implements the function of regularly monitoring nginx log files

This article mainly introduces the simple implementation of PHP's regular monitoring of nginx log files, involving PHP's regular reading of nginx server logs and curl-based data transmission related operating techniques. Friends in need can refer to this article

The example describes how PHP simply implements the function of regularly monitoring nginx log files. Share it with everyone for your reference, the details are as follows:

This function is to monitor the log data generated by nginx regularly and submit the new data to an interface (such as the big data interface, so that big data can for analysis)

define("MAX_SHOW", 8192*5); //新增数据提交阈值
define("LOG_NAME", ""); //读取的日志文件
define("LOG_SIZE", ""); //保留上次读取的位置
define("LOG_URL", ""); //日志提交地址
//运行时log文件原始大小
$log_size    = get_filesize();
$file_size     = filesize(LOG_NAME);
if(empty($log_size)){//没有记录上次位置,则从当前位置开始
  $file_size = $file_size;
}else if($log_size > $file_size){ //说明是第二天的日志文件，指针放到文件头
  $file_size = 0;
}else{ //从上次记录的位置开始
  $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){
    //大于一个阈值提交数据
    if($add_size > MAX_SHOW){
      fseek($fp, $file_size);
      //当增加量超过8192，需要分页读取增加量
      $page = ceil($add_size/8192);
      for($i=1; $i<=$page; $i++){
        if($i == $page){//最后一页
          $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[&#39;add_log&#39;] = $add_log;
      $add_data[&#39;add_log&#39;] = base64_encode($add_data[&#39;add_log&#39;]);
      http_post(LOG_URL, $add_data);
      $file_size = $file_size_new;
      //记录当前位置
      save_filesize($file_size);
    }
  }else if($add_size < 0){ //第二天从头部开始
    $file_size = 0;
  }
  sleep(2);
}
fclose($fp);
/**
 * 每次启动时获取上次打开文件位置
 */
function get_filesize(){
  $size = file_get_contents(LOG_SIZE);
  return $size;
}
/**
 * 每次提交后保存这次读取文件的位置
 */
function save_filesize($size){
  return file_put_contents(LOG_SIZE, $size);
}
/**
 * http请求
 * @param array $data
 * @return boolean
 */
function http_post($url = &#39;&#39;, $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;
}

Note: Since the log file will be cut after early morning, you need to make a judgment. It is judged that the next day’s log needs to be obtained from the log. Reading the file header

The logic that needs to be optimized: When the intermediate process hangs, stops for a period of time, and then starts again, it will read again from the last position. The submitted data will be relatively large and may be Exceeding the limit of submitted data size

The above is the entire content of this article. I hope it will be helpful to everyone's study. For more related content, please pay attention to the PHP Chinese website!

Related recommendations:

Detailed explanation of how PHP uses zlib extension to implement GZIP compression output

PHP implements distributed memcache settings Detailed explanation of web cluster session synchronization method

##Complete example explanation of mongoDB database operation class implemented by PHP

The above is the detailed content of PHP implements the function of regularly monitoring nginx log files. For more information, please follow other related articles on the PHP Chinese website!