复制代码 代码如下:
<?php
class Lib_File2
{
//文件目录
private $root = '/data/wwwroot/kkpromo/data/';
//文件后缀
private $suffix = '.log';
//文件句柄
private $handle=null;
//一次读取文件的最大记录数
private $limit=40000;
//每行读取的字节长度
private $length=1024;
//开始时间
private $startTime=0;
//内存使用基准点
private static $startMemory=0;
//
private $conn=null;
//
private static $init=null;
public static function instance()
{
self::$startMemory = memory_get_usage(true);
if(self::$init && is_object(self::$init))
{
return self::$init;
}
self::$init = new self();
return self::$init;
}
private function __construct(){}
public function setRoot($root)
{
if(!is_dir($root)) die($root.' ROOT DOES NOT EXIST');
$this->root = $root;
}
public function setSuffix($suffix)
{
$this->suffix = $suffix;
}
public function setLimit($limit)
{
if(!is_numeric($limit)) die($limit.' SHOULD BE NUMBERIC');
if(intval($limit) > 1000000) die($limit.' SHOULD BE LOWER THAN 1000000');
$this->limit = intval($limit);
}
public function _getFile($date , $appid , $op)
{
$filename = rtrim($this->root , 'https://www.jb51.net/').DIRECTORY_SEPARATOR.$date.DIRECTORY_SEPARATOR.$appid.'.'.$op.$this->suffix;
if(!file_exists($filename))
{
die($filename.' FILE DOES NOT EXISTS!');
}
if(!is_file($filename))
{
die($filename.' FILE DOES NOT EXIST!');
}
if(!is_readable($filename))
{
die($filename.' FILE ACCESS DENY!');
}
return $filename;
}
public function closeFile($date=null , $appid=null , $op=null)
{
if($op && $date && $appid)
{
if(is_object($this->handle[$date.'_'.$appid.'_'.$op]) || $this->conn[$date.'_'.$appid.'_'.$op])
{
unset($this->handle[$date.'_'.$appid.'_'.$op]);
$this->handle[$date.'_'.$appid.'_'.$op]=null;
}
$this->conn[$date.'_'.$appid.'_'.$op]=null;
$this->handle[$date.'_'.$appid.'_'.$op]=null;
unset($this->handle[$date.'_'.$appid.'_'.$op]);
}
else {
if(is_array($this->handle) && $this->handle)
{
foreach ($this->handle as $key=>$val){
unset($this->handle[$key]);
$this->conn[$key]=null;
$this->handle[$key]=null;
}
}
}
return true;
}
private function _openFile($date , $appid , $op)
{
$this->startTime = microtime(true);
if(isset($this->conn[$date.'_'.$appid.'_'.$op]) && $this->conn[$date.'_'.$appid.'_'.$op])
{
return $this->handle[$date.'_'.$appid.'_'.$op];
}
$filename = self::_getFile($date , $appid , $op);
if(($this->handle[$date.'_'.$appid.'_'.$op] = new SplFileObject($filename , 'r'))!=null)
{
$this->conn[$date.'_'.$appid.'_'.$op] = true;
return $this->handle[$date.'_'.$appid.'_'.$op];
}
else {
die('FILE OPEN FAILED!');
}
}
/**
* 功能:解析数据
* 格式: array('timestamp','mid','data');
* @param string $data
* @return boolean|array
*/
private function _parseData($data , $jsonFlag=true)
{
if(empty($data) || !is_string($data)) return false;
$result = array(
'timestamp'=>0,
'mid'=>0,
'data'=>array(),
);
$data = explode('|', $data);
if(count($data) < 3 || !is_array($data)) return false;
$result['timestamp'] = $data[0];
$result['mid'] = $data[1];
if($jsonFlag)
{
$result['data'] = @json_decode($data[2] , true);
unset($result['mid']);
}
if(empty($result['timestamp']) || empty($result['mid'])) return false;
unset($data);
return $result;
}
/**
* TODO:读取单一文件
* @param string $date: 如(20140327)
* @param int $appid: 如(1000,9000)
* @param string $op:如(show,login , index)
* @param number $startNum 默认从第一行开始
* @param number $length 默认到$this->limit 读取的行数
* @param array $condition:array('mid'=>arrray() , 'ip'=>array() , ...) 过滤条件
* @param bool $jsonFlag:默认为true, 则保留jsondata字段;设为false,则去掉false字段
* @return array(count , diffTime , memory , data)
*/
public function readFile($date , $appid , $op , $startNum=0 , $length=0 , $jsonFlag=false , $condition=array())
{
$data['data'] = "";
$data['count'] = 0;
$index = $startNum;
$startNum = empty($startNum) ? 0 : $startNum;
$length = empty($length) ? $this->limit : $length;
$handle = self::_openFile($date , $appid , $op );
$line_number=0;
if($handle)
{
$handle->seek($startNum);
$handle->setMaxLineLen($this->length);
while (intval($line_number) - intval($startNum) < intval($length)-1)
{
$tmp = $handle->current();
if(empty($tmp)) continue;
$tmp = self::_parseData($tmp , $jsonFlag);
$line_number = $handle->key();
!$jsonFlag && $condition= array();
if(isset($condition) && $condition)
{
$key = array_keys($condition);
if(in_array($tmp['data'][$key[0]], $condition[$key[0]]))
{
$data['count']++;
$data['data'][$line_number] = $tmp;
}
}
else
{
$data['data'][$line_number] = $tmp;
$data['count']++;
}
if(intval($line_number) - intval($startNum) >= intval($length)-1) break;
unset($tmp);
$handle->next();
}
unset($tmp , $length , $line_number , $condition);
}
$data['diffTime'] = doubleval(microtime(true)) - doubleval($this->startTime);
$data['memory'] = doubleval((doubleval(memory_get_usage(true)) - doubleval(self::$startMemory))/1024/1024) . ' M';
return $data;
}