Akka HTTP层的目的是通过HTTP将Actors暴露给Web,并使它们能够将HTTP服务作为客户端使用。它不是HTTP框架,它是一个基于Actor的工具包,用于与Web服务和客户端进行交互。
假设我们有以下请求:curl --location --request POST'localhost:8080 / api'\ --header'Content-Type:multipart / form-data'\ --form'field1 = value1'\- -form'field2 = value2'...
我有以下代码:val serverSource = Http()。bind(“ localhost”,8080)val connectionSink = Sink.foreach [IncomingConnection] {connection => println(s“接受了来自$ {...的传入连接
我有一系列看起来像这样的路径; path(“ slides” / Segment){segment => getFromDirectory(s“ $ {cfg.slidesDir} / $ segment”)}〜path(“ foo” / Segment){segment => getFromDirectory(s“ $ {...
我正在尝试在Akka HTTP中创建一个HTTP请求,该请求将能够通过HTTP请求发送两个字符串“ string1”和“ string2”。我目前有以下代码可以处理简单的...
我想使用kamon-akka-http,目前我的项目具有Kamon捆绑包依赖关系,其中包含kamon akka http。问题是我从其他所有指标中收到了许多其他指标...
我对学习Scala,Akka Streams和Akka HTTP并不陌生,因此如果问题太简单,请事先道歉。我想在HTTP请求中执行HTTP请求,就像在下面的...
akka http handleNotFound拒绝仅适用于POST方法
我有以下来自https://doc.akka.io/docs/akka-http/current/routing-dsl/rejections.html的akka http拒绝处理代码val message =“找不到所请求的资源。 ” ...
我正在使用带有spray-json的akka -http将rest API移植到scala。旧的API有以下响应:{“ result”:{...},“ error”:null}现在,我想保持精确的后退...
im试图使用elasticmq-rest-sqs运行sqs服务器:“ org.elasticmq” %%“ elasticmq-rest-sqs”%“ 0.14.7”,我的akka 依赖项是:val akka = Seq(“ com.lightbend .akka“ %%” akka-stream -...
我发现自己努力为我们的akka -http java应用程序启用https支持。文档页面(https://doc.akka.io/docs/akka-http/current/server-side/server-https-support.html)应该是...
akka.streams。您可以发出值的源(类似于monix.BehaviorSubject)
我正在寻找akka.stream.scaladsl.Source构造方法,该方法可让我简单地从不同代码位置发出下一个值(例如,监视系统事件)。我需要类似于...
akka.UnsupportedAkkaVersion:Akka的当前版本是[2.5.14],但是akka-http需要版本[2.5.26]
这里是课程:import akka.Done;导入akka.NotUsed;导入akka.actor.ActorSystem;导入akka.http.javadsl.ConnectHttp;导入akka.http.javadsl.Http;导入akka.http.javadsl.model ....
我是Scala的新手。我正在尝试从Akka HTTP的optionalCookie方法获取Cookie。我想使用此optionalCookie(“ user_session”)的输出以其他方法传递。如果我运行它...
找不到参数um的隐式值:akka.http.scaladsl.unmarshalling.FromRequestUnmarshaller [class]
我是akka http的新手,在整理和解压缩我的case类时遇到困难,这是我的代码case类Event(uuid:String)//主类class demo {val route:Route = ...
如何捕获从Future [HttpResponse] scala中抛出的异常
我是scala的新手。我正在使用scala的HTTP客户端来攻击另一台服务器。返回的响应是Future [HttpResponse]。这是我的一些东西:pathPrefix(“ run”){post {...
我遇到了我不理解的编译错误:[错误] /Users/nicu/mooc-reactive/akkahttp-typed-actors-cluster-ORMap-followers/src/main/scala/followers/HttpServer.scala :43:76:类型...
是否有使用Circe库处理REST API中的PATCH请求的通用方法?默认情况下,circe不允许仅使用指定字段的一部分解码部分JSON,即它需要...
我们计划创建少量新的微服务作为我们平台的一部分。当前,我们所有的微服务都基于Java-Spring,并且我们使用docker / kubernetes进行扩展。我们现在计划评估...
在RabbitMQ中将HTTP请求/响应与异步消息集成在一起
我们的应用程序是一个消息处理系统,具有与RabbitMQ队列连接的多个组件。因此消息处理是异步的。现在,我需要添加一个与...
我正在研究akka http上的教程。但是想知道akka演员模型是如何在akka http中实现的。有人可以解释一下吗?