这是类(class): import akka.Done; import akka.NotUsed; import akka.actor.ActorSystem; import akka.http.javadsl.ConnectHttp; import akka.http.javadsl.Http; import akka.http.javadsl.model.ContentTypes; import akka.http.javadsl.model.HttpEntities; import akka.http.ja…

2020年3月29日 0条评论 36点热度 阅读全文

我是akka-http的新手,遇到一个问题:有一个路由返回一个带有特定格式报告的文件。当请求一个xlsx文件时,用户会收到一个文件夹, 您可以在report.xlsx中重命名此文件夹并获取正常工作的excel文件 我以数组[bytes]的形式发送xlsx文件使用akka-http 10.0.5 也许有人遇到这样的问题: path("api" / "reports" / "downloadReport") { get { parameters('format, 'jobId.as[Long]) { (format, …

2019年9月18日 0条评论 16点热度 阅读全文

我有一个要求客户调用通过akka http创建的post REST端点。一旦请求进入post方法,我就需要将post对象传递给流(由源,多个流和接收器组成),并从接收器获取响应,以便可以将响应返回给客户端。 我浏览了一些文章,并看了下面的代码,但担心我不想为每个请求实现流。我只想实现一个流,并继续将元素传递到该流。 以下是我所看到的高层次: val route: Route = path("dummy path") { p => get { (extract(_.request) & extractM…

2019年5月6日 0条评论 31点热度 阅读全文

我发现自己努力为我们的akka​​-http java应用程序启用https支持。文档页面(https://doc.akka.io/docs/akka-http/current/server-side/server-https-support.html)应该有所帮助,但由于某种原因,它没有帮助。 从我从该页面得到的内容开始,我的想法是获取一个HttpsConnectionContext实例并将其用作http.setDefaultClientHttpsContext(...)方法调用的参数,然后实际进行一些路由绑定。…

2019年4月30日 0条评论 63点热度 阅读全文

这是类(class): import akka.Done; import akka.NotUsed; import akka.actor.ActorSystem; import akka.http.javadsl.ConnectHttp; import akka.http.javadsl.Http; import akka.http.javadsl.model.ContentTypes; import akka.http.javadsl.model.HttpEntities; import akka.http.ja…

2019年4月18日 0条评论 38点热度 阅读全文

即使没有负载,Kubernetes上的Akka应用也面临着延迟的心跳。 还经常出现以下警告: heartbeat interval is growing too large for address ... 我试图为集群添加自定义调度程序,即使是针对每个特定参与者也是如此,但是并没有帮助。我没有做任何阻塞操作,因为它只是一个简单的Http服务器。 群集加载后,节点将变得不可达。 我创建了一个可用于重现此问题的存储库: https://github.com/CostasChaitas/Akka-Demo 解决方案如下:…

2019年1月9日 0条评论 24点热度 阅读全文