如何在GridFS中保存对象而不从文件中取出？

Question

我正在使用一个spring boot api，它可以接收非常大的对象，并尝试将其保存在MongoDB数据库中。因此,程序有时会抛出下一个错误：

org.bson.BsonMaximumSizeExceededException: Payload document size is larger than maximum of 16793600.

我读到MongoDB只允许16MB以下大小的对象，这对我的系统非常不方便，因为一个对象可以很容易地超过这个差距。为了解决这个问题，我读过GridFS，一种允许超过16MB文件差距的技术。

现在，我试图在系统中实现GridFS，但我只看到了使用文件保存在数据库中的示例，如下所示：

gridFsOperations.store(new FileInputStream("/Users/myuser/Desktop/text.txt"), "myText.txt", "text/plain", metaData);

但我想做的不是从文件中获取数据，而是到api中接收一个对象并保存它，如下所示：

@PostMapping
    public String save(@RequestBody Object object){
        DBObject metaData = new BasicDBObject();
        metaData.put("type", "data");
        gridFsOperations.store(object, metaData);
        return "Stored successfully...";
    }

这是一个可行的方法吗？

Answer 1

从请求中获取InputStream并将其传递给GridfsBucket。下面是一个粗略的例子：

在控制器中：

@PostMapping
public ResponseEntity<String> uploadFile(MultipartHttpServletRequest request)
{
  Iterator<String> iterator = request.getFilenames();
  String filename = iterator.next();

  MultipartFile mf = request.getFile(filename);

  // I always have a service layer between controller and repository but for purposes of this example...
  myDao.uploadFile(filename, mf.getInputStream());
}

在DAO/存储库中：

private GridFSBucket bucket;

@Autowired
void setMongoDatabase(MongoDatabase db)
{
  bucket = GridFSBuckets.create(db);
}

public ObjectId uploadFile(String filename, InputStream is)
{
  Document metadata = new Document("type", "data");
  GridFSUploadOptions opts = new GridFSUploadOptions().metadata(metadata);

  ObjectId oid  = bucket.uploadFromStream(filename, is, opts);

  try
  {
     is.close();
  }
  catch (IOException ioe)
  {
    throw new UncheckedIOException(ioe);
  }
  
  return oid;
}

我从现有的代码中转述了这一点，所以它可能不是完美的，但会足够好，为您指明正确的方向。