cloud-product生产者发布的接口,将文件内容写入HttpServletResponse中
@GetMapping(value = "/file") public void downloadFile(@RequestParam String path, HttpServletResponse response) { }
cloud-consumer消费者声明feign接口,在controller中测试下载文件
@Component
@FeignClient(contextId = "file", value = "cloud-provider", fallback = RemoteFileBackFactory.class)
public interface FileDownloadService {
@GetMapping(value = "/product/file", consumes = MediaType.APPLICATION_PROBLEM_JSON_VALUE)
Response downloadFile(@RequestParam String path);
}
@GetMapping(value = "/file") public void downloadFile(@RequestParam String path, HttpServletResponse response) { InputStream inputStream = null; try { Response serviceResponse = this.fileDownloadService.downloadFile(path); Response.Body body = serviceResponse.body(); inputStream = body.asInputStream(); BufferedInputStream bufferedInputStream = new BufferedInputStream(inputStream); response.setHeader("Content-Disposition", serviceResponse.headers().get("Content-Disposition").toString().replace("[","").replace("]","")); BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(response.getOutputStream()); int length = 0; byte[] temp = new byte[1024 * 10]; while ((length = bufferedInputStream.read(temp)) != -1) { bufferedOutputStream.write(temp, 0, length); } bufferedOutputStream.flush(); bufferedOutputStream.close(); bufferedInputStream.close(); inputStream.close(); } catch (IOException e) { e.printStackTrace(); } }