akka-http

0热度

1回答

是否有可能在akka.http.javadsl.server.Route和akka.http.scaladsl.server.Route之间进行转换

我想知道是否可以将一个实例转换为另一个实例。如果是这样，那我该怎么做呢？我在akka-http文档中没有发现任何提及。我正在尝试编写一个实现Java接口的类，该接口返回akka-http应用程序的基本路由，但内部我想在Scala中实现该类。

0热度

2回答

为什么我的地图（）不工作？

我有它返回一个字符串，如下所示的阿卡HTTP服务： val route1: Route = { path("hello") { get{ complete{ println("Inside r1") "You just accessed hello" } } } } 我想了解地图和flatMap

1热度

2回答

Akka-http定制404页面

我想在akka-http（高级DSL）中创建一个定制的404页面。这基本上意味着：返回从我的静态文件夹页（如资源/网络/ 404.html）将结果代码ResultCodes.NOT_FOUND 我试过到目前为止什么： getFromResource - 我可以返回实体，但我无法弄清楚如何覆盖响应的HTTP结果代码，所以我可以将它设置为'404'。 complete（） - 我可以返回正确的代码

0热度

1回答

阿卡流+阿卡的Http传递参数

我有下面的代码片段： case class SomeClass(param1:String,param2:String,param3:String) val someClassActorSource: Source[SomeClass, ActorRef] = Source .actorPublisher[SomeClass](Props[SomeClassActorPub

1热度

1回答

使用接收内存的Akka http流越来越多

我已经使用AKK HTTP流来实现WebSocket服务器。但是，客户端每分钟发送大量数据。所以连接在客户端和服务器之间保持连接。在实现web套接字处理程序时，我使用了流和接收器。并使用Sink.seq。接收器是一直在收集传入元素，直到上游终止。我该如何避免它？ implicit val system = ActorSystem("DecoderSystem") implicit v

2热度

1回答

如何从Akka中执行SQL？

从Akka应用程序发出SQL语句的惯用Akka方法是什么？具体来说，我有一个想要执行SQL命令的Akka Http REST端点。有一些官方的SQL支持或异步或消息传递风格的SQL库吗？

0热度

1回答

allowedOrigins不工作在AKK HTTP服务器

我已经在本地主机上设置了一个AKK HTTP服务器，端口为8091.我使用XMLHttpRequest POST从客户端向它发送数据，但它显示警告说我的跨源请求被阻止，因为“Access-Control-Allow-Origin”标题不存在。所以，我添加了CORS支持。我的代码看起来像： import akka.actor.ActorSystem import akka.stream.Actor

2热度

2回答

akka-http：从http路由发送元素到akka接收器

如何从Akka HTTP路由发送元素/消息到Akka接收器？我的HTTP路由仍然需要返回一个正常的HTTP响应。我想这需要一个流分支/结。正常的HTTP路由是来自HttpRequest - > HttpResponse的流。我想添加一个分支/联结，以便HttpRequests可以触发事件到我单独的接收器以及生成正常的HttpResponse。下面是一个非常简单的单路akka-http应用程序。

0热度

1回答

Akka http读取并解析上传的excel文件

假如我有一个需要从客户端上传到服务器的excel文件（大小范围从0〜100MB），那么它会被解析。如何用Akka-Http做到这一点？我看了doc，看来他们只支持json和csv格式。另外，从服务器端的角度来看，我是否必须在文件上传之后才解析文件，或者只要在上传过程中可用，我就可以一次解析一个数据条目？

3热度

1回答

阿卡HTTP连接池挂起时间

的夫妇后，我有一对夫妇的运行小时后挂起的HTTP连接池： private def createHttpPool(host: String): SourceQueue[(HttpRequest, Promise[HttpResponse])] = { val pool = Http().cachedHostConnectionPoolHttps[Promise[HttpResponse]]