Scala Akka HTTP强制转换参数为java.time.ZonedDateTime
我正在使用Akka HTTP（在Scala中）开发REST服务。我希望将传递给http get请求的参数转换为ZonedDateTime类型。如果我尝试使用String或Int，但使用ZonedDateTime类型失败，则代码工作正常。代码如下所示： parameters（'testparam.as [ZonedDateTime]） 这是我看到的错误： 错误：（23
..
akka-http相关内容
akka-http发送连续的分块http响应（流）
我有一个带有 akka-http 客户端和服务器的粗略测试示例。 Server.scala： import akka.actor.ActorSystem import akka.stream.ActorMaterializer import akka.stream.scaladsl。接收器 导入akka.http.scaladsl.Http 导入akka.http.scal
..
akka HttpResponse将主体读取为String scala
所以我有一个带有此签名的函数（akka.http.model.HttpResponse）： def apply（query： Seq [（String，String）]，accept：String）：HttpResponse 我只是得到一个值像这样的测试： val resp = TagAPI（Seq.empty [（String，String）]，api.acc
..
一个日志Akka HTTP客户端请求如何
我需要记录akka http客户端请求及其响应。尽管似乎有用于记录这些请求的API提示，但是没有明确的文档说明如何完成这些请求。我的方法是创建一个记录请求，该请求透明地包装 Http（）。singleRequest（req）如下： def loggingRequest（req：HttpRequest） （隐式系统：ActorSystem，ctx：ExecutionContext，m：实体化
..
Akka-http：接受和内容类型处理
我正在尝试Akka-http，希望有人可以阐明以下问题： 如何一个基于请求中的accept：标头创建不同的路由？例如，我想要一个代码路径来处理“ json”，一个代码路径来处理“ xml”请求（如果缺少标头，则默认为“ json”） 在不希望推断contentType的情况下，如何指定它？例如，在下面的代码中，我尝试通过compactPrint（）运行json，但这会将其更改为字符串，
..
使用Akka流有条件地跳过流
我正在使用akka流，但由于该流无法处理某些值，因此需要有条件跳过该图的一部分。具体来说，我有一个流程，它接受一个字符串并发出http请求，但是当字符串为空时，服务器无法处理这种情况。但是我只需要返回一个空字符串即可。有没有一种方法可以执行此操作而不必经历http请求，而知道它会失败？我基本上是这样的： val source = Source（“ 1”，“ 2”，“”，“ 3”，“ 4“）
..
Akka HTTP：将来阻止会阻止服务器
我正在尝试使用Akka HTTP对我的请求进行基本身份验证。 碰巧我需要外部资源进行身份验证，因此我必须对该资源进行调用。 这需要一些时间，并且在处理过程中，似乎我的API其余部分已被阻止，正在等待此调用。 我用一个非常简单的示例复制了它： //二手调度程序： 隐式val系统= ActorSystem（） 隐式val执行器= system.dispatcher 隐式val实现器
..
如何创建可以在以后通过方法调用接收元素的Source？
我想创建一个 Source ，然后在其上推送元素，例如： val src = ... //在此处创建源 // //然后执行如下操作： pushElement（x1，src） pushElement（x2， src） 推荐的方法是什么？ 谢谢！ 解决方案 可以通过三种方式实现： 1。使用SourceQueue发布实现 您可以使
..
如何在Akka中扩展超级演员的行为
我想使用akka actor实现CRUD操作。我是akka的新手，所以不知道akka演员的设计基础。 我想在多个子演员中分享akka演员的行为。 例如，我想保存和删除学生，老师和其他实体。 我为StudentDao.scala创建了演员 class StudentDao使用ActorLogging扩展Actor { 覆盖def接收= { 情况Add（student
..
Akka-http POST结果为“不支持服务器端HTTP版本".
尝试使用akka-http对某些内部端点进行简单的POST请求时遇到问题.执行这段代码后: for { request
..
Spray，Akka-http和Play，这是新HTTP/REST项目的最佳选择
我将使用Scala和Akka Actors开发新的HTTP/REST服务. 我有使用Play的经验，但是我真的不需要完整的Web框架. 根据我的阅读，我认为Spray是合适的选择. 我的问题来自新的AKKA-HTTP之后的Spray的未来. Spray项目是否将独立于Akka-HTTP项目发展，还是将两个项目合并为一个Akka-HTTTP? 如果我开始使用Spray开发，这会有什
..
Play Framework测试助手需要隐式`Materializer`
我正在使用Play 2.6.x，并且status(result)的测试助手具有以下方法: def status(of: Accumulator[ByteString, Result])(implicit timeout: Timeout, mat: Materializer): Int = status(of.run()) 当编译器找不到隐式值时，运行测试将抛出: could not fi
..
使用Play 2.6和Akka流的Websocket代理
我正在尝试使用Play和Akka流为Websocket连接创建一个简单的代理. 流量是这样的: (Client) request -> -> request (Server) Proxy (Client) response
..
akka-http在NewRelic中未显示指标
我正在尝试使用NewRelic监视我的akka-http Rest网络服务 该应用程序只有一个 GET网址(由akka-http定义) 我在 plugins.sbt 中具有以下配置 logLevel := Level.Warn addSbtPlugin("com.typesafe.sbt" % "sbt-native-packager" % "1.0.4") addSbtPlu
..
为什么Akka-Http仍然使用较旧的Akka-Actor?
我已将最新的akka-http添加到我的项目中，但其中包括akka-actor上非常老的2.4.19版本.因此，我还向依赖项添加了akka-actor版本2.5.4.但是，这导致以下错误:- Detected java.lang.NoSuchMethodError error, which MAY be caused by incompatible Akka versions on th
..
如何使akka-http logRequest日志到特定的记录器日志文件
我有一个Main非角色类，其中定义了路由. 我想将这些路由的传入请求记录到一个特定的日志文件中，但是它们正在被记录到“根"日志文件中. val logger = LoggerFactory.getLogger("access_log")l logger.info("log to access log") //
..
Kubernetes-Akka集群部署
我们有一个docker映像和一个相应的yaml文件，用于使用kubernetes进行部署.我们构建的应用程序在带有akka-http的scala中.我们使用了akka集群.我们在使用Pod ip的应用程序代码中使用的配置文件中，有一个特定的变量(在我们的情况下为种子节点-akka群集).但是，除非完成部署，否则我们不会获得Pod ip.我们应该如何解决这个问题?环境变量会有所帮助吗(如果是)如何?
..
如何使用Akka HTTP从多个actor / web处理程序正确调用单个服务器？
我有一个服务（让我们称之为服务A），它使用Akka Server HTTP来处理传入的请求。 此外，我还有第三方应用程序（服务B），它提供了多种Web服务。 服务A的目的是转换客户端请求，调用服务B的一个或多个Web服务，合并/转换结果并将其提供给客户端。 我在某些部分使用Actors，而在其他部分使用Future。 要拨打服务B，我使用Akka HTTP客户端。 Http.g
..
如何正确调用Akka HTTP客户端多个（10k - 100k）请求？
我正在尝试使用Akka HTTP 2.0-M2编写批量数据上传工具。 但是我面临 akka.stream.OverflowStrategy $ Fail $ BufferOverflowException：超出配置的最大开放请求值[32]错误。 我试图找出一个问题，这里的示例代码也失败了： public class TestMaxRequests { private static
..
如何使用trait聚合akka-http路由？
对象SMController { def aggregateRoutes（actorSystem：ActorSystem）：List [Route] = { val runtimeMirror = universe.runtimeMirror（getClass.getClassLoader） val reflections = new Reflections（“com.example.api
..