SpringBoot接口内部从sftp服务器获取文件流实现文件下载
@GetMapping("/voice/file/download")@ApiOperation("语音文件--按id下载录音文件")@RequestLog(businessType = BusinessType.SELECT)public void downloadFile(@RequestParam("recfilename") String recfilename, HttpServletResponse response) throws IOException {ChannelSftp channel = (ChannelSftp) SftpUtil.initialChannel(null, sftpCtiConfiguration.getAccountSftp(), sftpCtiConfiguration.getEntranceTicketSftp(), sftpCtiConfiguration.getServerIp(), sftpCtiConfiguration.getPortSftp(), "180000");if (channel == null) {log.error(this.getClass().getSimpleName() + "#callVoiceFileList, step0:初始化连接sftp服务器失败！");emailUtil.sendMail("获取语音文件失败，初始化连接sftp服务器失败！请联系相关人员进行人工处理，谢谢！", "Connect sftp server failed");throw new BusinessException("连接cti服务器失败，请排查配置信息！");}InputStream inputStream;try {inputStream = channel.get(recfilename);} catch (SftpException e) {log.error("获取文件失败", e);emailUtil.sendMail("获取语音文件失败，请联系相关人员进行人工处理，谢谢！", "Get file failed");throw new BusinessException("获取文件失败");}String filename = recfilename.substring(recfilename.lastIndexOf("/") + 1);response.setCharacterEncoding("utf-8");response.setContentType("application/octet-stream");// 对真实文件名进行百分号编码String percentEncodedFileName = URLEncoder.encode(filename, "utf-8").replaceAll("\\+", "%20");// 组装contentDisposition的值StringBuilder contentDispositionValue = new StringBuilder();contentDispositionValue.append("attachment; filename=").append(percentEncodedFileName).append(";").append("filename*=").append("utf-8''").append(percentEncodedFileName);response.setHeader("Content-disposition",contentDispositionValue.toString());response.setHeader("filename", java.net.URLEncoder.encode(filename, "UTF-8"));// 将文件流写到response中try (OutputStream outputStream = response.getOutputStream()) {IOUtils.copy(inputStream, outputStream);} catch (IOException e) {log.error("文件下载失败！", e);throw new BusinessException("文件下载失败！");}log.info(this.getClass().getSimpleName() + "#downloadFile(),文件下载完毕！");}
