Java上传文件到MongoDB GirdFS

上传有两种方式，一种是使用UploadFromStream，另外一种是OpenUploadStream方式，这里使用的是第二种方式：

    public ObjectId save(){GridFSBucket gfsbk = GridFSBuckets.create(db, "user_photo");byte[] data = "Data to upload into GridFS".getBytes(StandardCharsets.UTF_8);GridFSUploadStream uploadStream = gfsbk .openUploadStream("user_09734");uploadStream.write(data);ObjectId id = uploadStream.getFileId();uploadStream.close();return id;}

解析:
1. GridFSBucket gfsbk = GridFSBuckets.create(db, “user_photo”);

创建一个容器，传入一个`MongoDatabase`类实例db，和容器名称"user_photo"作为参数

2. GridFSUploadStream uploadStream = gfsbk .openUploadStream(“user_09734”);

打开上传流，传入一个String参数作为GirdFS文件的文件名

3. ObjectId id = uploadStream.getFileId();

得到刚刚上传的文件的id

Mongo Java驱动GirdFS上传参考资料
下面是我编写的上传帮助类：

package com.huanle.utils.db;import java.io.ByteArrayOutputStream;
import java.io.IOException;import org.bson.types.ObjectId;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import com.huanle.utils.model.FileEntity;
import com.mongodb.Block;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.gridfs.GridFSBucket;
import com.mongodb.client.gridfs.GridFSBuckets;
import com.mongodb.client.gridfs.GridFSUploadStream;
import com.mongodb.client.gridfs.model.GridFSFile;
import com.mongodb.gridfs.GridFS;@Component
public class GirdFSHelper {private GridFSBucket gfsbk;private MongoDatabase db;@Autowiredpublic GirdFSHelper(MongoDBHelper mongoManager){this.db = mongoManager.getDB("huanle");}/**保存文件到GirdFS,通过openUploadStream方式* @param bucket 容器名称* @param file 文件实体* @return 返回FileEntity*/public FileEntity save(String bucket,FileEntity file){gfsbk = GridFSBuckets.create(db, bucket);GridFSUploadStream uploadStream = gfsbk.openUploadStream(file.getFileName());uploadStream.write(file.getContent());ObjectId id = uploadStream.getFileId();uploadStream.flush();uploadStream.close();FileEntity filter = new FileEntity();filter.setId(id);filter = find(bucket,filter);return filter;}public FileEntity download(String bucket,FileEntity filter) throws IOException{filter = find(bucket,filter);if(filter==null){return null;}ByteArrayOutputStream out = new ByteArrayOutputStream();gfsbk = GridFSBuckets.create(db, bucket);gfsbk.downloadToStream(filter.getId(), out);filter.setContent(out.toByteArray());out.close();return filter;}public FileEntity find(String bucket,FileEntity filter){gfsbk = GridFSBuckets.create(db, bucket);System.out.println(filter.toBson());GridFSFile result = gfsbk.find(filter.toBson()).first();if(result==null){ return null;}filter.setId(result.getObjectId());filter.setSize(result.getLength());filter.setFileName(result.getFilename());filter.setUploadTime(result.getUploadDate());return filter;}}package com.huanle.utils.model;import java.util.Date;import javax.validation.constraints.Past;import org.bson.Document;
import org.bson.types.ObjectId;
import org.hibernate.validator.constraints.Range;import com.huanle.utils.annotation.FileContent;
import com.huanle.utils.annotation.FileName;
import com.huanle.utils.annotation.PlainString;/**文件辅助实体类* @author luchu**/
public class FileEntity {public static String ID="_id",FILE_NAME="fileName",SIZE="size",UPLOAD_TIME="uploadTime",CONTENT="content";private ObjectId id;@PlainString@FileNameprivate String fileName;@Range(max=41943040)private long size;@Pastprivate Date uploadTime;@FileContentprivate byte[] content;public Document toBson(){Document doc = new Document();if(this.id!=null){doc.append(ID, this.id);}if(this.fileName!=null){doc.append(FILE_NAME, this.fileName);}if(this.size!=0){doc.append(SIZE, this.size);}if(this.uploadTime!=null){doc.append(UPLOAD_TIME, this.uploadTime);}return doc;}}

Java上传文件到MongoDB GirdFS相关推荐

java上传文件到远程服务器(一)---HttpURLConnection方式
我们在之前的文章 JavaWeb静态资源分离思路中已经了解到要把文件上传到静态资源服务器有三种方式: java上传文件到ftp服务器(这个方案需要在静态资源服务器安装ftp服务) java使用Htt ...
java上传文件功能_Java MemoryMapped文件的功能
java上传文件功能 Java MemoryMapped文件的功能在JDK 1.4中,内存映射文件的一个有趣功能被添加到Java中,该功能允许将任何文件映射到OS内存以进行有效读取. 内存映射文件可 ...
java 上传文件注意事项
java 上传文件注意事项 1.文件名有特殊字符的情况,所以最好是文件名前台url编码,后台再url解码,这点在下载的时候也一样 2.文件大小一定要设置,spring boot 有默认. 3.文件名校 ...
java 上传文件到服务器_java上传文件到OSS云服务器（二）
上篇文章中已经把接口端和service业务层写了,这次就把OSS上传文件的工具类补上. 一.首先配置好OSS服务器各项节点,这是在springboot中appliaction.yml配置文件中的写法. ...
JAVA上传文件图片到服务器保存
这里我记录一个比较简单方便操作的JAVA上传文件图片到服务器并且保存! 首先是页面 html的我这是提交一个文件和类型 <div style="border: 1px solid ...
Java上传文件到minio
Minio 是个基于 Golang 编写的开源对象存储套件,基于Apache License v2.0开源协议,虽然轻量,却拥有着不错的性能.而且学习成本低,安装运维简单,开箱即用,提供 Java 客 ...
Java上传文件保存到指定路径
Java上传文件保存到指定路径上代码 @PostMapping("/file-upload")@ApiOperation(value = "上传swagger.json ...
java上传文件到服务器,java上传文件到云服务器
java上传文件到云服务器内容精选换一换安装传输工具在本地主机和Windows云服务器上分别安装数据传输工具,将文件上传到云服务器.例如QQ.exe.在本地主机和Windows云服务器上分别安装 ...
java上传文件图片到服务器保存,Java上传文件图片到服务器的方法
这里我记录一个比较简单方便操作的java上传文件图片到服务器并且保存,具体内容如下首先是页面html的我这是提交一个文件和类型我是添加一张临时图片得到微信的media_id保存数据库! en ...

Java上传文件到MongoDB GirdFS

Java上传文件到MongoDB GirdFS相关推荐

最新文章

热门文章