node.js-http模塊深入理解

http模塊主要用于搭建HTTP服務(wù)端和客戶端,使用HTTP服務(wù)器或客戶端功能都必須調(diào)用http模塊。

創(chuàng)建服務(wù)器

var http = require(“http”);var url = require(“url”);//創(chuàng)建服務(wù)器//http繼承自tcpvar server = http.createServer(function (req,res) {    var urlstr = req.url;//獲取請(qǐng)求的路徑    var urlMethod = req.method;//獲取請(qǐng)求的方法    var urlObj = url.parse(urlstr,true);    console.log(urlObj);    
    console.log(urlMethod);    res.end(“hello”);});server.listen(8080);

對(duì)請(qǐng)求進(jìn)行處理

請(qǐng)求分為兩種:get和post,get請(qǐng)求url地址帶參數(shù),req.url便能獲取參數(shù),而post請(qǐng)求便復(fù)雜一些。使用req.on()處理post請(qǐng)求。

  1. post請(qǐng)求方式:使用req.on("data"function(){})方式讀取,使用str字符串拼接,在req.on("end",function(){})讀取結(jié)束后輸出str便是我們想得到的post請(qǐng)求發(fā)送的參數(shù);
  2. get請(qǐng)求方式:在請(qǐng)求地址上使用url.parse(req.url,true).query得到參數(shù)。
var http = require("http");
var fs = require("fs");
var url = require("url");
var querystring = require("querystring");
var server = http.createServer(function (req,res) {
    console.log(req.method);
    var pathname = url.parse(req.url,true).pathname;
    if(pathname=="/"){
    //    加載注冊(cè)頁(yè)面
        var rs = fs.createReadStream("post.html");
        rs.pipe(res);
    }else if(pathname=="/post"){
        // 處理post請(qǐng)求
        var str = "";
        req.on("data",function (chunk) {
            // console.log(chunk.toString());
            str += chunk;
        });
        req.on("end",function(){
            var postObj = querystring.parse(str);
            console.log(postObj);
        })
    }else if(pathname=="/get"){
        // get請(qǐng)求
        var getObj = url.parse(req.url,true).query;
        res.write(JSON.stringify(getObj));
        res.end();
    }else if(pathname!="/favicon.ico"){
        var rs = fs.createReadStream("."+pathname);
        rs.pipe(res);
    };
});
server.listen(8787);

上傳文件處理

前端html代碼如下:就不細(xì)說(shuō)了。

<form action=“/upimg” method=“post” enctype=“multipart/form-data”>    用戶名: <input type=“text” name=“user”><br>    密碼: <input type=“password” name=“pass”><br>    上傳圖片: <input type=“file” name=“file1”><br>    <input type=“submit” value=“提交”></form>

想要實(shí)現(xiàn)文件上傳,要引入formidable模塊var formidable = require("formidable");若是沒(méi)有此模塊,在終端輸入 npm install formidable安裝。
form.parse(req,function(err,fields,fies){})方法回調(diào)函數(shù)的三個(gè)參數(shù)

  • err:返回錯(cuò)誤信息
  • fields:post請(qǐng)求返回的字段以及對(duì)應(yīng)的值
  • fies:上傳的文件對(duì)象,對(duì)象中包含文件的很多詳細(xì)信息
    得到文件信息后,使用數(shù)據(jù)流的讀和寫復(fù)制文件
var http = require("http");
var fs = require("fs");
var url = require("url");
// 文件上傳
var formidable = require("formidable");
var server = http.createServer(function(req,res){
    var pathname = url.parse(req.url,true).pathname;
    if(pathname=="/"){
        var rs = fs.createReadStream("uploads.html");
        rs.pipe(res);
    }else if(pathname=="/uploads"){
       // 實(shí)例化一個(gè)formidable類
        var form = new formidable.IncomingForm();
      // 調(diào)用parse方法
        form.parse(req,function(err,fields,files){
            if(err){
                return console.log(err);
            }else{
                // console.log("字段",fields);
                // 存儲(chǔ)字段
                var fieldStr = JSON.stringify(fields);
                fs.writeFileSync("1.txt",fieldStr);
                // 轉(zhuǎn)存文件
                if(!fs.existsSync("uploads")){
                    fs.mkdir("uploads");
                }
              // 隨機(jī)路徑
                var filePath = files.img.path;
                var rs = fs.createReadStream(filePath);
                var ws = fs.createWriteStream("./uploads/"+files.img.name);
                rs.pipe(ws);
                rs.on("data",function (chunk) {
                    
                })
                rs.on("end",function(){
                    console.log("復(fù)制成功");
                    res.write("上傳成功");
                    res.end();
                })
                res.setHeader("Content-type","text/html;charset=utf8");   
                console.log("文件",files);
            }
        })

    }else if(pathname!="/favicon.ico"){
        var rs = fs.createReadStream("."+pathname);
        rs.pipe(res);
    }
});
server.listen(8880);

http模擬客戶端

主要是options的配置,最基本的參數(shù)如下面的代碼塊。

  1. method:說(shuō)明請(qǐng)求方式;
  2. host: 服務(wù)器ip,這里以本地localhost為例;
  3. port:服務(wù)器端口號(hào);
  4. path:請(qǐng)求路徑;
    此時(shí)不在使用http.createServer()創(chuàng)建服務(wù)器了,而是使用http.request()請(qǐng)求服務(wù)器,其余的都和服務(wù)器差不多了。
// 通過(guò)nodejs模擬客戶端
var http = require("http");
var options = {
    method:"post",
    host:"localhost",
    port:2121,
    path:"/"
};
var request = http.request(options,function (res) {
    var str = "";
    res.on("data",function(chunk){
        str += chunk;
    });
    res.on("end",function () {
        console.log(str);
    })
});
var obj = {
    name:"李四",
    age:20
}
request.write(JSON.stringify(obj));
request.end();
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容