springboot整合mongodb（三）

港控/mmm° 2021-12-11 11:07 375阅读 0赞

**背景：在此基础上进行[springboot整合mongodb（二）][springboot_mongodb]**

**下载、删除mongdb中文件**

一、FileController添加API接口

@GetMapping("/file/{id}")
        public ResponseEntity download(@PathVariable("id") String id, HttpServletResponse response) {
            try {
                if (fileService.download(id, response.getOutputStream())) {
                    response.flushBuffer();
                    return new ResponseEntity("success", HttpStatus.OK);
                }
            } catch (IOException e) {
                LOGGER.error("FileController.download.IOException: " + e.getMessage());
            }
            return new ResponseEntity("fail", HttpStatus.INTERNAL_SERVER_ERROR);
        }
    
        @GetMapping("/file2/{id}")
        public ResponseEntity download2(@PathVariable("id") String id, HttpServletResponse response) {
            try {
                OutputStream os = response.getOutputStream();
                String fileName = fileService.download2(id, os);
                if (fileName != null) {
                    return new ResponseEntity("success", HttpStatus.OK);
                }
            } catch (IOException e) {
                LOGGER.error("FileController.download2.IOException: " + e.getMessage());
            }
            return new ResponseEntity("fail", HttpStatus.INTERNAL_SERVER_ERROR);
        }
    
        @DeleteMapping("/file/{id}")
        public ResponseEntity delete(@PathVariable("id") String id) {
            if (!fileService.deleteById(id)) {
                return new ResponseEntity("fail", HttpStatus.INTERNAL_SERVER_ERROR);
            }
            return new ResponseEntity("success", HttpStatus.OK);
        }

### 二、FileService中创建对应的方法 ###

boolean deleteById(String id);
    
        boolean download(String id, OutputStream os);
    
        String download2(String id, OutputStream os);

### 三、FileServiceImpl增加具体实现 ###

@Override
        public boolean download(String id, OutputStream os) {
            return fileDao.download(id, os);
        }
    
        @Override
        public String download2(String id, OutputStream os) {
            return fileDao.download2(id, os);
        }
    
        @Override
        public boolean deleteById(String id) {
            return fileDao.deleteById(id);
        }

### 四、FileDao添加数据处理方法 ###

public boolean deleteById(String id) {
            try {
                gridFsTemplate.delete(Query.query(Criteria.where("_id").is(id)));
                return true;
            } catch (Exception e) {
                LOGGER.error("FileDao.deleteById.Exception: " + e.getMessage());
            }
            return false;
        }
    
        public boolean download(String id, OutputStream os) {
            try{
                // 根据id查询文件
                GridFSFile gridFSFile = gridFsTemplate.findOne(Query.query(Criteria.where("_id").is(id)));
                // 下载
                gridFSBucket.downloadToStream(gridFSFile.getObjectId(), os);
                return true;
            }catch (Exception e) {
                LOGGER.error("FileDao.download.Exception: " + e.getMessage());
            }
            return false;
        }
    
        public String download2(String id, OutputStream os) {
            try{
                // 根据id查询文件
                GridFSFile gridFSFile = gridFsTemplate.findOne(Query.query(Criteria.where("_id").is(id)));
                GridFSDownloadStream gridFSDownloadStream = gridFSBucket.openDownloadStream(gridFSFile.getObjectId());
                GridFsResource gridFsResource = new GridFsResource(gridFSFile, gridFSDownloadStream);
                // 下载
                IOUtils.copy(gridFsResource.getInputStream(), os);
                return gridFSFile.getFilename();
            }catch (Exception e) {
                LOGGER.error("FileDao.download2.Exception: " + e.getMessage());
            }
            return null;
        }

### 五、启动引导类主程序 ###

