文件服务器
让我们结合新学习的 HTTP 服务器和文件系统的知识,并建立起两者之间的桥梁:使用 HTTP 服务允许客户远程访问文件系统。这个服务有许多用处,它允许网络应用程序存储并共享数据或使得一组人可以共享访问一批文件。
当我们将文件当作 HTTP 资源时,可以将 HTTP 的 GET、PUT 和 DELETE 方法分别看成读取、写入和删除文件。我们将请求中的路径解释成请求指向的文件路径。
我们可能不希望共享整个文件系统,因此我们将这些路径解释成以服务器工作路径(即启动服务器的路径)为起点的相对路径。若从/home/marijn/public
(或 Windows 下的C:\Users\marijn\public
)启动服务器,那么对/file.txt
的请求应该指向/home/marijn/public/file.txt
(或C:\Users\marijn\public\file.txt
)。
我们将一段段地构建程序,使用名为methods
的对象来存储处理多种 HTTP 方法的函数。方法处理器是async
函数,它接受请求对象作为参数并返回一个Promise
,解析为描述响应的对象。
const {createServer} = require("http");
const methods = Object.create(null);
createServer((request, response) => {
let handler = methods[request.method] || notAllowed;
handler(request)
.catch(error => {
if (error.status != null) return error;
return {body: String(error), status: 500};
})
.then(({body, status = 200, type = "text/plain"}) => {
response.writeHead(status, {"Content-Type": type});
if (body && body.pipe) body.pipe(response);
else response.end(body);
});
}).listen(8000);
async function notAllowed(request) {
return {
status: 405,
body: `Method ${request.method} not allowed.`
};
}
这样启动服务器之后,服务器永远只会产生 405 错误响应,该代码表示服务器拒绝处理特定的方法。
当请求处理程序的Promise
受到拒绝时,catch
调用会将错误转换为响应对象(如果它还不是),以便服务器可以发回错误响应,来通知客户端它未能处理请求。
响应描述的status
字段可以省略,这种情况下,默认为 200(OK)。 type
属性中的内容类型也可以被省略,这种情况下,假定响应为纯文本。
当body
的值是可读流时,它将有pipe
方法,用于将所有内容从可读流转发到可写流。 如果不是,则假定它是null
(无正文),字符串或缓冲区,并直接传递给响应的end
方法。
为了弄清哪个文件路径对应于请求URL,urlPath
函数使用 Node 的url
内置模块来解析 URL。 它接受路径名,类似"/file.txt"
,将其解码来去掉%20
风格的转义代码,并相对于程序的工作目录来解析它。
const {parse} = require("url");
const {resolve} = require("path");
const baseDirectory = process.cwd();
function urlPath(url) {
let {pathname} = parse(url);
let path = resolve(decodeURIComponent(pathname).slice(1));
if (path != baseDirectory &&
!path.startsWith(baseDirectory + "/")) {
throw {status: 403, body: "Forbidden"};
}
return path;
}
只要你建立了一个接受网络请求的程序,就必须开始关注安全问题。 在这种情况下,如果我们不小心,很可能会意外地将整个文件系统暴露给网络。
文件路径在 Node 中是字符串。 为了将这样的字符串映射为实际的文件,需要大量有意义的解释。 例如,路径可能包含"../"
来引用父目录。 因此,一个显而易见的问题来源是像/../ secret_file
这样的路径请求。
为了避免这种问题,urlPath
使用path
模块中的resolve
函数来解析相对路径。 然后验证结果位于工作目录下面。 process.cwd
函数(其中cwd
代表“当前工作目录”)可用于查找此工作目录。 当路径不起始于基本目录时,该函数将使用 HTTP 状态码来抛出错误响应对象,该状态码表明禁止访问资源。
我们需要创建GET方法,在读取目录时返回文件列表,在读取普通文件时返回文件内容。
一个棘手的问题是我们返回文件内容时添加的Content-Type
头应该是什么类型。因为这些文件可以是任何内容,我们的服务器无法简单地对所有文件返回相同的内容类型。但 NPM 可以帮助我们完成该任务。mime
包(以text/plain
这种方式表示的内容类型,名为 MIME 类型)可以获取大量文件扩展名的正确类型。
以下npm
命令在服务器脚本所在的目录中,安装mime
的特定版本。
$ npm install mime@2.2.0
当请求文件不存在时,应该返回的正确 HTTP 状态码是 404。我们使用stat
函数,来找出特定文件是否存在以及是否是一个目录。
const {createReadStream} = require("fs");
const {stat, readdir} = require("fs/promises");
const mime = require("mime");
methods.GET = async function(request) {
let path = urlPath(request.url);
let stats;
try {
stats = await stat(path);
} catch (error) {
if (error.code != "ENOENT") throw error;
else return {status: 404, body: "File not found"};
}
if (stats.isDirectory()) {
return {body: (await readdir(path)).join("\n")};
} else {
return {body: createReadStream(path),
type: mime.getType(path)};
}
};
因为stat
访问磁盘需要耗费一些时间,因此该函数是异步的。由于我们使用Promise
而不是回调风格,因此必须从fs/promises
而不是fs
导入。
当文件不存在时,stat
会抛出一个错误对象,code
属性为'ENOENT'
。 这些有些模糊的,受 Unix 启发的代码,是你识别 Node 中的错误类型的方式。
由stat
返回的stats
对象告诉了我们文件的一系列信息,比如文件大小(size
属性)和修改日期(mtime
属性)。这里我们想知道的是,该文件是一个目录还是普通文件,isDirectory
方法可以告诉我们答案。
我们使用readdir
来读取目录中的文件列表,并将其返回给客户端。对于普通文件,我们使用createReadStream
创建一个可读流,并将其传递给respond
对象,同时使用mime
模块根据文件名获取内容类型并传递给respond
。
处理DELETE
请求的代码就稍显简单了。
const {rmdir, unlink} = require("fs/promises");
methods.DELETE = async function(request) {
let path = urlPath(request.url);
let stats;
try {
stats = await stat(path);
} catch (error) {
if (error.code != "ENOENT") throw error;
else return {status: 204};
}
if (stats.isDirectory()) await rmdir(path);
else await unlink(path);
return {status: 204};
};
当 HTTP 响应不包含任何数据时,状态码 204(“No Content”,无内容)可用于表明这一点。 由于删除的响应不需要传输任何信息,除了操作是否成功之外,在这里返回是明智的。
你可能想知道,为什么试图删除不存在的文件会返回成功状态代码,而不是错误。 当被删除的文件不存在时,可以说该请求的目标已经完成。 HTTP 标准鼓励我们使请求是幂等(idempotent)的,这意味着,多次发送相同请求的结果,会与一次相同。 从某种意义上说,如果你试图删除已经消失的东西,那么你试图去做的效果已经实现 - 东西已经不存在了。
下面是PUT
请求的处理器。
const {createWriteStream} = require("fs");
function pipeStream(from, to) {
return new Promise((resolve, reject) => {
from.on("error", reject);
to.on("error", reject);
to.on("finish", resolve);
from.pipe(to);
});
}
methods.PUT = async function(request) {
let path = urlPath(request.url);
await pipeStream(request, createWriteStream(path));
return {status: 204};
};
我们不需要检查文件是否存在,如果存在,只需覆盖即可。我们再次使用pipe
来将可读流中的数据移动到可写流中,在本例中是将请求的数据移动到文件中。但是由于pipe
没有为返回Promise
而编写,所以我们必须编写包装器pipeStream
,它从调用pipe
的结果中创建一个Promise
。
当打开文件createWriteStream
时出现问题时仍然会返回一个流,但是这个流会触发'error'
事件。 例如,如果网络出现故障,请求的输出流也可能失败。 所以我们连接两个流的'error'
事件来拒绝Promise
。 当pipe
完成时,它会关闭输出流,从而导致触发'finish'
事件。 这是我们可以成功解析Promise
的地方(不返回任何内容)。
完整的服务器脚本请见eloquentjavascript.net/code/file_server.js
。读者可以下载该脚本,并且在安装依赖项之后,使用 Node 启动你自己的文件服务器。当然你可以修改并扩展该脚本,来完成本章的习题或进行实验。
命令行工具curl
在类 Unix 系统(比如 Mac 或者 Linux)中得到广泛使用,可用于产生 HTTP 请求。接下来的会话用于简单测试我们的服务器。这里需要注意,-x
用于设置请求方法,-d
用于包含请求正文。
$ curl http://localhost:8000/file.txt
File not found
$ curl -X PUT -d hello http://localhost:8000/file.txt
$ curl http://localhost:8000/file.txt
hello
$ curl -X DELETE http://localhost:8000/file.txt
$ curl http://localhost:8000/file.txt
File not found
由于file.txt
一开始不存在,因此第一请求失败。而PUT
请求则创建文件,因此我们看到下一个请求可以成功获取该文件。在使用DELETE
请求删除该文件后,第三次GET
请求再次找不到该文件。