http - Quarkus - 响应式文件下载
问题描述
使用Quarkus,有人可以举例说明服务器和客户端代码如何使用响应式 API 通过 http 下载文件的外观吗?
到目前为止,我试图返回一个 Flux 的 nio ByteBuffers 但似乎不受支持:
@RegisterRestClient(baseUri = "http://some-page.com")
interface SomeService {
// same interface for client and server
@GET
@Produces(MediaType.APPLICATION_OCTET_STREAM)
@Path("/somePath")
fun downloadFile(): reactor.core.publisher.Flux<java.nio.ByteBuffer>
}
尝试在服务器端返回 Flux 会导致以下异常:
ERROR: RESTEASY002005: Failed executing GET /somePath
org.jboss.resteasy.core.NoMessageBodyWriterFoundFailure: Could not find MessageBodyWriter for response object of type: kotlinx.coroutines.reactor.FlowAsFlux of media type: application/octet-stream
at org.jboss.resteasy.core.ServerResponseWriter.lambda$writeNomapResponse$3(ServerResponseWriter.java:124)
at org.jboss.resteasy.core.interception.jaxrs.ContainerResponseContextImpl.filter(ContainerResponseContextImpl.java:403)
at org.jboss.resteasy.core.ServerResponseWriter.executeFilters(ServerResponseWriter.java:251)
...
解决方案
这是一个如何使用 smallrye mutiny 启动响应式文件下载的示例。主要功能是getFile
@GET
@Path("/f/{fileName}")
@Produces(MediaType.APPLICATION_OCTET_STREAM)
public Uni<Response> getFile(@PathParam String fileName) {
File nf = new File(fileName);
log.info("file:" + nf.exists());
ResponseBuilder response = Response.ok((Object) nf);
response.header("Content-Disposition", "attachment;filename=" + nf);
Uni<Response> re = Uni.createFrom().item(response.build());
return re;
}
您可以在本地进行测试mvn quarkus:dev
并转到此 url 以查看那里有哪些文件http://localhost:8080/hello/list/test之后您可以调用此 url 开始下载http://localhost:8080/你好/f/reactive-file-download-dev.jar
我没有检查 Flux(看起来比 quarkus 更多的春天),请随时分享你的想法。我只是在学习和回答/分享。
推荐阅读
- mongodb - Docker - Mongo 数据库实例未与应用程序连接
- c# - 如何在动态查询构建方法中使用逻辑替代
- python - 如何替换字符串中一起出现的 2 个或多个特殊字符或下划线 Python
- java - VLCJ:在 VLCJ 中使用 EmbeddedMediaPlayer 和 CallbackVideoSurface 直接渲染消耗高 CPU
- intersystems-cache - Intersystems Caché CSP DIRECTORY_ROOT
- javascript - 使用单选按钮更改网站 URL
- sql - 捕获 2 个数据集中的变化
- templates - 关于显示数据的自适应卡片问题
- java - 在 Java 中清理闭包的序列化
- python-3.x - 当我在我的 .csv 文件中写入数据时,数据变得混乱