http 模块主要用于搭建 HTTP 服务端和客户端,使用 HTTP 服务器或客户端功能都必须调用 http 模块.
创建服务器
var http = require("http");
var url = require("url");//创建服务器
//http继承自tcp
var server = http.createServer(function (req,res) {
var urlstr = req.url;//获取请求的路径
var urlMethod = req.method;//获取请求的方法
var urlObj = url.parse(urlstr,true);
console.log(urlObj);
console.log(urlMethod);
res.end("hello");
});server.listen(8080);
对请求进行处理
请求分为两种:get 和 post,get 请求 url 地址带参数,req.url 便能获取参数,而 post 请求便复杂一些.使用 req.on() 处理 post 请求.
post 请求方式:使用 req.on("data"function(){}) 方式读取,使用 str 字符串拼接,在 req.on("end",function(){}) 读取结束后输出 str 便是我们想得到的 post 请求发送的参数;
get 请求方式:在请求地址上使用 url.parse(req.url,true).query 得到参数.
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=="/"){
// 加载注册页面
var rs = fs.createReadStream("post.html");
rs.pipe(res);
}else if(pathname=="/post"){
// 处理post请求
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请求
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 代码如下:就不细说了.
<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>
想要实现文件上传,要引入 formidable 模块 var formidable = require("formidable"); 若是没有此模块,在终端输入 npm install formidable 安装.
form.parse(req,function(err,fields,fies){}) 方法回调函数的三个参数
err: 返回错误信息
fields:post 请求返回的字段以及对应的值
fies: 上传的文件对象,对象中包含文件的很多详细信息
得到文件信息后,使用数据流的读和写复制文件
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") {
// 实例化一个formidable类
var form = new formidable.IncomingForm();
// 调用parse方法
form.parse(req,
function(err, fields, files) {
if (err) {
return console.log(err);
} else {
// console.log("字段",fields);
// 存储字段
var fieldStr = JSON.stringify(fields);
fs.writeFileSync("1.txt", fieldStr);
// 转存文件
if (!fs.existsSync("uploads")) {
fs.mkdir("uploads");
}
// 随机路径
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("复制成功");
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 的配置,最基本的参数如下面的代码块.
method: 说明请求方式;
host: 服务器 ip,这里以本地 localhost 为例;
port: 服务器端口号;
path: 请求路径;
此时不在使用 http.createServer() 创建服务器了,而是使用 http.request() 请求服务器,其余的都和服务器差不多了.
// 通过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();
来源: http://www.jianshu.com/p/2c124203616a