频道栏目
首页 > 程序开发 > web前端 > HTML/CSS > 正文
Node.js指南(HTTP事务的剖析)
2018-12-22 11:38:15           
收藏   我要投稿

HTTP事务的剖析

本指南的目的是让你充分了解Node.js HTTP处理的过程,我们假设你在一般意义上知道HTTP请求的工作方式,无论语言或编程环境如何,我们还假设你对Node.js EventEmitters和Streams有点熟悉,如果你对它们不太熟悉,那么值得快速阅读每个API文档。

创建服务器

任何节点Web服务器应用程序在某些时候都必须创建Web服务器对象,这是通过使用createServer完成的。

const http = require(&世界杯投注官网39;http&世界杯投注官网39;);

const server = http.createServer((request, response) => {

// magic happens here!

});

传递给createServer的函数对于针对该服务器发出的每个HTTP请求都会调用一次,因此它被称为请求处理程序,实际上,createServer返回的Server对象是一个EventEmitter,我们这里只是创建server对象的简写,然后稍后添加监听器。

const server = http.createServer();

server.on(&世界杯投注官网39;request&世界杯投注官网39;, (request, response) => {

// the same kind of magic happens here!

});

当HTTP请求命中服务器时,node使用一些方便的对象调用请求处理函数来处理事务、request和response,我们很快就会讲到。

为了实际处理请求,需要在server对象上调用listen方法,在大多数情况下,你需要传递给listen的是你希望服务器监听的端口号,还有一些其他选项,请参阅API参考。

方法、URL和Headers

处理请求时,你可能要做的第一件事就是查看方法和URL,以便采取适当的措施,Node通过将方便的属性放在request对象上来使这相对轻松。

const { method, url } = request;

注意:request对象是IncomingMessage的一个实例。

这里的method将始终是普通的HTTP方法/动作,url是没有服务器、协议或端口的完整URL,对于典型的URL,这意味着包括第三个正斜杠后的所有内容。

Headers也不远,它们在自己的request对象中,被称为headers。

const { headers } = request;

const userAgent = headers[&世界杯投注官网39;user-agent&世界杯投注官网39;];

这里需要注意的是,无论客户端实际发送它们的方式如何,所有headers都仅以小写字母表示,这简化了为任何目的解析headers的任务。

如果重复某些headers,则它们的值将被覆盖或以逗号分隔的字符串连接在一起,具体取决于header,在某些情况下,这可能会有问题,因此rawHeaders也可用。

请求体

收到POST或PUT请求时,请求体可能对你的应用程序很重要,获取body数据比访问请求headers更复杂一点,传递给处理程序的request对象实现了ReadableStream接口,就像任何其他流一样,可以在其他地方监听或传输此流,我们可以通过监听流的&世界杯投注官网39;data&世界杯投注官网39;和&世界杯投注官网39;end&世界杯投注官网39;事件来直接从流中获取数据。

每个&世界杯投注官网39;data&世界杯投注官网39;事件中发出的块是一个Buffer,如果你知道它将是字符串数据,那么最好的方法是在数组中收集数据,然后在&世界杯投注官网39;end&世界杯投注官网39;,连接并对其进行字符串化。

let body = [];

request.on(&世界杯投注官网39;data&世界杯投注官网39;, (chunk) => {

body.push(chunk);

}).on(&世界杯投注官网39;end&世界杯投注官网39;, () => {

body = Buffer.concat(body).toString();

// at this point, `body` has the entire request body stored in it as a string

});

注意:这看起来有点单调乏味,而且在很多情况下确实如此,幸运的是,在npm上有像concat-stream和body这样的模块可以帮助隐藏一些逻辑,在走这条路之前,要很好地了解正在发生的事情,这就是为什么你在这里!

关于错误的简单介绍

由于request对象是一个ReadableStream,它也是一个EventEmitter,发生错误时的行为与此类似。

request流中的错误通过在流上发出&世界杯投注官网39;error&世界杯投注官网39;事件来呈现,如果你没有该事件的侦听器,则会抛出错误,这可能会导致Node.js程序崩溃。因此,你应该在请求流上添加&世界杯投注官网39;error&世界杯投注官网39;侦听器,即使你只是记录它并继续前进(虽然最好发送某种HTTP错误响应,稍后会详细介绍)。

request.on(&世界杯投注官网39;error&世界杯投注官网39;, (err) => {

// This prints the error message and stack trace to `stderr`.

console.error(err.stack);

});

还有其他方法可以处理这些错误,例如其他抽象和工具,但始终要注意错误可能并且确实会发生,并且你将不得不处理它们。

到目前为止我们已经得到了什么

此时,我们已经介绍了如何创建服务器,并从请求中获取方法、URL、headers和body,当我们将它们放在一起时,它可能看起来像这样:

