Node.js 是单进程单线程应用程序，但是通过事件和回调支持并发，所以性能非常高。
nodejs由以下模块组成:
引入 required 模块：我们可以使用 require 指令来载入 Node.js 模块。
创建服务器：服务器可以监听客户端的请求，类似于 Apache 、Nginx 等 HTTP 服务器。
接收请求与响应请求 服务器很容易创建，客户端可以使用浏览器或终端发送 HTTP 请求，服务器接收请求后返回响应数据。
创建服务器
首先要引入http模块
var http = require("http");
通过
http.createServer() 方法创建服务器
demo:
var http = require('http');http.createServer(function (request, response) { // 发送 HTTP 头部 // HTTP 状态值: 200 : OK // 内容类型: text/plain response.writeHead(200, {'Content-Type': 'text/plain'}); // 发送响应数据 "Hello World" response.end('Hello World\n');}).listen(8888);// 终端打印如下信息console.log('Server running at http://127.0.0.1:8888/');
写入数据可以使用write()
response.write("Hello World");
response.write(" IAM LQ");
response.write(data.toString());
response.end();
使用package.json
npm init 去创建
Node.js REPL交互式解释器
http://www.runoob.com/nodejs/nodejs-repl.html
Nodejs 回调函数
demo:
var http=require('http');//http服务
var fs = require("fs");//读取文件
http.createServer(function(request,response){
response.writeHead(200,{'Content-Type':'text/plain'});
//读取文件信息 将返回值 给response
//var data = fs.readFileSync('input.txt'); 这种方式 是 同步
fs.readFile('message.txt', function (err, data) {
if (err) return console.error(err);
response.end(data.toString());
});
}).listen(8888);
console.log('运行在 http://localhost:"8888');
Nodejs 事件循环
绑定和监听事件 需要引入events 模块 并且通过EventEmitter 类来绑定和监听事件
eventEmitter.on('你起的名字',function(){
//这里是这个事件对应的do something
})
eventEmitter.emit('你起的名字');//这样子去执行你写好的事件
demo：
// 引入 events 模块
var events = require('events');
// 创建 eventEmitter 对象
var eventEmitter = new events.EventEmitter();
//创建链接函数
eventEmitter.on('connection',function(){
console.log('链接成功');
eventEmitter.emit('data_received');
});
// 使用匿名函数绑定 data_received 事件
eventEmitter.on('data_received', function(){
console.log('数据接收成功。');
});
// 触发 connection 事件
eventEmitter.emit('connection');
console.log("程序执行完毕。");
Buffer缓冲区
专门存放二进制数据
new Buffer创建buffer对象实例 write返回实际写入的大小
写入demo:
var buf = new Buffer(256);
var len = buf.write("www.runoob.cn",0,8,"utf8");//数据，开始下标，能存多少位，编码方式
console.log("写入字节数 : "+ len);//8
存入汉子并且打印出来:
var buf = new Buffer('你好我是数据');
console.log(buf.toString());
合并buffer:
var buffer1 = new Buffer('菜鸟教程 ');var buffer2 = new Buffer('www.runoob.com');var buffer3 = Buffer.concat([buffer1,buffer2]);console.log("buffer3 内容: " + buffer3.toString());
Node.js Stream(流)
http 服务器发起请求的request 对象就是一个 Stream
createWriteStream//写入流
createReadStream//读取流
创建对象并且指向文件对象
var readerStream = fs.createReadStream('input.txt');
var writerStream = fs.createWriteStream('output.txt');
写入数据 并且定义编码规范
var data='我是写入的数据'
writerStream.write(data,'UTF8');
读取数据并且打印
// 设置编码为 utf8。
var data='';
readerStream.setEncoding('utf8');
// 读取数据并且打印
readerStream.on('data', function(data) {
data = data;
console.log(data);
});
以下是数据copy 一个文件读取存入另一个文件
var fs = require("fs");
// 创建一个可读流
var readerStream = fs.createReadStream('message.txt');
// 创建一个可写流
var writerStream = fs.createWriteStream('book.txt');
// 管道读写操作
// 读取 input.txt 文件内容，并将内容写入到 output.txt 文件中
readerStream.pipe(writerStream);
console.log("程序执行完毕");
压缩文件
var fs = require("fs");var zlib = require('zlib');// 压缩 input.txt 文件为 input.txt.gzfs.createReadStream('input.txt') .pipe(zlib.createGzip()) .pipe(fs.createWriteStream('input.txt.gz')); console.log("文件压缩完成。");
解压文件
var fs = require("fs");var zlib = require('zlib');// 解压 input.txt.gz 文件为 input.txtfs.createReadStream('input.txt.gz') .pipe(zlib.createGunzip()) .pipe(fs.createWriteStream('input.txt')); console.log("文件解压完成。");
nodejs 模块系统
优先加载原生模块 例如http、fs、path等
var http=require('http');
module.exports=function(){} or 对象
Nodejs函数
和JS一样
nodejs路由
我们需要的所有数据都会包含在request对象中，该对象作为onRequest()回调函数的第一个参数传递。但是为了解析这些数据，我们需要额外的Node.JS模块，它们分别是url和querystring模块。
说白了就是路径
var pathname = url.parse('http://baidu.com/a/b?a=1').pathname;
var router=url.parse('http://baidu.com/a/b?a=1').query
response.write(pathname+" "+router);
会出现 /a/b a=1
node全局对象
response.write(__filename);D:\nodejsdemo\global.js
response.write(__dirname);D:\nodejsdemo
setTimeout(cb, ms)
clearTimeout(t)
setInterval(cb, ms)
console
process process 是一个全局变量，即 global 对象的属性。 和系统交互要用到
nodejs常用工具 util
util 是一个Node.js 核心模块，提供常用函数的集合，用于弥补核心JavaScript 的功能 过于精简的不足。
用于继承
util.inherits（child,parent）
只能继承原型中定义的函数 即通过prototype扩展的函数
构造函数内部创造的不继承
util.inspect任意对象转换 为字符串的方法，通常用于调试和错误输出。它至少接受一个参数 object，即要转换的对象。
util.isArray(object)如果给定的参数 "object" 是一个数组返回true，否则返回false。
util.isRegExp(object)如果给定的参数 "object" 是一个正则表达式返回true，否则返回false。
util.isDate(object)如果给定的参数 "object" 是一个日期返回true，否则返回false。
util.isError(object)如果给定的参数 "object" 是一个错误对象返回true，否则返回false。
应用框架Express
安装:npm install express --save
以下几个重要的模块需要与express一起安装:
$ npm install body-parser --save$ npm install cookie-parser --save$ npm install multer --save
body-parser 处理JSON RAW Text URL编码的数据
cookie-parser解析cookie的工具 通过req.cookies 可以取到传来的cookie 转成对象
multer 处理enctype="multpart/form-data"的表单数据
demo: 这里配置路由
var express=require('express');
var app=express();
app.get('/',function(req,res){
res.send('HELLO WORD2');
})
app.get('/app',function(req,res){
res.send('进入了另一个路径');
})
var server=app.listen(8888,function(){
var host=server.address().address
var port=server.address().port
console.log("应用实例，访问地址为 http://", host, port)
})
静态资源
app.use(express.static('public'))
http://localhost:8888/img/2.png 就不用写public了
设置路由 编写接口
var express=require('express');
var app=express();
//静态文件
app.use(express.static('public'))
//设置默认入口
app.get('/',function(req,res){
res.sendFile(__dirname+"/"+"index.html");
})
//接口
app.get('/message',function(req,res){
res.writeHead(200,{'Content-Type':'text/html;charset=utf-8'});//设置response编码为utf-8
obj={
id:req.query.id,
name:req.query.name
}
res.end(JSON.stringify(obj));
})
var server=app.listen(8888,function(){
var host=server.address().address
var port=server.address().port
console.log("应用实例，访问地址为 http://", host, port)
})
Post的demo：必须要引入body-parser 需要安装依赖
var urlencodedParser = bodyParser.urlencoded({ extended: false }) 是必须的
var express=require('express');
var app=express();
var bodyParser = require('body-parser');
// 创建 application/x-www-form-urlencoded 编码解析
var urlencodedParser = bodyParser.urlencoded({ extended: false })
//静态文件
app.use(express.static('public'))
//设置默认入口
app.get('/',function(req,res){
res.sendFile(__dirname+"/"+"post.html");
})
//接口
app.post('/message',urlencodedParser,function(req,res){
res.writeHead(200,{'Content-Type':'text/html;charset=utf-8'});//设置response编码为utf-8
obj={
id:req.body.id,
name:req.body.name
}
res.end(JSON.stringify(obj));
})
var server=app.listen(8888,function(){
var host=server.address().address
var port=server.address().port
console.log("应用实例，访问地址为 http://", host, port)
})
网友评论