/*
 * File:   dread.cpp
 * Author: 肖武<[email protected]>
 *
 * Created on 2013年10月31日, 上午10:02
 *
 * 延時讀取(delayed read)檔案
 */

#include <cstdlib>
#include <iostream>
#include <ctime>
#include <fstream>

using namespace std;

/*
 *
 */
int main(int argc, char* argv[]) {
	//引數變數初始化
	string in_file;
	int sleep_time = 3;
	time_t end_time = 0;

	//獲取引數
	int ch;
	opterr = 0; //選項錯誤時不讓報錯
	while ((ch = getopt(argc, argv, "s:t:f:")) != -1) {
		switch (ch) {
			case 'f': in_file = string(optarg);break;
			case 't': end_time = atol(optarg); break;
			case 's': sleep_time = atoi(optarg); break;
		}
	}

	//引數檢查
	if (in_file == "") {
		cout<<
				"延時讀取(delayed read)檔案 v1.0\n"
				"用法："<<argv[0]<<" -f file_path [-s sleep_time] [-e end_time]\n"
				"選項：\n"
				"\t-f\t必須，讀取的檔案路徑\n"
				"\t-s\t可選，讀到檔案末尾時休眠的秒數。預設為3\n"
				"\t-e\t可選，結束時間戳，在此時間之前讀到檔案末尾時不會退出，而是休眠sleep_time秒後再次讀取。預設為0\n\n"
				"作者：肖武<
 
[email protected]>"
		<<endl;
		return 1;
	}


	ifstream ifs(in_file.c_str(), ios::in);
	if (!ifs.is_open()) {
		cerr<<"開啟資料檔案失敗:"<<in_file<<endl;
		return 1;
	}

	string row;
	string val;
	size_t seek = 0;
	time_t now = 0;
	while(1) {
		if (ifs.peek() == EOF) {
			time(&now);
			if (now > end_time) {
				break;
			}
			ifs.clear();
			sleep(sleep_time);
			ifs.seekg(seek, ios::beg);
			continue;
		}

		getline(ifs, row);
		seek = ifs.tellg();
		cout<<row<<endl;
	}
	ifs.close();

	return 0;
}
 

$ g++ -o dread dread.cpp 

使用

[[email protected] dread]# ./dread 
延時讀取(delayed read)檔案 v1.0
用法：./dread -f file_path [-s sleep_time] [-e end_time]
選項：
	-f	必須，讀取的檔案路徑
	-s	可選，讀到檔案末尾時休眠的秒數。預設為3
	-e	可選，結束時間戳，在此時間之前讀到檔案末尾時不會退出，而是休眠sleep_time秒後再次讀取。預設為0

作者：肖武<[email protected]>

使用場景舉例：日誌檔案處理

日誌實時產生，追加方式寫入檔案中，每小時一個檔案。現需要每小時結束時儘快分析處理上個小時的日誌資料，形成統計報表。那麼單條日誌的預處理工作就可以提前進行，如下

$ ./dread -f log/2013/10/31/12.txt -t `date -d "2013-10-31 13:01"` |awk '{#日誌處理.....}' > ret.txt