這篇文章帶給大家的內容是關於ES6下非同步處理的實例講解,有一定的參考價值,有需要的朋友可以參考一下,希望對你有幫助。
前言
我們以尋找指定目錄下的最大檔案為例,感受從
回呼函數-> Promise -> Generator -> Async
非同步處理方式的改變。
API 介紹
為了實作這個功能,我們需要用到幾個 Nodejs 的 API,所以我們來簡單介紹一下。
fs.readdir
readdir 方法用於讀取目錄,傳回一個包含檔案和目錄的陣列。
fs.stat
stat 方法的參數是一個檔案或目錄,它產生一個對象,該對象包含了該檔案或目錄的具體資訊。此外,物件還有一個 isFile() 方法可以判斷正在處理的到底是一個文件,還是一個目錄。
思路分析
我們基本的實作想法就是:
#用fs.readdir
取得指定目錄的內容資訊
循環遍歷內容訊息,使用fs.stat
取得該檔案或目錄的具體資訊
將具體資訊儲存起來
當全部儲存起來後,篩選其中的是文件的資訊
遍歷比較,找出最大檔案
取得並傳回最大檔案
然後我們直接上程式碼吧。
var fs = require('fs'); var path = require('path'); function findLargest(dir, cb) { // 读取目录下的所有文件 fs.readdir(dir, function(er, files) { if (er) return cb(er); var counter = files.length; var errored = false; var stats = []; files.forEach(function(file, index) { // 读取文件信息 fs.stat(path.join(dir, file), function(er, stat) { if (errored) return; if (er) { errored = true; return cb(er); } stats[index] = stat; // 事先算好有多少个文件,读完 1 个文件信息,计数减 1,当为 0 时,说明读取完毕,此时执行最终的比较操作 if (--counter == 0) { var largest = stats .filter(function(stat) { return stat.isFile() }) .reduce(function(prev, next) { if (prev.size > next.size) return prev return next }) cb(null, files[stats.indexOf(largest)]) } }) }) }) }
使用方式為:
// 查找当前目录最大的文件 findLargest('./', function(er, filename) { if (er) return console.error(er) console.log('largest file was:', filename) });
var fs = require('fs'); var path = require('path'); var readDir = function(dir) { return new Promise(function(resolve, reject) { fs.readdir(dir, function(err, files) { if (err) reject(err); resolve(files) }) }) } var stat = function(path) { return new Promise(function(resolve, reject) { fs.stat(path, function(err, stat) { if (err) reject(err) resolve(stat) }) }) } function findLargest(dir) { return readDir(dir) .then(function(files) { let promises = files.map(file => stat(path.join(dir, file))) return Promise.all(promises).then(function(stats) { return { stats, files } }) }) .then(data => { let largest = data.stats .filter(function(stat) { return stat.isFile() }) .reduce((prev, next) => { if (prev.size > next.size) return prev return next }) return data.files[data.stats.indexOf(largest)] }) }
使用方式為:
findLargest('./') .then(function(filename) { console.log('largest file was:', filename); }) .catch(function() { console.log(error); });
var fs = require('fs'); var path = require('path'); var co = require('co') var readDir = function(dir) { return new Promise(function(resolve, reject) { fs.readdir(dir, function(err, files) { if (err) reject(err); resolve(files) }) }) } var stat = function(path) { return new Promise(function(resolve, reject) { fs.stat(path, function(err, stat) { if (err) reject(err) resolve(stat) }) }) } function* findLargest(dir) { var files = yield readDir(dir); var stats = yield files.map(function(file) { return stat(path.join(dir, file)) }) let largest = stats .filter(function(stat) { return stat.isFile() }) .reduce((prev, next) => { if (prev.size > next.size) return prev return next }) return files[stats.indexOf(largest)] }
使用方式為:
co(findLargest, './') .then(function(filename) { console.log('largest file was:', filename); }) .catch(function() { console.log(error); });
var fs = require('fs'); var path = require('path'); var readDir = function(dir) { return new Promise(function(resolve, reject) { fs.readdir(dir, function(err, files) { if (err) reject(err); resolve(files) }) }) } var stat = function(path) { return new Promise(function(resolve, reject) { fs.stat(path, function(err, stat) { if (err) reject(err) resolve(stat) }) }) } async function findLargest(dir) { var files = await readDir(dir); let promises = files.map(file => stat(path.join(dir, file))) var stats = await Promise.all(promises) let largest = stats .filter(function(stat) { return stat.isFile() }) .reduce((prev, next) => { if (prev.size > next.size) return prev return next }) return files[stats.indexOf(largest)] }
使用方式為:
findLargest('./') .then(function(filename) { console.log('largest file was:', filename); }) .catch(function() { console.log(error); });
https://github.com/mqyqingfeng/Blog
#以上是ES6下異步處理的實例講解的詳細內容。更多資訊請關注PHP中文網其他相關文章!