Node.js核心入门（二）

时间 2019-11-17

原文原文链接

全局对象
经常使用工具
事件机制

Node.js核心入门（二）html

文件系统访问
HTTP服务器与客户端

文件系统 fs

fs 模块是文件操做的封装，它提供了文件的读取、写入、改名、删除、遍历目录、连接等 POSIX 文件系统操做，且全部的方法都有异步和同步的形式。异步方法的最后一个参数都是一个回调函数。传给回调函数的参数取决于具体方法，但回调函数的第一个参数都会保留给异常。若是操做成功完成，则第一个参数会是 null 或 undefined。node

const fs = require('fs');
fs.unlink('/tmp/hello', (err) => {
  if (err) throw err;
  console.log('成功删除 /tmp/hello');
});

复制代码

当使用同步方法时，任何异常都会被当即抛出。可使用 try/catch 来处理异常，或让异常向上冒泡。后端

const fs = require('fs');
fs.unlinkSync('/tmp/hello');
console.log('成功删除 /tmp/hello');

复制代码

1.fs.readFile(path,[options], callback)

fs.readFile(path,[options], callback) 是最简单的读取。它接受一个必选参数filename，表示要读取的文件名。第二个参数options是可选的，表示文件的字符编码。callback是回调函数，用于接收文件的内容。若是不指定options，则 callback 就是第二个参数。回调函数提供两个参数 err和data，err表示有没有错误发生，data是文件内容。若是指定了options， data 是一个解析后的字符串，不然data将会是以Buffer形式表示的二进制数据。例如：数组

fs.readFile('/etc/passwd', 'utf8', callback);
复制代码

须要注意的是，当path是一个目录时，fs.readFile()与fs.readFileSync()的行为与平台有关。在 macOS、Linux 与Windows上，会返回一个错误。在 FreeBSD 上，会返回目录内容的表示。缓存

// 在 macOS、Linux 与 Windows 上：
fs.readFile('<directory>', (err, data) => {
  // => [Error: EISDIR: illegal operation on a directory, read <directory>]
});

//  在 FreeBSD 上：
fs.readFile('<directory>', (err, data) => {
  // => null, <data>
});
复制代码

2.fs.readFileSync(path[, options])

fs.readFileSync(filename,[encoding])是fs.readFile 同步的版本。它接受的参数和fs.readFile相同，但读取到的文件内容会以函数返回值的形式返回。若是有错误发生，fs 将会抛出异常，这时候咱们就须要使用 try 和catch 捕捉并处理异常。bash

3.fs.open(path, flags[, mode], callback)

fs.open(path, flags[, mode], callback)是POSIX open 函数的封装，与 C 语言标准库中的fopen函数相似。它接受两个必选参数，path 为文件的路径，而flags 能够是如下值：服务器

'r' - 以读取模式打开文件。若是文件不存在则发生异常。

'r+' - 以读写模式打开文件。若是文件不存在则发生异常。

'rs+' - 以同步读写模式打开文件。命令操做系统绕过本地文件系统缓存。

（这对 NFS 挂载模式下打开文件颇有用，由于它可让你跳过潜在的旧本地缓存。 它对 I/O 的性能有明显的影响，因此除非须要，不然不要使用此标志。

注意，这不会使 fs.open() 进入同步阻塞调用。 若是那是你想要的，则应该使用 fs.openSync()。）

'w' - 以写入模式打开文件。文件会被建立（若是文件不存在）或截断（若是文件存在）。

'wx' - 相似 'w'，但若是 path 存在，则失败。

'w+' - 以读写模式打开文件。文件会被建立（若是文件不存在）或截断（若是文件存在）。

'wx+' - 相似 'w+'，但若是 path 存在，则失败。

'a' - 以追加模式打开文件。若是文件不存在，则会被建立。

'ax' - 相似于 'a'，但若是 path 存在，则失败。

'a+' - 以读取和追加模式打开文件。若是文件不存在，则会被建立。

'ax+' - 相似于 'a+'，但若是 path 存在，则失败。
复制代码

mode 可设置文件模式（权限和 sticky 位），但只有当文件被建立时才有效。默认为 0o666，可读写。app

4.fs.read(fd, buffer, offset, length, position, callback)

fs.read(fd, buffer, offset, length, position, callback) 是 POSIX read 函数的封装，相比 fs.readFile 提供了更底层的接口。从fd指定的文件中读取数据。buffer 是数据将被写入到的 buffer。offset是buffer 中开始写入的偏移量。length是一个整数，指定要读取的字节数。position指定从文件中开始读取的位置。若是position为null，则数据从当前文件读取位置开始读取，且文件读取位置会被更新。若是position为一个整数，则文件读取位置保持不变。回调有三个参数 (err, bytesRead, buffer)。异步

