akka-http

1热度

2回答

处理（序列化，实际上..）在akka-http中的DeserializationException

我需要在我的http响应中将异常消息编码为特定的JSON格式。我想知道如何在我的路由或其外部捕获DeserializationException或编码DeserializationException。我试过如下： 1）异常在我的路由处理： val exceptionHandler = ExceptionHandler { case e: DeserializationException

6热度

1回答

关闭Akka HTTP应用程序

我有一个正在运行的Akka HTTP应用程序，我想关闭它。按按Ctrl +Ç在does not work SBT对我来说（我的壳是目前的Git的Bash适用于Windows）。优雅地关闭Akka应用程序的建议方法是什么？

1热度

1回答

在泊坞窗内运行的akka-http应用程序

我有一个在本地工作正常的akka-http应用程序，我遇到了一些“dockerizing”应用程序的问题。我通过Dockerfile构建docker镜像并使用docker-entrypoint来执行java -jar命令。当我第一次访问正在运行的Docker容器时，应用程序未运行，但如果我访问容器并手动执行java -jar命令，则应用程序可以正常启动。如果我执行以下命令（容器内）的应用程序启

2热度

1回答

Akka.net持久性参与者恢复失败，消息更改为新属性

使用持久性参与者将消息持久存入SQL Server数据库。初始消息格式如下。系统几次运行这种格式，并且这些消息中的许多消息被保存。目前我改变了消息格式以包含如下的几个属性。有人能给我一个想法如何解决这个问题吗？目前我面临的问题是恢复最初的持久消息与新的更改失败，并给出如下错误。 “重播persistenceId [tz-persistent-factory]的事件时发生持久性失败。最后已知序列号

1热度

1回答

斯卡拉阿卡-HTTP - 一个预建的JSON对象完整的GET请求并流呢

我想通过返回预建JsonArray完成一个GET请求，并找到一种方法来流呢。我可以很容易地完成请求没有任何错误，并返回JSON，如果我转换JsonArray为字符串，像这样： get { path("getJsonData") { parameterMap { params => complete(HttpEntity(ContentTypes.`app

2热度

2回答

从演员返回实际结果而不是承诺/未来

我正在尝试在Akka/Scala中编写一个调用HTTP REST API的演员，并将结果发回给主叫演员。 API可能会返回必须首先转换为内部供应商中性格式的结果的集合/向量，以便将来可以更改供应商，而无需对代码进行太多的更改。大部分的代码工作，但我不知道如何解压缩并发送内部向量。这是我拥有的代码，它会将Promise返回给调用actor。我想回到的是，获取最终的map操作所创建的实际载体： cl

0热度

1回答

Ipv4 ClientIp上extractClientIp - > akka-http

我怎样才能得到ipv4客户端ip在akka-http下java？在我createRoute方法，我尝试： return extractClientIP(clientIp -> { Optional<InetAddress> optAdd = clientIp.getAddress(); return complete(optAdd.get().getClass().g

2热度

1回答

使用阿卡HTTP和瑟茜在斯卡拉

我想创建阿卡的Http REST后端点的JSON对象映射到所定义的情况下，类解码JSON import io.circe.Decoder, io.circe.generic.auto._ case class JobEntity(id: Option[Long] = None, name: String, description: String, json_data :java.sql.blo

0热度

1回答

如何使用Akka actors来处理Akka中的HTTP请求

我是一般的Akka HTTP和Scala的新手。我正在尝试使用Akka actors来处理HTTP请求。当遇到HTTP请求时，相应的子actor被激活。目前，这是我的演员逻辑： trait CorsDirective extends BasicDirectives { actor: Actor => private def createResponder(requestContext:

0热度

1回答

Server.route不符合预期的类型的RequestContext [阿卡，斯卡拉]

我试图玩弄这个例子http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/http/directives/coding-directives/decodeRequest.html 1 def routesWithCompression = { 2 time() { 3 count() { 4 dec