nodejs 对文件进行 压缩加密和解压缩解密

var fs = require('fs');
var zlib = require('zlib');
var crypto = require('crypto');

function geFileList(path) {
var filesList = [];
readFile(path, filesList);
return filesList;
}

function readFile(path, filesList) {
files = fs.readdirSync(path);
files.forEach(walk);
function walk(file) {
states = fs.statSync(path + '/' + file);
if (states.isDirectory()) {
readFile(path + '/' + file, filesList);
}
else {
var obj = new Object();
obj.size = states.size;
obj.name = file;
obj.path = path + '/' + file;
filesList.push(obj);
}
}
}

var getFileName = function (path) {
var pathList = path.split("/");
var fileName = pathList[pathList.length - 1];
return fileName;
};

var getFileContent = function (filePath, cb) {
fs.readFile(filePath, function (err, buf) {
cb(err, buf);
});
};

var writeFileSync = function (filePath, text) {
fs.writeFileSync(filePath, text);
};

var writeFileAsync = function (filePath, text, cb) {
fs.writeFile(filePath, text, function (err) {
cb(err);
});
};

/********************加密解密部分**************************/

var consts = {
cryptkey: 'S62rgt9rf!nYS5b3',
iv: "Og'Y6Jm-'i#io9Op"
};

function util (){

}
var prot = util.prototype;

prot.md5 = function (str) {
var md5sum = crypto.createHash('md5');
md5sum.update(str);
str = md5sum.digest('hex');
return str;
};

prot.encode = function (content) {
var cipher = crypto.createCipheriv('aes-128-cbc', consts.cryptkey, consts.iv);
cipher.setAutoPadding(true);
var bf = [];
bf.push(cipher.update(content));
bf.push(cipher.final());
return Buffer.concat(bf);
};

prot.decode = function (content) {
var decipher = crypto.createDecipheriv('aes-128-cbc', consts.cryptkey, consts.iv);
decipher.setAutoPadding(true);
try {
var a = [];
a.push(decipher.update(content));
a.push(decipher.final());
return Buffer.concat(a);
} catch (e) {
console.error('decode error:', e.message);
return null;
}
};

/**********************压缩解压缩部分************************/
function gZip(strText, cb) {
zlib.gzip(strText, function (err, bufData) {
cb(err, bufData);
});
}

function unZip(buffer, cb) {
zlib.unzip(buffer, function (err, buf) {
cb(err, buf);
});
}

module.exports = {
"FileUtil": {
"getDirFiles": geFileList,
"getFileName": getFileName,
"writeFileAsync": writeFileAsync,
"writeFileSync": writeFileSync,
"getFileContent": getFileContent
},
"EncodeUtil":util,
"ZipUtil": {
"gZip": gZip,
"unZip": unZip
}
};

var utils = require('./utils');
var async = require('async');

var encodeUtil = new utils.EncodeUtil();

zipEncode();

function zipEncode() {
var fileList = utils.FileUtil.getDirFiles(__dirname + "/jsonFile");
async.each(fileList, function (item, callback) {
var filepath = item.path;
var filename = utils.FileUtil.getFileName(filepath);
utils.FileUtil.getFileContent(filepath, function (err, buf) {
if (!err) {
var bpstr = new Buffer(buf);
utils.ZipUtil.gZip(bpstr, function (err, bufData) {
var encodeBuffer = encodeUtil.encode(bufData);//fs.readFileSync(curPath)
var resultPath = __dirname + "/resFile/" + filename;

utils.FileUtil.writeFileSync(resultPath, encodeBuffer);
callback(err);
});
} else {
callback(err);
}
});
}, function (err, resp) {
if (err) {
console.log("err :", err);
} else {
console.log("success");
decodeUnzip();
}
});
}

function decodeUnzip() {
var fileList = utils.FileUtil.getDirFiles(__dirname + "/resFile");
async.each(fileList, function (item, callback) {
var filepath = item.path;
utils.FileUtil.getFileContent(filepath, function (err, buf) {
if (!err) {
var bpstr = new Buffer(buf);
var decodeBuffer = encodeUtil.decode(bpstr);
utils.ZipUtil.unZip(decodeBuffer, function (err, buf) {
console.log(JSON.parse(buf.toString()));
callback(err);
});
} else {
callback(err);
}
});
}, function (err, resp) {
if (err) {
console.log("err :", err);
} else {
console.log("success");
}
});
}