var fs = require('fs');
fs.open('content.txt', 'r', function(err, fd) {
if (err) {
console.error(err);
return;
}
var buf = new Buffer(8);
fs.read(fd, buf, 0, 8, null, function(err, bytesRead, buffer) {
if (err) {
console.error(err);
return;
}
console.log('bytesRead: ' + bytesRead);
console.log(buffer);
})
});
复制代码

输出：

bytesRead: 8
<Buffer 54 65 78 74 20 e6 96 87>
复制代码

HTTP服务器与客户端

Node.js 标准库提供了http模块，其中封装了一个高效的 HTTP 服务器和一个简易的HTTP 客户端。 http.Server 是一个基于事件的 HTTP 服务器，它的核心由 Node.js 下层 C++ 部分实现，而接口由 JavaScript 封装，兼顾了高性能与简易性。 http.request则是一个HTTP 客户端工具，用于向 HTTP 服务器发起请求，例如实现 Pingback或者内容抓取。

Node.js 中的HTTP接口被设计成支持协议的许多特性。好比，大块编码的消息。这些接口不缓冲完整的请求或响应，用户可以以流的形式处理数据。HTTP消息头由一个对象表示，其中键名是小写的，键值不能修改：

{ 'content-length': '123',
  'content-type': 'text/plain',
  'connection': 'keep-alive',
  'host': 'mysite.com',
  'accept': '*/*' }
复制代码

为了支持各类可能的 HTTP 应用，Node.js的 HTTP API是很是底层的。它只涉及流处理与消息解析。它把一个消息解析成消息头和消息主体，但不解析具体的消息头或消息主体。键名是小写的，键值不能修改。为了支持各类可能的 HTTP 应用，Node.js 的 HTTP API 是很是底层的。它只涉及流处理与消息解析。它把一个消息解析成消息头和消息主体，但不解析具体的消息头或消息主体。

HTTP服务器

http.Server 是 http 模块中的 HTTP 服务器对象，用 Node.js 作的全部基于 HTTP 协议的系统，如网站、社交应用甚至代理服务器，都是基于http.Server实现的。它提供了一套封装级别很低的API，仅仅是流控制和简单的学习解析，而全部的高级功能都是经过它的接口来实现的。好比官网上的这个例子：

const http = require('http');

const hostname = '127.0.0.1';
const port = 3000;

const server = http.createServer((req, res) => {
  res.statusCode = 200;
  res.setHeader('Content-Type', 'text/plain');
  res.end('Hello World\n');
});

server.listen(port, hostname, () => {
  console.log(`Server running at http://${hostname}:${port}/`);
})
复制代码

在这段代码中，就使用了http.createServer([requestListener])来新建一个的 http.Server 实例。如今就先让咱们来看看http.createServer([requestListener])吧。

1. http.Server 的事件

http.Server 是一个基于事件的 HTTP 服务器，全部的请求都被封装为独立的事件，开发者只须要对它的事件编写响应函数便可实现 HTTP 服务器的全部功能。它继承自 EventEmitter ，提供了如下几个事件：

request：每次接收到一个请求时触发。注意，每一个链接可能有多个请求（在 HTTP keep-alive 链接的状况下）。
connection ：当一个新的 TCP 流被创建时触发。socket 是一个 net.Socket 类型的对象。一般用户无需访问该事件。注意，由于协议解析器绑定到 socket 的方式，socket 不会触发 'readable' 事件。socket 也能够经过 request.connection 访问。
connect：每当客户端发送 HTTP CONNECT 请求时触发。若是该事件未被监听，则发送 CONNECT 请求的客户端会关闭链接。当该事件被触发后，请求的 socket 上没有 'data' 事件监听器，这意味着须要绑定 'data' 事件监听器，用来处理 socket 上被发送到服务器的数据。
close：当服务器关闭时，该事件被触发。注意不是在用户链接断开时，而是服务器关闭时。

在这些事件最经常使用的是request是最经常使用的，所以 http 提供了一个捷径： http.createServer([requestListener]) ，功能是建立一个 HTTP 服务器并将requestListener 做为 request 事件的监听函数。咱们上面那个官网的例子就是如此，其实它显式的实现方法是这样的：

//httpserver.js
const http = require('http');
const hostname = '127.0.0.1';
const port = 3000;
const server = new http.Server();
server.on('request', (req, res) => {
  res.statusCode = 200;
  res.setHeader('Content-Type', 'text/plain');
  res.end('Hello World\n');
});
server.listen(port, hostname, () => {
  console.log(`Server running at http://${hostname}:${port}/`);
})
复制代码

2. http.ServerRequest

