MongoDB使用GridFS存储大数据（Java）

MongoDB 是一个灵活的 NoSQL 数据库，能够存储大量的数据。但是，当涉及到特别大的数据项，比如大文件、视频或大型图片时，MongoDB 提供了一个特殊的方法来存储这些数据：GridFS。

简介：

1. 什么是 GridFS？

GridFS 是 MongoDB 提供的一个规范和工具集，用于将大文件切分成多个较小的数据块并存储在 MongoDB 中。默认情况下，GridFS 将文件分成 255 KB 的数据块进行存储。

2. 如何工作？

当你使用 GridFS 存储文件时：

• 文件被切分成多个小块。
• 每个小块作为一个单独的文档存储在 chunks 集合中。
• 文件的元数据（如文件名、类型等）将被存储在 files 集合中。

3. 为什么使用 GridFS？

如果你有一个超过 BSON 文档大小限制（16MB）的文件或数据，那么 GridFS 是一个理想的解决方案。即使不超过这个限制，GridFS 也对于存储大量需要快速随机访问的数据非常有用。

5. 其他注意事项

• 性能：由于 GridFS 将大文件切分成较小的数据块，所以可以非常快速地访问文件的任意部分，而不需要加载整个文件。
• 扩展性：MongoDB 和 GridFS 设计得非常适合扩展，所以你可以轻松地在集群上存储和管理大量的大文件。

Java中使用

使用 Java 的

MongoTemplate

来与 MongoDB 交互。想和GridFS 交互，你可以使用

GridFsTemplate

。

1. 添加依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-mongodb</artifactId></dependency>

2. 配置

GridFsTemplate

在你的 Spring 配置中，你可以配置

GridFsTemplate

bean。

@ConfigurationpublicclassGridFsConfig{@BeanpublicGridFsTemplategridFsTemplate(MongoDatabaseFactory mongoDbFactory,MongoConverter mongoConverter){returnnewGridFsTemplate(mongoDbFactory, mongoConverter);}}

3. 使用

GridFsTemplate

存储文件

你可以使用

GridFsTemplate

的

store

方法来存储文件。

@AutowiredprivateGridFsTemplate gridFsTemplate;publicStringaddGridFs(InputStream content,String filename){ObjectId objectId = gridFsTemplate.store(content, filename);return objectId.toHexString();}

4. 使用

GridFsTemplate

检索文件

为了从 GridFS 中检索文件，你可以使用

findOne

方法。

publicInputStreamgetFile(String id)throwsIOException{GridFSFile file = gridFsTemplate.findOne(newQuery(Criteria.where("_id").is(id)));if(file !=null){GridFsResource resource = gridFsTemplate.getResource(file);return resource.getInputStream();}returnnull;}//根据名称查询多个文件publicList<InputStream>getFilesByName(String name)throwsIOException{List<InputStream> inputStreams =newArrayList<>();Query query =newQuery(Criteria.where("filename").is(name));List<GridFSFile> files = gridFsTemplate.find(query).into(newArrayList<>());for(GridFSFile file : files){GridFsResource resource = gridFsTemplate.getResource(file);InputStream inputStream = resource.getInputStream();if(inputStream !=null){
            inputStreams.add(inputStream);}}return inputStreams;}

5. 删除 GridFS 中的文件

//根据名称publicvoiddeleteFile(String filename){
    gridFsTemplate.delete(newQuery(Criteria.where("filename").is(filename)));}publicvoiddeleteFile(String id){
    gridFsTemplate.delete(newQuery(Criteria.where("_id").is(id)));}