H:\JDK\jdk-11.0.3\bin\java.exe -agentlib:jdwp=transport=dt_socket,address=127.0.0.1:51325,suspend=y,server=n -XX:TieredStopAtLevel=1 -noverify -Dspring.output.ansi.enabled=always -Dcom.sun.management.jmxremote -Dspring.jmx.enabled=true -Dspring.liveBeansView.mbeanDomain -Dspring.application.admin.enabled=true -javaagent:C:\Users\Administrator\.IntelliJIdea2019.1\system\captureAgent\debugger-agent.jar -Dfile.encoding=UTF-8 -classpath "F:\IdeaProjects\springbootmongodb\target\classes;E:\maven\repository\org\springframework\boot\spring-boot-starter-web\2.1.4.RELEASE\spring-boot-starter-web-2.1.4.RELEASE.jar;E:\maven\repository\org\springframework\boot\spring-boot-starter\2.1.4.RELEASE\spring-boot-starter-2.1.4.RELEASE.jar;E:\maven\repository\org\springframework\boot\spring-boot-starter-logging\2.1.4.RELEASE\spring-boot-starter-logging-2.1.4.RELEASE.jar;E:\maven\repository\ch\qos\logback\logback-classic\1.2.3\logback-classic-1.2.3.jar;E:\maven\repository\ch\qos\logback\logback-core\1.2.3\logback-core-1.2.3.jar;E:\maven\repository\org\apache\logging\log4j\log4j-to-slf4j\2.11.2\log4j-to-slf4j-2.11.2.jar;E:\maven\repository\org\apache\logging\log4j\log4j-api\2.11.2\log4j-api-2.11.2.jar;E:\maven\repository\org\slf4j\jul-to-slf4j\1.7.26\jul-to-slf4j-1.7.26.jar;E:\maven\repository\javax\annotation\javax.annotation-api\1.3.2\javax.annotation-api-1.3.2.jar;E:\maven\repository\org\yaml\snakeyaml\1.23\snakeyaml-1.23.jar;E:\maven\repository\org\springframework\boot\spring-boot-starter-json\2.1.4.RELEASE\spring-boot-starter-json-2.1.4.RELEASE.jar;E:\maven\repository\com\fasterxml\jackson\core\jackson-databind\2.9.8\jackson-databind-2.9.8.jar;E:\maven\repository\com\fasterxml\jackson\core\jackson-annotations\2.9.0\jackson-annotations-2.9.0.jar;E:\maven\repository\com\fasterxml\jackson\core\jackson-core\2.9.8\jackson-core-2.9.8.jar;E:\maven\repository\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.9.8\jackson-datatype-jdk8-2.9.8.jar;E:\maven\repository\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.9.8\jackson-datatype-jsr310-2.9.8.jar;E:\maven\repository\com\fasterxml\jackson\module\jackson-module-parameter-names\2.9.8\jackson-module-parameter-names-2.9.8.jar;E:\maven\repository\org\springframework\boot\spring-boot-starter-tomcat\2.1.4.RELEASE\spring-boot-starter-tomcat-2.1.4.RELEASE.jar;E:\maven\repository\org\apache\tomcat\embed\tomcat-embed-core\9.0.17\tomcat-embed-core-9.0.17.jar;E:\maven\repository\org\apache\tomcat\embed\tomcat-embed-el\9.0.17\tomcat-embed-el-9.0.17.jar;E:\maven\repository\org\apache\tomcat\embed\tomcat-embed-websocket\9.0.17\tomcat-embed-websocket-9.0.17.jar;E:\maven\repository\org\hibernate\validator\hibernate-validator\6.0.16.Final\hibernate-validator-6.0.16.Final.jar;E:\maven\repository\javax\validation\validation-api\2.0.1.Final\validation-api-2.0.1.Final.jar;E:\maven\repository\org\jboss\logging\jboss-logging\3.3.2.Final\jboss-logging-3.3.2.Final.jar;E:\maven\repository\com\fasterxml\classmate\1.4.0\classmate-1.4.0.jar;E:\maven\repository\org\springframework\spring-web\5.1.6.RELEASE\spring-web-5.1.6.RELEASE.jar;E:\maven\repository\org\springframework\spring-beans\5.1.6.RELEASE\spring-beans-5.1.6.RELEASE.jar;E:\maven\repository\org\springframework\spring-webmvc\5.1.6.RELEASE\spring-webmvc-5.1.6.RELEASE.jar;E:\maven\repository\org\springframework\spring-aop\5.1.6.RELEASE\spring-aop-5.1.6.RELEASE.jar;E:\maven\repository\org\springframework\spring-context\5.1.6.RELEASE\spring-context-5.1.6.RELEASE.jar;E:\maven\repository\org\springframework\spring-expression\5.1.6.RELEASE\spring-expression-5.1.6.RELEASE.jar;E:\maven\repository\org\springframework\boot\spring-boot-starter-data-mongodb\2.1.4.RELEASE\spring-boot-starter-data-mongodb-2.1.4.RELEASE.jar;E:\maven\repository\org\springframework\data\spring-data-mongodb\2.1.6.RELEASE\spring-data-mongodb-2.1.6.RELEASE.jar;E:\maven\repository\org\springframework\spring-tx\5.1.6.RELEASE\spring-tx-5.1.6.RELEASE.jar;E:\maven\repository\org\springframework\data\spring-data-commons\2.1.6.RELEASE\spring-data-commons-2.1.6.RELEASE.jar;E:\maven\repository\org\slf4j\slf4j-api\1.7.26\slf4j-api-1.7.26.jar;E:\maven\repository\org\springframework\spring-core\5.1.6.RELEASE\spring-core-5.1.6.RELEASE.jar;E:\maven\repository\org\springframework\spring-jcl\5.1.6.RELEASE\spring-jcl-5.1.6.RELEASE.jar;E:\maven\repository\org\mongodb\mongodb-driver\3.8.2\mongodb-driver-3.8.2.jar;E:\maven\repository\org\mongodb\bson\3.8.2\bson-3.8.2.jar;E:\maven\repository\org\mongodb\mongodb-driver-core\3.8.2\mongodb-driver-core-3.8.2.jar;E:\maven\repository\org\springframework\boot\spring-boot-configuration-processor\2.1.4.RELEASE\spring-boot-configuration-processor-2.1.4.RELEASE.jar;E:\maven\repository\org\springframework\boot\spring-boot-devtools\2.1.4.RELEASE\spring-boot-devtools-2.1.4.RELEASE.jar;E:\maven\repository\org\springframework\boot\spring-boot\2.1.4.RELEASE\spring-boot-2.1.4.RELEASE.jar;E:\maven\repository\org\springframework\boot\spring-boot-autoconfigure\2.1.4.RELEASE\spring-boot-autoconfigure-2.1.4.RELEASE.jar;H:\JetBrains\IntelliJ IDEA 2019.1.3\lib\idea_rt.jar" com.zsx.MongoDBApplication
    Connected to the target VM, address: '127.0.0.1:51325', transport: 'socket'
    
      .   ____          _            __ _ _
     /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
    ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
     \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
      '  |____| .__|_| |_|_| |_\__, | / / / /
     =========|_|==============|___/=/_/_/_/
     :: Spring Boot ::        (v2.1.4.RELEASE)
    
    2019-07-09 00:19:28.788  INFO 11732 --- [  restartedMain] com.zsx.MongoDBApplication               : Starting MongoDBApplication on zsx with PID 11732 (F:\IdeaProjects\springbootmongodb\target\classes started by admin in F:\IdeaProjects\springbootmongodb)
    2019-07-09 00:19:28.791  INFO 11732 --- [  restartedMain] com.zsx.MongoDBApplication               : No active profile set, falling back to default profiles: default
    2019-07-09 00:19:28.842  INFO 11732 --- [  restartedMain] .e.DevToolsPropertyDefaultsPostProcessor : Devtools property defaults active! Set 'spring.devtools.add-properties' to 'false' to disable
    2019-07-09 00:19:28.842  INFO 11732 --- [  restartedMain] .e.DevToolsPropertyDefaultsPostProcessor : For additional web related logging consider setting the 'logging.level.web' property to 'DEBUG'
    2019-07-09 00:19:29.996  INFO 11732 --- [  restartedMain] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data repositories in DEFAULT mode.
    2019-07-09 00:19:30.067  INFO 11732 --- [  restartedMain] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 65ms. Found 1 repository interfaces.
    2019-07-09 00:19:30.824  INFO 11732 --- [  restartedMain] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
    2019-07-09 00:19:30.852  INFO 11732 --- [  restartedMain] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
    2019-07-09 00:19:30.852  INFO 11732 --- [  restartedMain] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/9.0.17]
    2019-07-09 00:19:30.861  INFO 11732 --- [  restartedMain] o.a.catalina.core.AprLifecycleListener   : An older version [1.2.16] of the APR based Apache Tomcat Native library is installed, while Tomcat recommends a minimum version of [1.2.21]
    2019-07-09 00:19:30.861  INFO 11732 --- [  restartedMain] o.a.catalina.core.AprLifecycleListener   : Loaded APR based Apache Tomcat Native library [1.2.16] using APR version [1.6.3].
    2019-07-09 00:19:30.868  INFO 11732 --- [  restartedMain] o.a.catalina.core.AprLifecycleListener   : APR capabilities: IPv6 [true], sendfile [true], accept filters [false], random [true].
    2019-07-09 00:19:30.868  INFO 11732 --- [  restartedMain] o.a.catalina.core.AprLifecycleListener   : APR/OpenSSL configuration: useAprConnector [false], useOpenSSL [true]
    2019-07-09 00:19:31.954  INFO 11732 --- [  restartedMain] o.a.catalina.core.AprLifecycleListener   : OpenSSL successfully initialized [OpenSSL 1.0.2m  2 Nov 2017]
    2019-07-09 00:19:32.070  INFO 11732 --- [  restartedMain] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
    2019-07-09 00:19:32.071  INFO 11732 --- [  restartedMain] o.s.web.context.ContextLoader            : Root WebApplicationContext: initialization completed in 3229 ms
    2019-07-09 00:19:32.618  INFO 11732 --- [  restartedMain] org.mongodb.driver.cluster               : Cluster created with settings {hosts=[localhost:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms', maxWaitQueueSize=500}
    2019-07-09 00:19:32.684  INFO 11732 --- [localhost:27017] org.mongodb.driver.connection            : Opened connection [connectionId{localValue:1, serverValue:212}] to localhost:27017
    2019-07-09 00:19:32.689  INFO 11732 --- [localhost:27017] org.mongodb.driver.cluster               : Monitor thread successfully connected to server with description ServerDescription{address=localhost:27017, type=STANDALONE, state=CONNECTED, ok=true, version=ServerVersion{versionList=[4, 0, 10]}, minWireVersion=0, maxWireVersion=7, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=3317333}
    2019-07-09 00:19:32.871  INFO 11732 --- [  restartedMain] o.s.b.d.a.OptionalLiveReloadServer       : LiveReload server is running on port 35729
    2019-07-09 00:19:33.365  INFO 11732 --- [  restartedMain] o.s.s.concurrent.ThreadPoolTaskExecutor  : Initializing ExecutorService 'applicationTaskExecutor'
    2019-07-09 00:19:33.627  INFO 11732 --- [  restartedMain] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
    2019-07-09 00:19:33.632  INFO 11732 --- [  restartedMain] com.zsx.MongoDBApplication               : Started MongoDBApplication in 5.356 seconds (JVM running for 6.608)

### 六、打开postman ###

**1. 查看请求[http://localhost:8080/api/v1/file/5d2357c5fbfab7259021c22d][http_localhost_8080_api_v1_file_5d2357c5fbfab7259021c22d]**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzeDE4MjczMTE3MDAz_size_16_color_FFFFFF_t_70][]

**2. 查看请求[http://localhost:8080/api/v1/file2/5d2357c5fbfab7259021c22d][http_localhost_8080_api_v1_file_5d2357c5fbfab7259021c22d] **

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzeDE4MjczMTE3MDAz_size_16_color_FFFFFF_t_70 1][]

**3. 查看请求[http://localhost:8080/api/v1/file/5d234d4efbfab724c88de9da][http_localhost_8080_api_v1_file_5d234d4efbfab724c88de9da]**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzeDE4MjczMTE3MDAz_size_16_color_FFFFFF_t_70 2][]

[springboot_mongodb]: https://mp.csdn.net/postedit/95102458
[http_localhost_8080_api_v1_file_5d2357c5fbfab7259021c22d]: http://localhost:8080/api/v1/file/5d2357c5fbfab7259021c22d
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzeDE4MjczMTE3MDAz_size_16_color_FFFFFF_t_70]: /images/20211211/4a0f8631cdaf4da9911a418dfda4a2b3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzeDE4MjczMTE3MDAz_size_16_color_FFFFFF_t_70 1]: /images/20211211/2e05ea7c8418408a80d2df017980ea55.png
[http_localhost_8080_api_v1_file_5d234d4efbfab724c88de9da]: http://localhost:8080/api/v1/file/5d234d4efbfab724c88de9da
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzeDE4MjczMTE3MDAz_size_16_color_FFFFFF_t_70 2]: /images/20211211/1b43a412156f45bc9a8669ca7d14d28a.png