http.ServerRequest 是 HTTP 请求的信息，是后端开发者最关注的内容。它通常由http.Server 的 request 事件发送，做为第一个参数传递，一般简称 request 或 HTTP 请求通常能够分为两部分：请求头（Request Header）和请求体（Requset Body）。以上内容因为长度较短均可以在请求头解析完成后当即读取。而请求体可能相对较长，须要必定的时间传输，所以 http.ServerRequest 提供了如下3个事件用于控制请求体传输。req。HTTP请求通常能够分为两部分：请求头（RequestHeader）和请求体（RequsetBody）。以上内容因为长度较短均可以在请求头解析完成后当即读取。而请求体可能相对较长，须要必定的时间传输，所以http.ServerRequest提供了如下3个事件用于控制请求体传输。http.ServerRequest提供了3个事件用于控制请求体传输：

data：当请求体数据到来时，该事件被触发，提供一个参数给回调函数，是接受到的数据，该事件可能被屡次调用（全部data按顺序的集合，是请求体数据）。若是该事件没有被监听，请求体将被抛弃；
end：当请求体数据完成时该事件触发。此后再也不触发data事件；

close：用户当前请求结束时，该事件被触发。不一样于end，若是用户强制终止了传输，也仍是调用close。

表4-2  ServerRequest 的属性
     名 称                  含 义
     complete        客户端请求是否已经发送完成
     httpVersion     HTTP 协议版本，一般是 1.0 或 1.1
     method          HTTP 请求方法，如 GET、POST、PUT、DELETE 等
     url             原始的请求路径，例如 /static/image/x.jpg 或 /user?name=byvoid
     headers         HTTP 请求头
     trailers        HTTP 请求尾（不常见）
     connection      当前 HTTP 链接套接字，为 net.Socket 的实例
     socket          connection 属性的别名
     client          client 属性的别名
复制代码

3. 获取 GET 请求内容

注意， http.ServerRequest 提供的属性中没有相似于 PHP 语言中的 _POST 的属性，GET请求被直接内嵌在路径中。URL是完整的请求路径（包括？后面的部分），所以手动解析后面的内容做为GET请求的参数。Node.js的url模块中的parse函数提供了这个功能。

以url：http://127.0.0.1/user?name=byvoid&email=byvoid@byvoid.com为例：

var http = require("http");
var url = require("url");
var server = new http.Server();
server.on("request", function (req, res) {
    if (req.url == "/favicon.ico") {
        return;
    }
    var m = url.parse(req.url, true);
    console.log(m)
    res.writeHead(200, {'Content-type': 'text/html;charset = utf8'});
    res.end();
})
server.listen(80);
console.log("The server begin");
复制代码

console.log输出内容：

Url {
  protocol: null,
  slashes: null,
  auth: null,
  host: null,
  port: null,
  hostname: null,
  hash: null,
  search:'?name=byvoid&email=byvoid@byvoid.com',
  query: { name: 'byvoid', email:'byvoid@byvoid.com' },
  pathname: '/user',
  path:'/user?name=byvoid&email=byvoid@byvoid.com',
  href:'/user?name=byvoid&email=byvoid@byvoid.com' 
}
复制代码

4. 获取 POST 请求内容

HTTP 协议1.1版本提供了8种标准的请求方法，而其中最多见的就是 GET 和 POST。相比GET请求把全部的内容编码到访问路径中，POST 请求的内容所有都在请求体中。http.ServerRequest 并无一个属性内容是在请求体中，缘由是等待请求体传输多是一件耗时的工做，譬如上传文件。而不少时候咱们可能并不须要理会请求体的内容，且恶意的 POST 请求会大大消耗服务器的资源。因此 Node.js 默认是不会解析请求体的，所以当咱们须要的时候，咱们就要手写一个，具体实现方法以下：

var http = require('http');
var querystring = require('querystring');
var util = require('util');
http.createServer(function(req, res) {
    var post = '';
    req.on('data', function(chunk) {
    post += chunk;
});
req.on('end', function() {
    post = querystring.parse(post);
    res.end(util.inspect(post));
    });
}).listen(3000);
复制代码

5.http.ServerResponse

http.ServerResponse 是返回给客户端的信息，决定了用户最终能看到的结果。它也是由 http.Server 的 request 事件发送的，做为第二个参数传递，通常简称为 response 或 res 。http.ServerResponse 有三个重要的成员函数，用于返回响应头、响应内容以及结束请求：

