GridFS 是什么？
在 MongoDB 中，GridFS 是一种专门用于文件存储和管理的机制。如果你有很多大文件需要存储，比如视频、音频等，直接存储到 MongoDB 中可能不是一个好的选择，因为它们会占用大量的磁盘空间，同时也会影响数据库的性能。
而 GridFS 在这种情况下就派上了用场。它把大文件拆分成小块，并将这些小块存储到 MongoDB 的集合中，这种方式既节省了磁盘空间，又能保证数据的完整性和可靠性。当需要读取文件时，GridFS 会将小块重新组合成原始文件。通过这种方式，我们就可以轻松处理大文件的上传与下载。
GridFS 的上传及下载操作
上传操作
在 Node.js 中，我们可以使用 GridFS Stream 进行上传操作。下面给出一个上传单个文件的示例代码：
-- -------------------- ---- -------
----- ----------- - -------------------------------
----- ---- - -------------------------
----- -- - --------------
----- --- - --------------------------------------
----- -------- - -----------
------------------------ -------- ----- --- -
-- ----- -
-----------------
-------
-
----- --- - -------- --------------------
----- ----------- - -----------------------
--------- --------
---
-------------------------------------------------------
----------------------- -------- ------ -
----------------- ---------------- -- ------- -- ------- ----------------
---
---首先，我们需要连接 MongoDB，并通过 gridfs-stream 模块创建 GridFS 对象。接着，我们创建一个可写流（writestream），并把文件通过管道写入 GridFS。当文件写入完成后，writestream 会触发 close 事件，我们可以在这里添加回调函数，通知操作的成功或失败。
如果我们想上传一个文件列表，可以使用如下代码进行操作：
-- -------------------- ---- -------
----- ----------- - -------------------------------
----- ---- - -------------------------
----- ----- - -----------------
----- -- - --------------
----- --- - --------------------------------------
----- -------- - ------------- ------------ -------------
------------------------ -------- ----- --- -
-- ----- -
-----------------
-------
-
----- --- - -------- --------------------
-------------------------- -------- ---------- --- -
----- ----------- - -----------------------
--------- --------
---
-------------------------------------------------------
----------------------- -------- ------ -
----------------- ---------------- -- ------- -- ------- ----------------
-----
---
----------------------- ----
-- -------- ----- -
-- ----- -----------------
-----------
---
---在这个示例中，我们使用 async 模块来控制文件的异步写入。async.eachSeries() 会按照 fileList 的顺序，依次执行上传操作。
下载操作
在 Node.js 中，我们可以使用 GridFS Stream 进行下载操作。下面给出一个下载单个文件的示例代码：
-- -------------------- ---- -------
----- ----------- - -------------------------------
----- ---- - -------------------------
----- -- - --------------
----- --- - --------------------------------------
----- -------- - -----------
------------------------ -------- ----- --- -
-- ----- -
-----------------
-------
-
----- --- - -------- --------------------
----- ---------- - ----------------------
--------- --------
---
----------------------------------------------------------------
---------------------- -------- ----- -
------------------ ----- ------- ---- ------------- -----
---
-------------------- -------- -- -
----------------- ----------- -- ---------- ----------------
---
---我们首先需要连接 MongoDB，并通过 gridfs-stream 模块创建 GridFS 对象。接着，我们创建一个可读流（readstream），并通过管道将数据写入到文件中。当文件读取过程中出现错误时，readstream 会触发 error 事件；当文件读取完成后，readstream 会触发 end 事件，我们可以在这里添加回调函数，通知操作的成功或失败。
如果我们想下载一个文件列表，可以使用如下代码进行操作：
-- -------------------- ---- -------
----- ----------- - -------------------------------
----- ---- - -------------------------
----- ----- - -----------------
----- -- - --------------
----- --- - --------------------------------------
----- -------- - ------------- ------------ -------------
------------------------ -------- ----- --- -
-- ----- -
-----------------
-------
-
----- --- - -------- --------------------
-------------------------- -------- ---------- --- -
----- ---------- - ----------------------
--------- --------
---
----------------------------------------------------------------
---------------------- ----
-------------------- -------- -- -
----------------- ----------- -- ---------- ----------------
-----
---
-- -------- ----- -
-- ----- -----------------
-----------
---
---在这个示例中，我们同样使用 async 模块来控制文件的异步读取。async.eachSeries() 会按照 fileList 的顺序，依次执行下载操作。
总结
在实际开发中，读写大文件是不可避免的。通过 GridFS，我们可以轻松地处理大文件的读写操作。本文简单介绍了 MongoDB GridFS 的上传和下载操作，并给出了示例代码供读者参考。需要注意的是，在实际生产环境中，我们还需要根据具体情况对上传和下载操作进行性能优化和安全防护。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64b3675c48841e9894fabf12