階段5 3.微服務項目【學成在線】_day04 頁面靜態化_18-頁面靜態化-模板管理-GridFS研究-取文件

須要建立mongoDB的配置類1

 

配置類裏面主要建立。GridFSBucket這個對象。這個對象的做用就是用來打開一個下載流

在cms的微服務下，在config下建立MongoConfig。這個時候就須要用到spring的註解。@Configuration。加上這個註解。這個類就至關因而一個Bean。
用這個標識的類，spring的容器子在啓動的時候。會掃描到這個Bean，而後就會把這個Bean註冊到IOC容器中


這個類就是從配置文件中讀取到mongo的database。

在建立GridFSBucket的時候須要指定是哪一個數據庫

 

package com.xuecheng.manage_cms.config; import com.mongodb.MongoClient; import com.mongodb.client.MongoDatabase; import com.mongodb.client.gridfs.GridFSBucket; import com.mongodb.client.gridfs.GridFSBuckets; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.mongodb.gridfs.GridFsTemplate; @Configuration public class MongoConfig { @Value("${spring.data.mongodb.database}") String db; @Bean public GridFSBucket getGridFsTemplate(MongoClient mongoClient){ MongoDatabase database = mongoClient.getDatabase(db); GridFSBucket bucket = GridFSBuckets.create(database); return bucket; } }

 

這是配置文件內配置的mongo的數據庫信息

測試類測試

cms的微服務下，測試類GridFsTest內。注入GridFsBucket。目的是打開一個下載流

查詢用到Criteria，Criteria就是一個條件對象。

criteria

美 [kraɪ'tɪriən]

英 [kraɪ'tɪəriən]

• n.標準；尺度
• 網絡準則；條件；規準

把content複製出來。

最終代碼

 

package com.xuecheng.manage_cms; import com.mongodb.client.gridfs.GridFSBucket; import com.mongodb.client.gridfs.GridFSDownloadStream; import com.mongodb.client.gridfs.model.GridFSFile; import org.apache.commons.io.IOUtils; import org.bson.types.ObjectId; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.Query; import org.springframework.data.mongodb.gridfs.GridFsResource; import org.springframework.data.mongodb.gridfs.GridFsTemplate; import org.springframework.test.context.junit4.SpringRunner; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; @SpringBootTest @RunWith(SpringRunner.class) public class GridFsTest { @Autowired GridFsTemplate gridFsTemplate; @Autowired GridFSBucket gridFSBucket; @Test public void testGridFsTemplate() throws FileNotFoundException { File file = new File("d:/index_banner.ftl"); FileInputStream fileInputStream = new FileInputStream(file); //定義fileInputSream
        ObjectId objectId = gridFsTemplate.store(fileInputStream, "index_banner.ftl"); System.out.println(objectId); } @Test public void queryFile() throws IOException { //根據文件id查詢文件
        GridFSFile gridFsFile = gridFsTemplate.findOne(Query.query(Criteria.where("_id").is("5dbeb89bface36388cb8c7d4"))); //打開一個下載流對象
        GridFSDownloadStream gridFSDownloadStream = gridFSBucket.openDownloadStream(gridFsFile.getObjectId()); //建立GridFsResource對象，獲取流
        GridFsResource gridFsResource = new GridFsResource(gridFsFile, gridFSDownloadStream); //從流中取數據
        String content = IOUtils.toString(gridFsResource.getInputStream(), "utf-8"); System.out.println(content); } }

 

 

刪除文件

自行測試