response.writeHead(statusCode, [headers]) ：向请求的客户端发送响应头。statusCode是HTTP状态码，如200（请求成功）、404（未找到）等。headers是一个相似关联数组的对象，表示响应头的每一个属性。该函数在一个请求内最多只能调用一次，若是不调用，则会自动生成一个响应头。
response.write(data, [encoding]) ：向请求的客户端发送响应内容。 data 是一个 Buffer 或字符串，表示要发送的内容。若是 data 是字符串，那么须要指定 encoding 来讲明它的编码方式，默认是 utf-8 。在 response.end 调用以前，response.write 能够被屡次调用。
response.end([data], [encoding]) ：结束响应，告知客户端全部发送已经完成。当全部要返回的内容发送完毕的时候，该函数必须被调用一次。它接受两个可选参数，意义和 response.write 相同。若是不调用该函数，客户端将永远处于等待状态。

HTTP 客户端

http 模块提供了两个函数 http.request和http.get，功能是做为客户端向HTTP服务器发起请求。

1.http.request(options,callback)

http.request(options,callback)发起HTTP请求，它接受两个参数，option是一个相似关联数组的对象，表示请求的参数，callback是请求的回调函数。option经常使用的参数以下所示：

host ：请求网站的域名或 IP 地址。
port ：请求网站的端口，默认 80。
method ：请求方法，默认是 GET。
path ：请求的相对于根的路径，默认是“ / ”。 QueryString 应该包含在其中。例如 /search?query=byvoid 。
headers ：一个关联数组对象，为请求头的内容。

而callback 则传递一个参数，为 http.ClientResponse 的实例。http.request 返回一个http.ClientRequest 的实例，下面是一个经过 http.request 发送 POST 请求的代码：

var http = require('http');
var querystring = require('querystring');
var contents = querystring.stringify({
    name: 'byvoid',
    email: 'byvoid@byvoid.com',
    address: 'Zijing 2#, Tsinghua University',
});
var options = {
    host: 'www.byvoid.com',
    path: '/application/node/post.php',
    method: 'POST',
    headers: {
        'Content-Type': 'application/x-www-form-urlencoded',
        'Content-Length' : contents.length
    }
};
var req = http.request(options, function(res) {
    res.setEncoding('utf8');
    res.on('data', function (data) {
    console.log(data);
    });
});
req.write(contents);
req.end();
复制代码

运行结果以下：

array(3) {
["name"]=>
string(6) "byvoid"
["email"]=>
string(17) "byvoid@byvoid.com"
["address"]=>
string(30) "Zijing 2#, Tsinghua University"
}
复制代码

2.http.get(options, callback)

http 模块还提供了一个更加简便的方法用于处理GET请求：http.get(options, callback)。它是http.request的简化版，惟一的区别在于http.get自动将请求方法设为了 GET 请求，同时不须要手动调用 req.end() ：

var http = require('http');
http.get({host: 'www.byvoid.com'}, function(res) {
    res.setEncoding('utf8');
    res.on('data', function (data) {
    console.log(data);
    });
});
复制代码

http.ClientRequest

该对象在 http.request() 内部被建立并返回。它表示着一个正在处理的请求，其请求头已进入队列。它提供一个response事件，即http.request或http.get第二个参数指定的回调函数的绑定对象。

var http = require('http');
var req = http.get({host: 'www.byvoid.com'});
    req.on('response', function(res) {
    res.setEncoding('utf8');
    res.on('data', function (data) {
    console.log(data);
    });
});
复制代码

http.ClientRequest像http.ServerResponse同样也提供了 write 和 end 函数，用于向服务器发送请求体，一般用于 POST、PUT 等操做。全部写结束之后必须调用end函数以通知服务器，不然请求无效。http.ClientRequest 还提供了如下经常使用的函数:

request.abort() ：标记请求为终止。调用该方法将使响应中剩余的数据被丢弃且 socket 被销毁。
request.setTimeout(timeout,[callback])：设置请求超时时间， timeout为毫秒数。一旦socket被分配给请求且已链接，socket.setTimeout() 会被调用。
request.end([data[, encoding]][, callback])结束发送请求。若是部分请求主体还未被发送，则会刷新它们到流中。若是请求是分块的，则会发送终止字符 '0\r\n\r\n'。

http.ClientResponse

http.ClientResponse 与 http.ServerRequest类似，提供了三个事件data、end和 close，分别在数据到达、传输结束和链接结束时触发，其中data 事件传递一个参数chunk，表示接收到的数据。

http.ClientResponse 也提供了一些属性，用于表示请求的结果状态：

statusCode   HTTP 状态码，如 200、40四、500
httpVersion  HTTP 协议版本，一般是 1.0 或 1.1
headers      HTTP 请求头
trailers     HTTP 请求尾（不常见）
复制代码

http.ClientResponse 还提供了如下几个特殊的函数：

response.setEncoding([encoding])：设置默认的编码，当data事件被触发时，数据将会以encoding编码。默认值是null，即不编码，以Buffer的形式存储。经常使用编码为 utf8。
response.pause()：暂停接收数据和发送事件，方便实现下载功能。
response.resume()：从暂停的状态中恢复。