詳解PHP如何在兩個(gè)大文件中找出相同記錄
1、引言
給定a,b兩個(gè)文件, 分別有x,y行數(shù)據(jù), 其中(x, y均大于10億), 機(jī)器內(nèi)存限制100M,該如何找出其中相同的記錄?
2、思路
- 處理該問題的困難主要是無法將這海量數(shù)據(jù)一次性讀進(jìn)內(nèi)存中.
- 一次性讀不進(jìn)內(nèi)存中,那么是否可以考慮多次呢?如果可以,那么多次讀入要怎么計(jì)算相同的值呢?
- 我們可以用分治思想, 大而化小。相同字符串的值hash過后是相等的, 那么我們可以考慮使用hash取模, 將記錄分散到n個(gè)文件中。這個(gè)n怎么取呢?PHP 100M內(nèi)存,數(shù)組大約可以存100w的數(shù)據(jù), 那么按a,b記錄都只有10億行來算, n至少要大于200。
- 此時(shí)有200個(gè)文件,相同的記錄肯定在同一個(gè)文件中,并且每個(gè)文件都可以全部讀進(jìn)內(nèi)存。那么可以依次找出這200個(gè)文件中各自相同的記錄,然后輸出到同一個(gè)文件中,得到的最終結(jié)果就是a, b兩個(gè)文件中相同的記錄。
- 找一個(gè)小文件中相同的記錄很簡(jiǎn)單了吧,將每行記錄作為hash表的key, 統(tǒng)計(jì)key的出現(xiàn)次數(shù)>=2就可以了。
3、實(shí)操
10億個(gè)文件太大了,實(shí)操浪費(fèi)時(shí)間,達(dá)到實(shí)踐目的即可。
問題規(guī)??s小為: 1M內(nèi)存限制, a, b各有10w行記錄, 內(nèi)存限制可以用PHP的ini_set('memory_limit', '1M');
來限制。
4、生成測(cè)試文件
生成隨機(jī)數(shù)用于填充文件:
/** * 生成隨機(jī)數(shù)填充文件 * Author: ClassmateLin * Email: classmatelin.site@gmail.com * Site: https://www.classmatelin.top * @param string $filename 輸出文件名 * @param int $batch 按多少批次生成數(shù)據(jù) * @param int $batchSize 每批數(shù)據(jù)的大小 */ function generate(string $filename, int $batch=1000, int $batchSize=10000) { for ($i=0; $i<$batch; $i++) { $str = ''; for ($j=0; $j<$batchSize; $j++) { $str .= rand($batch, $batchSize) . PHP_EOL; // 生成隨機(jī)數(shù) } file_put_contents($filename, $str, FILE_APPEND); // 追加模式寫入文件 } } generate('a.txt', 10); generate('b.txt', 10);
5、分割文件
將a.txt
, b.txt
通過hash取模的方式分割到n個(gè)文件中.
/** * 用hash取模方式將文件分散到n個(gè)文件中 * Author: ClassmateLin * Email: classmatelin.site@gmail.com * Site: https://www.classmatelin.top * @param string $filename 輸入文件名 * @param int $mod 按mod取模 * @param string $dir 文件輸出目錄 */ function spiltFile(string $filename, int $mod=20, string $dir='files') { if (!is_dir($dir)){ mkdir($dir); } $fp = fopen($filename, 'r'); while (!feof($fp)){ $line = fgets($fp); $n = crc32(hash('md5', $line)) % $mod; // hash取模 $filepath = $dir . '/' . $n . '.txt'; // 文件輸出路徑 file_put_contents($filepath, $line, FILE_APPEND); // 追加模式寫入文件 } fclose($fp); } spiltFile('a.txt'); spiltFile('b.txt');
執(zhí)行 splitFile
函數(shù), 得到如下圖 files
目錄的20個(gè)文件。
6、查找重復(fù)記錄
現(xiàn)在需要查找20個(gè)文件中相同的記錄, 其實(shí)也就是找一個(gè)文件中的相同記錄,操作個(gè)20次。
找一個(gè)文件中的相同記錄:
/** * 查找一個(gè)文件中相同的記錄輸出到指定文件中 * Author: ClassmateLin * Email: classmatelin.site@gmail.com * Site: https://www.classmatelin.top * @param string $inputFilename 輸入文件路徑 * @param string $outputFilename 輸出文件路徑 */ function search(string $inputFilename, $outputFilename='output.txt') { $table = []; $fp = fopen($inputFilename, 'r'); while (!feof($fp)) { $line = fgets($fp); !isset($table[$line]) ? $table[$line] = 1 : $table[$line]++; // 未設(shè)置的值設(shè)1,否則自增 } fclose($fp); foreach ($table as $line => $count) { if ($count >= 2){ // 出現(xiàn)大于2次的則是相同的記錄,輸出到指定文件中 file_put_contents($outputFilename, $line, FILE_APPEND); } } }
找出所有文件相同記錄:
/** * 從給定目錄下文件中分別找出相同記錄輸出到指定文件中 * Author: ClassmateLin * Email: classmatelin.site@gmail.com * Site: https://www.classmatelin.top * @param string $dirs 指定目錄 * @param string $outputFilename 輸出文件路徑 */ function searchAll($dirs='files', $outputFilename='output.txt') { $files = scandir($dirs); foreach ($files as $file) { $filepath = $dirs . '/' . $file; if (is_file($filepath)){ search($filepath, $outputFilename); } } }
到這里已經(jīng)解決了大文件處理的空間問題,那么時(shí)間問題該如何處理? 單機(jī)可通過利用CPU的多核心處理,不夠的話通過多臺(tái)服務(wù)器處理。
7、完整代碼
<?php ini_set('memory_limit', '1M'); // 內(nèi)存限制1M /** * 生成隨機(jī)數(shù)填充文件 * Author: ClassmateLin * Email: classmatelin.site@gmail.com * Site: https://www.classmatelin.top * @param string $filename 輸出文件名 * @param int $batch 按多少批次生成數(shù)據(jù) * @param int $batchSize 每批數(shù)據(jù)的大小 */ function generate(string $filename, int $batch=1000, int $batchSize=10000) { for ($i=0; $i<$batch; $i++) { $str = ''; for ($j=0; $j<$batchSize; $j++) { $str .= rand($batch, $batchSize) . PHP_EOL; // 生成隨機(jī)數(shù) } file_put_contents($filename, $str, FILE_APPEND); // 追加模式寫入文件 } } /** * 用hash取模方式將文件分散到n個(gè)文件中 * Author: ClassmateLin * Email: classmatelin.site@gmail.com * Site: https://www.classmatelin.top * @param string $filename 輸入文件名 * @param int $mod 按mod取模 * @param string $dir 文件輸出目錄 */ function spiltFile(string $filename, int $mod=20, string $dir='files') { if (!is_dir($dir)){ mkdir($dir); } $fp = fopen($filename, 'r'); while (!feof($fp)){ $line = fgets($fp); $n = crc32(hash('md5', $line)) % $mod; // hash取模 $filepath = $dir . '/' . $n . '.txt'; // 文件輸出路徑 file_put_contents($filepath, $line, FILE_APPEND); // 追加模式寫入文件 } fclose($fp); } /** * 查找一個(gè)文件中相同的記錄輸出到指定文件中 * Author: ClassmateLin * Email: classmatelin.site@gmail.com * Site: https://www.classmatelin.top * @param string $inputFilename 輸入文件路徑 * @param string $outputFilename 輸出文件路徑 */ function search(string $inputFilename, $outputFilename='output.txt') { $table = []; $fp = fopen($inputFilename, 'r'); while (!feof($fp)) { $line = fgets($fp); !isset($table[$line]) ? $table[$line] = 1 : $table[$line]++; // 未設(shè)置的值設(shè)1,否則自增 } fclose($fp); foreach ($table as $line => $count) { if ($count >= 2){ // 出現(xiàn)大于2次的則是相同的記錄,輸出到指定文件中 file_put_contents($outputFilename, $line, FILE_APPEND); } } } /** * 從給定目錄下文件中分別找出相同記錄輸出到指定文件中 * Author: ClassmateLin * Email: classmatelin.site@gmail.com * Site: https://www.classmatelin.top * @param string $dirs 指定目錄 * @param string $outputFilename 輸出文件路徑 */ function searchAll($dirs='files', $outputFilename='output.txt') { $files = scandir($dirs); foreach ($files as $file) { $filepath = $dirs . '/' . $file; if (is_file($filepath)){ search($filepath, $outputFilename); } } } // 生成文件 generate('a.txt', 10); generate('b.txt', 10); // 分割文件 spiltFile('a.txt'); spiltFile('b.txt'); // 查找記錄 searchAll('files', 'output.txt');
到此這篇關(guān)于詳解PHP如何在兩個(gè)大文件中找出相同記錄的文章就介紹到這了,更多相關(guān)PHP文件相同記錄內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
dedecms系統(tǒng)的廣告設(shè)置代碼 基礎(chǔ)版本
dedecms系統(tǒng)的廣告設(shè)置代碼 基礎(chǔ)版本,需要的朋友可以參考下。2010-04-04PHP數(shù)據(jù)庫操作二:memcache用法分析
這篇文章主要介紹了PHP數(shù)據(jù)庫操作memcache用法,結(jié)合實(shí)例形式詳細(xì)分析了memcache的下載、安裝、配置及相關(guān)使用技巧,需要的朋友可以參考下2017-08-08淺析關(guān)于PHP位運(yùn)算的簡(jiǎn)單權(quán)限設(shè)計(jì)
本篇文章是對(duì)PHP位運(yùn)算的簡(jiǎn)單權(quán)限設(shè)計(jì)進(jìn)行了詳細(xì)的分析介紹,需要的朋友參考下2013-06-06apache2.2.4+mysql5.0.77+php5.2.8安裝精簡(jiǎn)
linux下apache php環(huán)境的配置方法。2009-04-04