const http = require(&世界杯投注官网39;http&世界杯投注官网39;);

http.createServer((request, response) => {

const { headers, method, url } = request;

let body = [];

request.on(&世界杯投注官网39;error&世界杯投注官网39;, (err) => {

console.error(err);

}).on(&世界杯投注官网39;data&世界杯投注官网39;, (chunk) => {

body.push(chunk);

}).on(&世界杯投注官网39;end&世界杯投注官网39;, () => {

body = Buffer.concat(body).toString();

// At this point, we have the headers, method, url and body, and can now

// do whatever we need to in order to respond to this request.

});

}).listen(8080); // Activates this server, listening on port 8080.

如果我们运行此示例,我们将能够接收请求,但不会响应它们,实际上,如果你在Web浏览器中请求此示例,则你的请求将超时,因为没有任何内容被发送回客户端。

到目前为止,我们还没有涉及响应对象,它是ServerResponse的一个实例,它是一个WritableStream,它包含许多用于将数据发送回客户端的有用方法,接下来我们将介绍。

HTTP状态码

如果不设置它,响应中的HTTP状态码始终为200,当然,并非每个HTTP响应都保证这一点,并且在某些时候你肯定希望发送不同的状态码,为此,你可以设置statusCode属性。

response.statusCode = 404; // Tell the client that the resource wasn&世界杯投注官网39;t found.

还有其他一些快捷方式,我们很快就会看到。

设置响应Headers

Headers是通过一个名为setHeader的方便方法设置的。

response.setHeader(&世界杯投注官网39;Content-Type&世界杯投注官网39;, &世界杯投注官网39;application/json&世界杯投注官网39;);

response.setHeader(&世界杯投注官网39;X-Powered-By&世界杯投注官网39;, &世界杯投注官网39;bacon&世界杯投注官网39;);

在响应上设置headers时,大小写对其名称不敏感,如果重复设置标题,则设置的最后一个值是发送的值。

显式发送Header数据

我们已经讨论过的设置headers和状态码的方法假设你正在使用“隐式headers”,这意味着在开始发送body数据之前,你需要依赖node在正确的时间为你发送headers。

如果需要,可以将headers显式写入响应流,为此,有一个名为writeHead的方法,它将状态码和headers写入流。

response.writeHead(200, {

&世界杯投注官网39;Content-Type&世界杯投注官网39;: &世界杯投注官网39;application/json&世界杯投注官网39;,

&世界杯投注官网39;X-Powered-By&世界杯投注官网39;: &世界杯投注官网39;bacon&世界杯投注官网39;

});

一旦设置了headers(隐式或显式),你就可以开始发送响应数据了。

发送响应体

由于response对象是WritableStream,因此将响应体写入客户端只需使用常用的流方法即可。

response.write(&世界杯投注官网39;

&世界杯投注官网39;); response.write(&世界杯投注官网39;&世界杯投注官网39;); response.write(&世界杯投注官网39;

Hello, World!

&世界杯投注官网39;); response.write(&世界杯投注官网39;&世界杯投注官网39;); response.write(&世界杯投注官网39;&世界杯投注官网39;); response.end();

流上的end函数也可以接收一些可选数据作为流上的最后一位数据发送,因此我们可以如下简化上面的示例。

response.end(&世界杯投注官网39;

Hello, World!

&世界杯投注官网39;);

注意:在开始向body写入数据块之前设置状态和headers很重要,这是有道理的,因为headers在HTTP响应中位于body之前。

关于错误的另一件事

response流也可以发出&世界杯投注官网39;error&世界杯投注官网39;事件,在某些时候你也必须处理它,所有关于request流错误的建议仍然适用于此处。

把它放在一起

现在我们已经了解了如何进行HTTP响应,让我们把它们放在一起,在前面的示例的基础上,我们将创建一个服务器,用于发回世界杯指定投注官网发送给我们的所有数据,我们将使用JSON.stringify将该数据格式化为JSON。

const http = require(&世界杯投注官网39;http&世界杯投注官网39;);

http.createServer((request, response) => {

const { headers, method, url } = request;

let body = [];

request.on(&世界杯投注官网39;error&世界杯投注官网39;, (err) => {

console.error(err);

}).on(&世界杯投注官网39;data&世界杯投注官网39;, (chunk) => {

body.push(chunk);

}).on(&世界杯投注官网39;end&世界杯投注官网39;, () => {

body = Buffer.concat(body).toString();

// BEGINNING OF NEW STUFF

response.on(&世界杯投注官网39;error&世界杯投注官网39;, (err) => {

console.error(err);

});

response.statusCode = 200;

response.setHeader(&世界杯投注官网39;Content-Type&世界杯投注官网39;, &世界杯投注官网39;application/json&世界杯投注官网39;);

// Note: the 2 lines above could be replaced with this next one:

// response.writeHead(200, {&世界杯投注官网39;Content-Type&世界杯投注官网39;: &世界杯投注官网39;application/json&世界杯投注官网39;})

const responseBody = { headers, method, url, body };

response.write(JSON.stringify(responseBody));

response.end();

// Note: the 2 lines above could be replaced with this next one:

// response.end(JSON.stringify(responseBody))

// END OF NEW STUFF

});

}).listen(8080);

