log.php

<?php
/**
 * 日志读写相关函数
 * @author: horsley
 * @version: 2014-01-29
 */

/**
 * 为日志建立索引
 * @return bool|int
 */
function make_index() {
    $handle = @fopen(DATA_FILE, 'r');
    if ($handle) {
        $buffer = '';$index = '';$offset = 0;
        do {
            $offset += strlen($buffer);
            $index .= pack('L', $offset);
        } while (($buffer = fgets($handle)) !== false);

        if (!feof($handle)) {
            return false;
        }
        fclose($handle);

        return file_put_contents(DATA_INDEX, $index, LOCK_EX);
    } else {
        return false;
    }
}

/**
 * 分页读取
 * @param int $page_num
 * @param int $page_size
 * @param bool $is_last_page 是否最后一页
 * @return bool
 */
function paged_read_lines($page_num = 0, $page_size = 300, &$is_last_page = true) {
    //利用索引定位
    $handle = @fopen(DATA_INDEX, 'r');
    if (!$handle) {return false;}
    $index_stat = fstat($handle);
    $total_lines = $index_stat['size'] / 4; //总行数 包含最后一行是空白行

    fseek($handle, - ($page_num + 1) * $page_size * 4 - 4, SEEK_END); //如果页数太大肯定会seek到开头
    if (ftell($handle) == 0) {
        $is_last_page = true;
        $page_size = $total_lines % $page_size; //最后一页条目数量的特殊处理
    } else {
        $is_last_page = false;
    }

    $pos = unpack('Loffset', fread($handle, 4));
    $pos = array_pop($pos);
    fclose($handle);
    //读取单页数据
    $handle = @fopen(DATA_FILE, 'r');
    if ($handle) {
        fseek($handle, $pos, SEEK_SET);
        $line_count = 0;$ret = array();
        while ((($buffer = fgets($handle)) !== false) && $line_count < $page_size) {
            $ret[] = htmlspecialchars($buffer);
            $line_count++;
        }
        fclose($handle);

        return $ret;
    } else {
        return false;
    }
}

function write_line($log_line) { //@todo: 这里再并发情况下没办法保持写入索引和数据事务的一致性，应该用一个另外的锁
    if (!file_exists(DATA_INDEX)) file_put_contents(DATA_INDEX, pack('L', 0), FILE_APPEND|LOCK_EX); //所以首次写入应该有0
    if (!file_put_contents(DATA_FILE, $log_line, FILE_APPEND|LOCK_EX)) return false;
    if (!file_put_contents(DATA_INDEX, pack('L', filesize(DATA_FILE)), FILE_APPEND|LOCK_EX)) return false;
    return true;
}