【问题标题】:How to check if file was downloaded completely via Spring Rest Api如何通过 Spring Rest Api 检查文件是否已完全下载
【发布时间】:2018-02-03 06:31:35
【问题描述】:

我创建了简单的 rest api 来提供来自 hdfs 的文件(文件很大,我不想在本地复制它们)。

我想记录文件下载成功完成的信息,即读取整个流,但我不知道如何。我只能记录文件下载开始的信息。

我将不胜感激。

    @Autowired
    private FileDownloadService fds;

    @RequestMapping(value = GET_FILE_PATH, method = RequestMethod.GET)
    @Produces(MediaType.APPLICATION_OCTET_STREAM_VALUE)
    public ResponseEntity getFileStream(@RequestParam("name") String name) {
        LOG.info("Processing for filename: " + name);
        try {
            Path p = fds.getFilePath(name);
            org.apache.hadoop.fs.FSDataInputStream is = fds.getFileStream(p);

            return ResponseEntity.ok().header("Content-Disposition", "attachment; filename=\"" + p.getName() + "\"'").contentLength(fds.getFileLength(p))
                    .contentType(MediaType.APPLICATION_OCTET_STREAM).body(new InputStreamResource(is));

        } catch (Exception e) {
            LOG.error(e.getLocalizedMessage(), e);
            return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body("Internal Server Error");
        } finally {
           LOG.info("File: " + name + " download started");
        }
    }

【问题讨论】:

    标签: java spring rest hadoop


    【解决方案1】:

    您可以尝试在 InputStream 上创建一个包装器并在流关闭时触发一些标志 (close())。

    比如你可以以ProxyInputStream为基础:

     ProxyInputStreamis = new ProxyInputStream(fds.getFileStream(p)) {
        @Override
        public void close() throws IOException {
                super.close();
                // some trigger
        }
     };
    

    【讨论】:

    • 这很有帮助。谢谢你。但我仍然不知道如何区分该文件已完全下载或例如操作已中止。
    • ProxyInputStream 有一个实现 CountingInputStream - 您可以使用它并将文件大小与close() 方法中的读取字节数进行比较
    猜你喜欢
    • 2013-05-18
    • 1970-01-01
    • 1970-01-01
    • 2014-11-29
    • 2021-04-26
    • 1970-01-01
    • 2020-06-14
    • 2021-12-23
    • 1970-01-01
    相关资源
    最近更新 更多