Echo服务器示例

让我们简化前面的示例来进行一个简单的echo服务器,它只是在响应中发送请求中收到的任何数据,我们需要做的就是从请求流中获取数据并将该数据写入响应流,类似于我们之前所做的。

const http = require(&世界杯投注官网39;http&世界杯投注官网39;);

http.createServer((request, response) => {

let body = [];

request.on(&世界杯投注官网39;data&世界杯投注官网39;, (chunk) => {

body.push(chunk);

}).on(&世界杯投注官网39;end&世界杯投注官网39;, () => {

body = Buffer.concat(body).toString();

response.end(body);

});

}).listen(8080);

现在让我们调整一下,我们只想在以下条件下发送echo:

请求方法是POST。 URL是/echo。

在任何其他情况下,我们只想响应404。

const http = require(&世界杯投注官网39;http&世界杯投注官网39;);

http.createServer((request, response) => {

if (request.method === &世界杯投注官网39;POST&世界杯投注官网39; && request.url === &世界杯投注官网39;/echo&世界杯投注官网39;) {

let body = [];

request.on(&世界杯投注官网39;data&世界杯投注官网39;, (chunk) => {

body.push(chunk);

}).on(&世界杯投注官网39;end&世界杯投注官网39;, () => {

body = Buffer.concat(body).toString();

response.end(body);

});

} else {

response.statusCode = 404;

response.end();

}

}).listen(8080);

注意:通过这种方式检查URL,我们正在做一种“路由”的形式,其他形式的路由可以像switch语句一样简单,也可以像express这样的整个框架一样复杂,如果你正在寻找可以进行路由的东西,请尝试使用router。

现在让我们来简化一下吧,请记住,request对象是ReadableStream,response对象是WritableStream,这意味着我们可以使用pipe将数据从一个引导到另一个,这正是我们想要的echo服务器!

const http = require(&世界杯投注官网39;http&世界杯投注官网39;);

http.createServer((request, response) => {

if (request.method === &世界杯投注官网39;POST&世界杯投注官网39; && request.url === &世界杯投注官网39;/echo&世界杯投注官网39;) {

request.pipe(response);

} else {

response.statusCode = 404;

response.end();

}

}).listen(8080);

我们还没有完成,正如本指南中多次提到的,错误可以而且确实会发生,我们需要处理它们。

为了处理请求流上的错误,我们将错误记录到stderr并发送400状态码以指示Bad Request,但是,在实际应用程序中,我们需要检查错误以确定正确的状态码和消息是什么,与通常的错误一样,你应该查阅错误文档。

在响应中,我们只是将错误记录到stderr。

const http = require(&世界杯投注官网39;http&世界杯投注官网39;);

http.createServer((request, response) => {

request.on(&世界杯投注官网39;error&世界杯投注官网39;, (err) => {

console.error(err);

response.statusCode = 400;

response.end();

});

response.on(&世界杯投注官网39;error&世界杯投注官网39;, (err) => {

console.error(err);

});

if (request.method === &世界杯投注官网39;POST&世界杯投注官网39; && request.url === &世界杯投注官网39;/echo&世界杯投注官网39;) {

request.pipe(response);

} else {

response.statusCode = 404;

response.end();

}

}).listen(8080);

我们现在已经介绍了处理HTTP请求的大部分基础知识,此时,你应该能够:

使用请求处理程序函数实例化HTTP服务器,并让它侦听端口。 从request对象中获取headers、URL、方法和body数据。 根据request对象中的URL和/或其他数据做出路由决策。 通过response对象发送headers、HTTP状态码和body数据。 从request对象和response对象管道数据。 处理request和response流中的流错误。

从这些基础知识中,可以构建用于许多典型用例的Node.js HTTP服务器,这些API提供了许多其他功能,因此请务必阅读有关EventEmitters、Streams和HTTP的API文档。

点击复制链接 与好友分享!回本站首页
上一篇:Javascript中的深浅拷贝
下一篇:Promise源码分析
相关文章
图文推荐
点击排行

关于我们 | 联系我们 | 服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训 | 举报中心

版权所有: 红黑--致力于做实用的IT技术学习网站

世界杯投注官网