您好,登錄后才能下訂單哦!
這篇文章主要介紹NodeJs如何實(shí)現(xiàn)簡(jiǎn)易WEB上傳下載服務(wù)器,文中介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們一定要看完!
項(xiàng)目上的需求是集群均可生成PDF文件或是訪問PDF文件,但是沒有文件服務(wù)器,故做一個(gè)簡(jiǎn)易的文件服務(wù)器。
解決方案:集群內(nèi)的機(jī)器(客戶端)生成PDF文件之后將PDF文件推給文件服務(wù)器,我們暫且稱它為服務(wù)端;如果某個(gè)客戶端需要訪問到這個(gè)PDF文件,則去服務(wù)端獲?。ㄒ?yàn)榭赡芷渌蛻舳艘呀?jīng)生成了該P(yáng)DF文件),如果沒有找到,則自己客戶端生成PDF文件,再將PDF文件推給服務(wù)端。
為了實(shí)施簡(jiǎn)易,現(xiàn)采取NodeJs來實(shí)現(xiàn)一個(gè)小程序。 不多說,直接上代碼:
server.js
var express = require('express'); var url = require('url'); var fs = require('fs'); var http = require('http'); var queryString = require('querystring'); var bodyParser = require('body-parser'); var path=require('path'); var app = express(); app.use(bodyParser.json({limit:'1000kb'})); app.use(bodyParser.urlencoded({limit:'1000kb',extended:true})); var count=0; app.post('/upload.node',function(req,resp){ console.log('上傳請(qǐng)求 '+ (new Date())); var data = new Buffer(req.body.fileData,'base64'); var filePath = req.body.filePath; var pathObj = path.parse(filePath);//對(duì)文件路徑字符串進(jìn)行操作 var responseBody = {}; mkdirsSync(pathObj.dir);//遞歸創(chuàng)建文件目錄 try{ var writerStream = fs.createWriteStream(filePath); writerStream.write(data); writerStream.end(); writerStream.on('finish', function() { console.log('上傳完成 '+ (new Date())); }); writerStream.on('error', function(err){ console.log(err.stack); }); responseBody=JSON.stringify({ returnMsg:'200' }); }catch(err){ console.log('上傳出錯(cuò) '+ (new Date())); responseBody=JSON.stringify({ returnMsg:'400' }); } //寫入文件 //console.log('*** ' + count +' ***'); resp.status(200).end(responseBody.toString()); }); app.post('/download.node',function(req,resp){ console.log('下載請(qǐng)求 '+ (new Date())); var filePath = req.body.filePath; console.log('download'); var responseBody = {}; if(fs.existsSync(filePath)){ var data = fs.readFileSync(filePath); var dataBase64 = data.toString('base64'); responseBody = JSON.stringify({ returnMsg:'200', filePath:filePath, fileData:dataBase64 }); console.log('下載完成 '+ (new Date())); }else{ responseBody=JSON.stringify({ returnMsg:'400' }); console.log('文件未找到 '+ (new Date())); } //console.log('*** ' + ++count +' ***'); resp.status(200).end(responseBody.toString()); }); //遞歸創(chuàng)建文件目錄 同步方法 function mkdirsSync(filePath){ if(fs.existsSync(filePath)){ return true; }else{ if(mkdirsSync(path.dirname(filePath))){ fs.mkdirSync(filePath); return true; } } } var server = app.listen(20001,function(){ console.log('Server started.'); })
提供一個(gè)測(cè)試js代碼.. 瀏覽器通過get請(qǐng)求 http://127.0.0.1:20000/upload.do?filePath=XXXX即可觸發(fā)上傳過程
var express = require('express'); var url = require('url'); var fs = require('fs'); var http = require('http'); var queryString = require('querystring'); var bodyParser = require('body-parser'); var app = express(); app.use(bodyParser.json({limit:'1000kb'})); app.use(bodyParser.urlencoded({limit:'1000kb',extended:true})); var count=0; app.get('/upload.do',function(req,resp){ console.log('upload.do'); //var path = url.parse(req.url).pathname; //console.log('Request for ' + path); var filePath = req.query.filePath; //var fileData = req.query.fileData; var address = req.query.address; upload(filePath,'127.0.0.1',20001); console.log('*** ' + ++count +' ***'); var response = { "first":req.query.filePath, "last":req.query.address }; resp.end(JSON.stringify(response)); }); function upload(filePath,address,port){ var Data = readFile(filePath); var dataBase64 = Data.toString('base64'); console.log(Data); console.log(dataBase64); //var DataJSON = JSON.stringify(Data); //fs.writeFile('D:/input.txt',dataBase64,function(err){ // if(err){ // console.err(err); // } //}); var JsonData = queryString.stringify({ filePath:filePath, fileData:dataBase64 }); //console.log(JsonData); var options = { method: "POST", host : address, port : port, path : '/upload.node', headers: { 'Content-Type':'application/x-www-form-urlencoded' } }; var req = http.request(options, function(res){ res.setEncoding('utf8'); }); req.write(JsonData); req.end(); } function readFile(filePath){ var fileData = ''; try{ fileData = fs.readFileSync(filePath); }catch(e){ fileData = ''; } return fileData; } app.post('/download.do',function(req,resp){ //可直接參考server.js的代碼 }) var server = app.listen(20000,function(){ console.log('Server started.'); })
這僅僅是一個(gè)簡(jiǎn)易的Nodejs程序,直接用此程序去壓測(cè),得到結(jié)果是每秒可處理八十多個(gè)請(qǐng)求,基本上能滿足現(xiàn)在的需求,還有很多改進(jìn)的地方,比如加入緩存,隊(duì)列....等等。
對(duì)于NodeJs本人也只是學(xué)到了一點(diǎn)皮毛,還有很多知識(shí)點(diǎn)沒去探究。大家看看就行。
以上是“NodeJs如何實(shí)現(xiàn)簡(jiǎn)易WEB上傳下載服務(wù)器”這篇文章的所有內(nèi)容,感謝各位的閱讀!希望分享的內(nèi)容對(duì)大家有幫助,更多相關(guān)知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。